Documentation ¶
Index ¶
- Constants
- Variables
- func AppendPermissionFilterToQuery(query string, sTable string, sGTable string, user userModels.User) string
- func Contains(array []int, value int) bool
- func ValidateURL(url string) bool
- type Service
- func (service *Service) BalanceUrl() string
- func (service *Service) Call(method string, uri string, headers map[string]string, body string) *fasthttp.Response
- func (service *Service) GenerateId() bson.ObjectId
- func (service *Service) GenerateIdentifier() string
- func (service *Service) GetGroup() (servicegroup.ServiceGroup, error)
- func (service *Service) GetHost() string
- func (service *Service) GetManagementEndpoint(managementType string) string
- func (service *Service) GetManagementEndpointMethod(managementType string) string
- func (service *Service) NormalizeService()
- func (service *Service) ServiceManagementCall(managementType string) (bool, string)
- type ServiceMongoRepository
- func (smr *ServiceMongoRepository) CreateService(s Service) (Service, error)
- func (smr *ServiceMongoRepository) DeleteService(s Service) error
- func (smr *ServiceMongoRepository) Find(s Service) (Service, error)
- func (smr *ServiceMongoRepository) ListAllAvailableHosts() ([]string, error)
- func (smr *ServiceMongoRepository) ListServices(page int, filterQuery string) []Service
- func (smr *ServiceMongoRepository) NormalizeServices() error
- func (smr *ServiceMongoRepository) Update(service Service, serviceExists Service) (int, error)
- type ServiceOracleRepository
- func (smo *ServiceOracleRepository) AddHostsToService(s Service, tx *sql.Tx) error
- func (smo *ServiceOracleRepository) CreateService(s Service) (Service, error)
- func (smo *ServiceOracleRepository) DeleteHostsFromService(s Service, tx *sql.Tx) error
- func (smo *ServiceOracleRepository) DeleteService(s Service) error
- func (smo *ServiceOracleRepository) Find(s Service) (Service, error)
- func (smo *ServiceOracleRepository) ListAllAvailableHosts() ([]string, error)
- func (smo *ServiceOracleRepository) ListServices(page int, filterQuery string) []Service
- func (smo *ServiceOracleRepository) NormalizeServices() error
- func (smo *ServiceOracleRepository) Update(service Service, serviceExists Service) (int, error)
- func (smo *ServiceOracleRepository) VerifyServiceMatchingCollision(s Service, tx *sql.Tx) error
- type ServiceRepositoryInterface
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 ValidateURL ¶
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 (*Service) BalanceUrl ¶
func (*Service) GenerateId ¶
func (*Service) GenerateIdentifier ¶
func (*Service) GetGroup ¶
func (service *Service) GetGroup() (servicegroup.ServiceGroup, error)
func (*Service) GetManagementEndpoint ¶
func (*Service) GetManagementEndpointMethod ¶
func (*Service) NormalizeService ¶
func (service *Service) NormalizeService()
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
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
Click to show internal directories.
Click to hide internal directories.