service

package
v0.0.0-...-9b02830 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 12, 2019 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const USER_PERMISSION_CHECK = "id in (select service_id from gapi_user_services_permissions c where c.user_id = '##USER_ID##') or 1 = ##IS_USER_ADMIN##"

Variables

View Source
var DELETE_SERVICES_ORACLE = `delete from gapi_services where id = :id`
View Source
var DELETE_SERVICE_HOSTS_ORACLE = "delete from gapi_services_hosts where service_id = :sid"
View Source
var FIND_COLLISIONS = `select count(*) total 
from gapi_services a where a.matchinguri like :newmatchinguri and a.matchinguri <> :matchinguri`
View Source
var FIND_SERVICES_ORACLE = `select ` + SERVICE_COLUMNS +
	` from gapi_services a left join gapi_services_groups b on a.groupid = b.id where (a.id = :id or regexp_like(matchinguri, :matchinguriregex) or a.identifier = :identifier) `
View Source
var INSERT_SERVICE_HOSTS_ORACLE = "INSERT INTO gapi_services_hosts(service_id, domain) VALUES(:sid, :domain)"
View Source
var INSERT_SERVICE_ORACLE = `` /* 708-byte string literal not displayed */
View Source
var LIST_SERVICES_ORACLE = `select ` + SERVICE_COLUMNS + ` 
	from gapi_services a left join gapi_services_groups b on a.groupid = b.id where 
	(upper(a.name) like upper(:name) or upper(a.matchinguri) like upper(:matchinguri)) `
View Source
var SERVICE_COLUMNS = `` /* 410-byte string literal not displayed */
View Source
var SERVICE_DISTINCT_HOSTS_ORACLE = `SELECT distinct domain from gapi_services_hosts`
View Source
var UPDATE_SERVICE_ORACLE = `` /* 763-byte string literal not displayed */

Functions

func AppendPermissionFilterToQuery

func AppendPermissionFilterToQuery(query string, sTable string, sGTable string, user userModels.User) string

func Contains

func Contains(array []int, value int) bool

func ValidateURL

func ValidateURL(url string) bool

Types

type Service

type Service struct {
	Id                         bson.ObjectId `bson:"_id" json:"Id"`
	Identifier                 string
	Name                       string
	Hosts                      []string
	Domain                     string
	Port                       string
	MatchingURI                string
	MatchingURIRegex           string
	ToURI                      string
	Protected                  bool
	APIDocumentation           string
	IsCachingActive            bool
	IsActive                   bool
	HealthcheckUrl             string
	LastActiveTime             int64
	ServiceManagementHost      string
	ServiceManagementPort      string
	ServiceManagementEndpoints map[string]string
	RateLimit                  int
	RateLimitExpirationTime    int64
	IsReachable                bool
	GroupId                    bson.ObjectId `bson:"groupid,omitempty" json:"GroupId"`
	GroupVisibility            bool
	UseGroupAttributes         bool
	ProtectedExclude           map[string]string
}

func FindServiceInList

func FindServiceInList(s Service, services []Service) (Service, error)

func RowsToService

func RowsToService(rows *sql.Rows, containsPagination bool) []Service

func (*Service) BalanceUrl

func (service *Service) BalanceUrl() string

func (*Service) Call

func (service *Service) Call(method string, uri string, headers map[string]string, body string) *fasthttp.Response

func (*Service) GenerateId

func (service *Service) GenerateId() bson.ObjectId

func (*Service) GenerateIdentifier

func (service *Service) GenerateIdentifier() string

func (*Service) GetGroup

func (service *Service) GetGroup() (servicegroup.ServiceGroup, error)

func (*Service) GetHost

func (service *Service) GetHost() string

func (*Service) GetManagementEndpoint

func (service *Service) GetManagementEndpoint(managementType string) string

func (*Service) GetManagementEndpointMethod

func (service *Service) GetManagementEndpointMethod(managementType string) string

func (*Service) NormalizeService

func (service *Service) NormalizeService()

func (*Service) ServiceManagementCall

func (service *Service) ServiceManagementCall(managementType string) (bool, string)

type ServiceMongoRepository

type ServiceMongoRepository struct {
	User userModels.User
}

func (*ServiceMongoRepository) CreateService

func (smr *ServiceMongoRepository) CreateService(s Service) (Service, error)

func (*ServiceMongoRepository) DeleteService

func (smr *ServiceMongoRepository) DeleteService(s Service) error

func (*ServiceMongoRepository) Find

func (smr *ServiceMongoRepository) Find(s Service) (Service, error)

func (*ServiceMongoRepository) ListAllAvailableHosts

func (smr *ServiceMongoRepository) ListAllAvailableHosts() ([]string, error)

func (*ServiceMongoRepository) ListServices

func (smr *ServiceMongoRepository) ListServices(page int, filterQuery string) []Service

func (*ServiceMongoRepository) NormalizeServices

func (smr *ServiceMongoRepository) NormalizeServices() error

func (*ServiceMongoRepository) Update

func (smr *ServiceMongoRepository) Update(service Service, serviceExists Service) (int, error)

type ServiceOracleRepository

type ServiceOracleRepository struct {
	User userModels.User
}

func (*ServiceOracleRepository) AddHostsToService

func (smo *ServiceOracleRepository) AddHostsToService(s Service, tx *sql.Tx) error

func (*ServiceOracleRepository) CreateService

func (smo *ServiceOracleRepository) CreateService(s Service) (Service, error)

func (*ServiceOracleRepository) DeleteHostsFromService

func (smo *ServiceOracleRepository) DeleteHostsFromService(s Service, tx *sql.Tx) error

func (*ServiceOracleRepository) DeleteService

func (smo *ServiceOracleRepository) DeleteService(s Service) error

func (*ServiceOracleRepository) Find

func (smo *ServiceOracleRepository) Find(s Service) (Service, error)

func (*ServiceOracleRepository) ListAllAvailableHosts

func (smo *ServiceOracleRepository) ListAllAvailableHosts() ([]string, error)

func (*ServiceOracleRepository) ListServices

func (smo *ServiceOracleRepository) ListServices(page int, filterQuery string) []Service

func (*ServiceOracleRepository) NormalizeServices

func (smo *ServiceOracleRepository) NormalizeServices() error

func (*ServiceOracleRepository) Update

func (smo *ServiceOracleRepository) Update(service Service, serviceExists Service) (int, error)

func (*ServiceOracleRepository) VerifyServiceMatchingCollision

func (smo *ServiceOracleRepository) VerifyServiceMatchingCollision(s Service, tx *sql.Tx) error

type ServiceRepositoryInterface

type ServiceRepositoryInterface interface {
	Update(service Service, serviceExists Service) (int, error)
	CreateService(s Service) (Service, error)
	ListServices(page int, filterQuery string) []Service
	DeleteService(s Service) error
	Find(s Service) (Service, error)
	ListAllAvailableHosts() ([]string, error)
	NormalizeServices() error
}

func GetServicesRepository

func GetServicesRepository(user userModels.User) ServiceRepositoryInterface

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL