service

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CT_K8S  = "kubernetes"
	CT_DCOS = "dcos"
	CT_EDAS = "edas"
)
View Source 
const (
	ZONE_TYPE_DICE_APP       = "diceApp" //已废弃
	ZONE_TYPE_PACKAGE        = "package" // 老的入口
	ZONE_TYPE_PACKAGE_NEW    = "packageNew"
	ZONE_TYPE_PACKAGE_API    = "packageApi"
	ZONE_TYPE_UNITY          = "unity"
	ZONE_TYPE_UNITY_Provider = "unityProvider"
)

Variables

View Source 
var GLOBAL_REGIONS = []string{"option", "main", "http", "server"}
View Source 
var ZONE_REGIONS = []string{"annotation", "location"}

Functions

This section is empty.

Types

type AdminProjectDto 

type AdminProjectDto struct {
	Name          string            `json:"name"`
	ClusterConfig map[string]string `json:"clusterConfig"`
}

type AdminRespDto 

type AdminRespDto struct {
	Success bool            `json:"success"`
	Data    AdminProjectDto `json:"data"`
}

type ClusterInfoDto 

type ClusterInfoDto struct {
	DiceClusterType string `json:"DICE_CLUSTER_TYPE"`
	DiceRootDomain  string `json:"DICE_ROOT_DOMAIN"`
	MasterAddr      string `json:"MASTER_VIP_ADDR"`
	NetportalUrl    string `json:"NETPORTAL_URL"`
	GatewayProvider string `json:"GATEWAY_PROVIDER"`
}

type ClusterRespDto 

type ClusterRespDto struct {
	Success bool           `json:"success"`
	Data    ClusterInfoDto `json:"data"`
}

type ConfigInfo 

type ConfigInfo struct {
	ConfigItem
	IsolationConfig ConfigItem `json:"ISOLATION_CONFIG"`
	IsolationEnvs   []string   `json:"ISOLATION_ENVS"`
	ProjectName     string     `json:"PROJECT_NAME"`
}

type ConfigItem 

type ConfigItem struct {
	GatewayEndpoint string `json:"GATEWAY_ENDPOINT"`
	VipKongHost     string `json:"VIP_KONG_HOST"`
	ProxyKongPort   string `json:"PROXY_KONG_PORT"`
	AdminEndpoint   string `json:"ADMIN_ENDPOINT"`
	DiceAddon       string `json:"GATEWAY_INSTANCE_ID"`
}

type GatewayApiInPackageService 

type GatewayApiInPackageService interface {
	NewSession(...*SessionHelper) (GatewayApiInPackageService, error)
	Insert(*GatewayApiInPackage) error
	Delete(packageId, apiId string) error
	DeleteByPackageId(string) error
	// use for delete or update api check
	SelectByApi(string) ([]GatewayApiInPackage, error)
}

type GatewayApiInPackageServiceImpl 

type GatewayApiInPackageServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayApiInPackageServiceImpl 

func NewGatewayApiInPackageServiceImpl() (*GatewayApiInPackageServiceImpl, error)

func (*GatewayApiInPackageServiceImpl) Delete 

func (impl *GatewayApiInPackageServiceImpl) Delete(packageId, apiId string) error

func (*GatewayApiInPackageServiceImpl) DeleteByPackageId 

func (impl *GatewayApiInPackageServiceImpl) DeleteByPackageId(packageId string) error

func (*GatewayApiInPackageServiceImpl) Get 

func (impl *GatewayApiInPackageServiceImpl) Get(id string) (*orm.GatewayApiInPackage, error)

func (*GatewayApiInPackageServiceImpl) GetByAny 

func (impl *GatewayApiInPackageServiceImpl) GetByAny(cond *orm.GatewayApiInPackage) (*orm.GatewayApiInPackage, error)

func (*GatewayApiInPackageServiceImpl) Insert 

func (impl *GatewayApiInPackageServiceImpl) Insert(dao *orm.GatewayApiInPackage) error

func (*GatewayApiInPackageServiceImpl) NewSession 

func (impl *GatewayApiInPackageServiceImpl) NewSession(helper ...*SessionHelper) (GatewayApiInPackageService, error)

func (*GatewayApiInPackageServiceImpl) SelectByAny 

func (impl *GatewayApiInPackageServiceImpl) SelectByAny(cond *orm.GatewayApiInPackage) ([]orm.GatewayApiInPackage, error)

func (*GatewayApiInPackageServiceImpl) SelectByApi 

func (impl *GatewayApiInPackageServiceImpl) SelectByApi(id string) ([]orm.GatewayApiInPackage, error)

func (*GatewayApiInPackageServiceImpl) Update 

func (impl *GatewayApiInPackageServiceImpl) Update(dao *orm.GatewayApiInPackage) error

type GatewayApiService 

type GatewayApiService interface {
	NewSession(...*SessionHelper) (GatewayApiService, error)
	Insert(*GatewayApi) error
	GetPage(options []SelectOption, page *Page) (*PageQuery, error)
	Count(options []SelectOption) (int64, error)
	GetPageByConsumerId(consumerId string, page *Page) (*PageQuery, error)
	CountByConsumerId(consumerId string) (int64, error)
	GetById(string) (*GatewayApi, error)
	GetByAny(*GatewayApi) (*GatewayApi, error)
	GetRawByAny(*GatewayApi) (*GatewayApi, error)
	SelectByGroupId(string) ([]GatewayApi, error)
	RealDeleteById(string) error
	DeleteById(string) error
	Update(*GatewayApi) error
	SelectByOptions(options []SelectOption) ([]GatewayApi, error)
	SelectByAny(*GatewayApi) ([]GatewayApi, error)
	RealDeleteByRuntimeServiceId(string) error
}

type GatewayApiServiceImpl 

type GatewayApiServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayApiServiceImpl 

func NewGatewayApiServiceImpl() (*GatewayApiServiceImpl, error)

func (*GatewayApiServiceImpl) Count 

func (impl *GatewayApiServiceImpl) Count(options []orm.SelectOption) (int64, error)

func (*GatewayApiServiceImpl) CountByConsumerId 

func (impl *GatewayApiServiceImpl) CountByConsumerId(consumerId string) (int64, error)

func (*GatewayApiServiceImpl) DeleteById 

func (impl *GatewayApiServiceImpl) DeleteById(id string) error

func (*GatewayApiServiceImpl) GetByAny 

func (impl *GatewayApiServiceImpl) GetByAny(cond *orm.GatewayApi) (*orm.GatewayApi, error)

func (*GatewayApiServiceImpl) GetById 

func (impl *GatewayApiServiceImpl) GetById(id string) (*orm.GatewayApi, error)

func (*GatewayApiServiceImpl) GetPage 

func (impl *GatewayApiServiceImpl) GetPage(options []orm.SelectOption, page *common.Page) (*common.PageQuery, error)

func (*GatewayApiServiceImpl) GetPageByConsumerId 

func (impl *GatewayApiServiceImpl) GetPageByConsumerId(consumerId string, page *common.Page) (*common.PageQuery, error)

func (*GatewayApiServiceImpl) GetRawByAny 

func (impl *GatewayApiServiceImpl) GetRawByAny(cond *orm.GatewayApi) (*orm.GatewayApi, error)

func (*GatewayApiServiceImpl) Insert 

func (impl *GatewayApiServiceImpl) Insert(api *orm.GatewayApi) error

func (*GatewayApiServiceImpl) NewSession 

func (impl *GatewayApiServiceImpl) NewSession(helper ...*SessionHelper) (GatewayApiService, error)

func (*GatewayApiServiceImpl) RealDeleteById 

func (impl *GatewayApiServiceImpl) RealDeleteById(id string) error

func (*GatewayApiServiceImpl) RealDeleteByRuntimeServiceId 

func (impl *GatewayApiServiceImpl) RealDeleteByRuntimeServiceId(id string) error

func (*GatewayApiServiceImpl) SelectByAny 

func (impl *GatewayApiServiceImpl) SelectByAny(cond *orm.GatewayApi) ([]orm.GatewayApi, error)

func (*GatewayApiServiceImpl) SelectByGroupId 

func (impl *GatewayApiServiceImpl) SelectByGroupId(id string) ([]orm.GatewayApi, error)

func (*GatewayApiServiceImpl) SelectByOptions 

func (impl *GatewayApiServiceImpl) SelectByOptions(options []orm.SelectOption) ([]orm.GatewayApi, error)

func (*GatewayApiServiceImpl) Update 

func (impl *GatewayApiServiceImpl) Update(api *orm.GatewayApi) error

type GatewayAzInfoService 

type GatewayAzInfoService interface {
	GetAz(*GatewayAzInfo) (string, error)
	GetAzInfoByClusterName(name string) (*orm.GatewayAzInfo, *ClusterInfoDto, error)
	GetAzInfo(*GatewayAzInfo) (*GatewayAzInfo, error)
	SelectByAny(*GatewayAzInfo) ([]GatewayAzInfo, error)
	SelectValidAz() ([]GatewayAzInfo, error)
}

type GatewayAzInfoServiceImpl 

type GatewayAzInfoServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayAzInfoServiceImpl 

func NewGatewayAzInfoServiceImpl() (*GatewayAzInfoServiceImpl, error)

func (*GatewayAzInfoServiceImpl) GetAz 

func (impl *GatewayAzInfoServiceImpl) GetAz(cond *orm.GatewayAzInfo) (string, error)

func (*GatewayAzInfoServiceImpl) GetAzInfo 

func (impl *GatewayAzInfoServiceImpl) GetAzInfo(cond *orm.GatewayAzInfo) (*orm.GatewayAzInfo, error)

func (*GatewayAzInfoServiceImpl) GetAzInfoByClusterName 

func (impl *GatewayAzInfoServiceImpl) GetAzInfoByClusterName(name string) (*orm.GatewayAzInfo, *ClusterInfoDto, error)

func (*GatewayAzInfoServiceImpl) SelectByAny 

func (impl *GatewayAzInfoServiceImpl) SelectByAny(cond *orm.GatewayAzInfo) ([]orm.GatewayAzInfo, error)

func (*GatewayAzInfoServiceImpl) SelectValidAz 

func (impl *GatewayAzInfoServiceImpl) SelectValidAz() ([]orm.GatewayAzInfo, error)

type GatewayConfig 

type GatewayConfig struct {
	Success bool       `json:"success"`
	Data    ConfigInfo `json:"data"`
}

type GatewayConsumerApiService 

type GatewayConsumerApiService interface {
	Insert(*GatewayConsumerApi) error
	Update(*GatewayConsumerApi) error
	DeleteById(id string) error
	GetByConsumerAndApi(string, string) (*GatewayConsumerApi, error)
	GetById(string) (*GatewayConsumerApi, error)
	SelectByConsumer(string) ([]GatewayConsumerApi, error)
	SelectByApi(string) ([]GatewayConsumerApi, error)
}

type GatewayConsumerApiServiceImpl 

type GatewayConsumerApiServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayConsumerApiServiceImpl 

func NewGatewayConsumerApiServiceImpl() (*GatewayConsumerApiServiceImpl, error)

func (*GatewayConsumerApiServiceImpl) DeleteById 

func (impl *GatewayConsumerApiServiceImpl) DeleteById(id string) error

func (*GatewayConsumerApiServiceImpl) GetByConsumerAndApi 

func (impl *GatewayConsumerApiServiceImpl) GetByConsumerAndApi(consumerId string, apiId string) (*orm.GatewayConsumerApi, error)

func (*GatewayConsumerApiServiceImpl) GetById 

func (impl *GatewayConsumerApiServiceImpl) GetById(id string) (*orm.GatewayConsumerApi, error)

func (*GatewayConsumerApiServiceImpl) Insert 

func (impl *GatewayConsumerApiServiceImpl) Insert(api *orm.GatewayConsumerApi) error

func (*GatewayConsumerApiServiceImpl) SelectByApi 

func (impl *GatewayConsumerApiServiceImpl) SelectByApi(apiId string) ([]orm.GatewayConsumerApi, error)

func (*GatewayConsumerApiServiceImpl) SelectByConsumer 

func (impl *GatewayConsumerApiServiceImpl) SelectByConsumer(consumerId string) ([]orm.GatewayConsumerApi, error)

func (*GatewayConsumerApiServiceImpl) Update 

func (impl *GatewayConsumerApiServiceImpl) Update(api *orm.GatewayConsumerApi) error

type GatewayConsumerService 

type GatewayConsumerService interface {
	Get(*GatewayConsumer) (*GatewayConsumer, error)
	GetDefaultConsumerName(*GatewayConsumer) string
	GetDefaultConsumer(*GatewayConsumer) (*GatewayConsumer, error)
	GetByName(name string) (*GatewayConsumer, error)
	Insert(*GatewayConsumer) error
	Update(*GatewayConsumer) error
	GetById(string) (*GatewayConsumer, error)
	SelectByAny(*GatewayConsumer) ([]GatewayConsumer, error)
	GetByAny(*GatewayConsumer) (*GatewayConsumer, error)
	DeleteById(string) error
	CheckUnique(*GatewayConsumer) (bool, error)
	GetPage(options []SelectOption, page *Page) (*PageQuery, error)
	Count(options []SelectOption) (int64, error)
	SelectByOptions(options []SelectOption) ([]GatewayConsumer, error)
	GetByConsumerId(consumerId string) (*orm.GatewayConsumer, error)
}

type GatewayConsumerServiceImpl 

type GatewayConsumerServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayConsumerServiceImpl 

func NewGatewayConsumerServiceImpl() (*GatewayConsumerServiceImpl, error)

func (*GatewayConsumerServiceImpl) CheckUnique 

func (impl *GatewayConsumerServiceImpl) CheckUnique(consumer *orm.GatewayConsumer) (bool, error)

func (*GatewayConsumerServiceImpl) Count 

func (impl *GatewayConsumerServiceImpl) Count(options []orm.SelectOption) (int64, error)

func (*GatewayConsumerServiceImpl) DeleteById 

func (impl *GatewayConsumerServiceImpl) DeleteById(id string) error

func (*GatewayConsumerServiceImpl) Get 

func (impl *GatewayConsumerServiceImpl) Get(cond *orm.GatewayConsumer) (*orm.GatewayConsumer, error)

func (*GatewayConsumerServiceImpl) GetByAny 

func (impl *GatewayConsumerServiceImpl) GetByAny(cond *orm.GatewayConsumer) (*orm.GatewayConsumer, error)

func (*GatewayConsumerServiceImpl) GetByConsumerId 

func (impl *GatewayConsumerServiceImpl) GetByConsumerId(consumerId string) (*orm.GatewayConsumer, error)

func (*GatewayConsumerServiceImpl) GetById 

func (impl *GatewayConsumerServiceImpl) GetById(id string) (*orm.GatewayConsumer, error)

func (*GatewayConsumerServiceImpl) GetByName 

func (impl *GatewayConsumerServiceImpl) GetByName(name string) (*orm.GatewayConsumer, error)

func (*GatewayConsumerServiceImpl) GetDefaultConsumer 

func (impl *GatewayConsumerServiceImpl) GetDefaultConsumer(cond *orm.GatewayConsumer) (*orm.GatewayConsumer, error)

func (*GatewayConsumerServiceImpl) GetDefaultConsumerName 

func (impl *GatewayConsumerServiceImpl) GetDefaultConsumerName(dao *orm.GatewayConsumer) string

func (*GatewayConsumerServiceImpl) GetPage 

func (impl *GatewayConsumerServiceImpl) GetPage(options []orm.SelectOption, page *common.Page) (*common.PageQuery, error)

func (*GatewayConsumerServiceImpl) Insert 

func (impl *GatewayConsumerServiceImpl) Insert(consumer *orm.GatewayConsumer) error

func (*GatewayConsumerServiceImpl) SelectByAny 

func (impl *GatewayConsumerServiceImpl) SelectByAny(cond *orm.GatewayConsumer) ([]orm.GatewayConsumer, error)

func (*GatewayConsumerServiceImpl) SelectByOptions 

func (impl *GatewayConsumerServiceImpl) SelectByOptions(options []orm.SelectOption) ([]orm.GatewayConsumer, error)

func (*GatewayConsumerServiceImpl) Update 

func (impl *GatewayConsumerServiceImpl) Update(consumer *orm.GatewayConsumer) error

type GatewayCredentialService 

type GatewayCredentialService interface {
	Insert(credential *GatewayCredential) error
	Update(*GatewayCredential) error
	DeleteById(id string) error
	DeleteByConsumerId(consumerId string) error
	GetByConsumerAndApi(string, string) (*GatewayCredential, error)
	GetById(string) (*GatewayCredential, error)
	GetByConsumerId(string) (*GatewayCredential, error)
	SelectByConsumerId(string) ([]GatewayCredential, error)
}

type GatewayCredentialServiceImpl 

type GatewayCredentialServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayCredentialServiceImpl 

func NewGatewayCredentialServiceImpl() (*GatewayCredentialServiceImpl, error)

func (*GatewayCredentialServiceImpl) DeleteByConsumerId 

func (impl *GatewayCredentialServiceImpl) DeleteByConsumerId(consumerId string) error

func (*GatewayCredentialServiceImpl) DeleteById 

func (impl *GatewayCredentialServiceImpl) DeleteById(id string) error

func (*GatewayCredentialServiceImpl) GetByConsumerAndApi 

func (impl *GatewayCredentialServiceImpl) GetByConsumerAndApi(apiId string, consumerId string) (*orm.GatewayCredential, error)

func (*GatewayCredentialServiceImpl) GetByConsumerId 

func (impl *GatewayCredentialServiceImpl) GetByConsumerId(consumerId string) (*orm.GatewayCredential, error)

func (*GatewayCredentialServiceImpl) GetById 

func (impl *GatewayCredentialServiceImpl) GetById(id string) (*orm.GatewayCredential, error)

func (*GatewayCredentialServiceImpl) Insert 

func (impl *GatewayCredentialServiceImpl) Insert(credential *orm.GatewayCredential) error

func (*GatewayCredentialServiceImpl) SelectByConsumerId 

func (impl *GatewayCredentialServiceImpl) SelectByConsumerId(consumerId string) ([]orm.GatewayCredential, error)

func (*GatewayCredentialServiceImpl) Update 

func (impl *GatewayCredentialServiceImpl) Update(credential *orm.GatewayCredential) error

type GatewayDefaultPolicyService 

type GatewayDefaultPolicyService interface {
	NewSession(...*SessionHelper) (GatewayDefaultPolicyService, error)
	CreateOrUpdate(*GatewayDefaultPolicy) error
	Insert(*GatewayDefaultPolicy) error
	GetByAny(*GatewayDefaultPolicy) (*GatewayDefaultPolicy, error)
	SelectByAny(*GatewayDefaultPolicy) ([]GatewayDefaultPolicy, error)
	Update(*GatewayDefaultPolicy) error
}

type GatewayDefaultPolicyServiceImpl 

type GatewayDefaultPolicyServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayDefaultPolicyServiceImpl 

func NewGatewayDefaultPolicyServiceImpl() (*GatewayDefaultPolicyServiceImpl, error)

func (*GatewayDefaultPolicyServiceImpl) CreateOrUpdate 

func (impl *GatewayDefaultPolicyServiceImpl) CreateOrUpdate(dao *orm.GatewayDefaultPolicy) error

func (*GatewayDefaultPolicyServiceImpl) GetByAny 

func (impl *GatewayDefaultPolicyServiceImpl) GetByAny(cond *orm.GatewayDefaultPolicy) (*orm.GatewayDefaultPolicy, error)

func (*GatewayDefaultPolicyServiceImpl) Insert 

func (impl *GatewayDefaultPolicyServiceImpl) Insert(defaultPolicy *orm.GatewayDefaultPolicy) error

func (*GatewayDefaultPolicyServiceImpl) NewSession 

func (impl *GatewayDefaultPolicyServiceImpl) NewSession(helper ...*SessionHelper) (GatewayDefaultPolicyService, error)

func (*GatewayDefaultPolicyServiceImpl) SelectByAny 

func (impl *GatewayDefaultPolicyServiceImpl) SelectByAny(cond *orm.GatewayDefaultPolicy) ([]orm.GatewayDefaultPolicy, error)

func (*GatewayDefaultPolicyServiceImpl) Update 

func (impl *GatewayDefaultPolicyServiceImpl) Update(policy *orm.GatewayDefaultPolicy) error

type GatewayDomainService 

type GatewayDomainService interface {
	NewSession(...*SessionHelper) (GatewayDomainService, error)
	Insert(*GatewayDomain) error
	Update(*GatewayDomain) error
	Delete(string) error
	Get(string) (*GatewayDomain, error)
	DeleteByAny(*GatewayDomain) (int64, error)
	SelectByAny(*GatewayDomain) ([]GatewayDomain, error)
	GetByAny(*GatewayDomain) (*GatewayDomain, error)
	GetPage(options []SelectOption, page *Page) (*PageQuery, error)
	SelectByOptions(options []SelectOption) ([]GatewayDomain, error)
}

type GatewayDomainServiceImpl 

type GatewayDomainServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayDomainServiceImpl 

func NewGatewayDomainServiceImpl() (*GatewayDomainServiceImpl, error)

func (*GatewayDomainServiceImpl) Count 

func (impl *GatewayDomainServiceImpl) Count(options []orm.SelectOption) (int64, error)

func (*GatewayDomainServiceImpl) Delete 

func (impl *GatewayDomainServiceImpl) Delete(id string) error

func (*GatewayDomainServiceImpl) DeleteByAny 

func (impl *GatewayDomainServiceImpl) DeleteByAny(cond *orm.GatewayDomain) (int64, error)

func (*GatewayDomainServiceImpl) Get 

func (impl *GatewayDomainServiceImpl) Get(id string) (*orm.GatewayDomain, error)

func (*GatewayDomainServiceImpl) GetByAny 

func (impl *GatewayDomainServiceImpl) GetByAny(cond *orm.GatewayDomain) (*orm.GatewayDomain, error)

func (*GatewayDomainServiceImpl) GetPage 

func (impl *GatewayDomainServiceImpl) GetPage(options []orm.SelectOption, page *common.Page) (*common.PageQuery, error)

func (*GatewayDomainServiceImpl) Insert 

func (impl *GatewayDomainServiceImpl) Insert(dao *orm.GatewayDomain) error

func (*GatewayDomainServiceImpl) NewSession 

func (impl *GatewayDomainServiceImpl) NewSession(helper ...*SessionHelper) (GatewayDomainService, error)

func (*GatewayDomainServiceImpl) SelectByAny 

func (impl *GatewayDomainServiceImpl) SelectByAny(cond *orm.GatewayDomain) ([]orm.GatewayDomain, error)

func (*GatewayDomainServiceImpl) SelectByOptions 

func (impl *GatewayDomainServiceImpl) SelectByOptions(options []orm.SelectOption) ([]orm.GatewayDomain, error)

func (*GatewayDomainServiceImpl) Update 

func (impl *GatewayDomainServiceImpl) Update(dao *orm.GatewayDomain) error

type GatewayExtraService 

type GatewayExtraService interface {
	GetByKeyAndField(key string, field string) (*GatewayExtra, error)
}

type GatewayExtraServiceImpl 

type GatewayExtraServiceImpl struct {
	// contains filtered or unexported fields
}

func (*GatewayExtraServiceImpl) GetByKeyAndField 

func (impl *GatewayExtraServiceImpl) GetByKeyAndField(key string, field string) (*orm.GatewayExtra, error)

type GatewayGroupService 

type GatewayGroupService interface {
	Insert(*GatewayGroup) error
	GetPageByConsumerId(consumerId string, page *Page) (*PageQuery, error)
	CountByConsumerId(consumerId string) (int64, error)
	DeleteById(groupId string) error
	Update(*GatewayGroup) error
	GetById(groupId string) (*GatewayGroup, error)
	GetByNameAndConsumerId(groupName string, consumerId string) (*GatewayGroup, error)
}

type GatewayGroupServiceImpl 

type GatewayGroupServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayGroupServiceImpl 

func NewGatewayGroupServiceImpl() (*GatewayGroupServiceImpl, error)

func (*GatewayGroupServiceImpl) CountByConsumerId 

func (impl *GatewayGroupServiceImpl) CountByConsumerId(consumerId string) (int64, error)

func (*GatewayGroupServiceImpl) DeleteById 

func (impl *GatewayGroupServiceImpl) DeleteById(id string) error

func (*GatewayGroupServiceImpl) GetById 

func (impl *GatewayGroupServiceImpl) GetById(id string) (*orm.GatewayGroup, error)

func (*GatewayGroupServiceImpl) GetByNameAndConsumerId 

func (impl *GatewayGroupServiceImpl) GetByNameAndConsumerId(name string, id string) (*orm.GatewayGroup, error)

func (*GatewayGroupServiceImpl) GetPageByConsumerId 

func (impl *GatewayGroupServiceImpl) GetPageByConsumerId(consumerId string, page *common.Page) (*common.PageQuery, error)

func (*GatewayGroupServiceImpl) Insert 

func (impl *GatewayGroupServiceImpl) Insert(group *orm.GatewayGroup) error

func (*GatewayGroupServiceImpl) Update 

func (impl *GatewayGroupServiceImpl) Update(group *orm.GatewayGroup) error

type GatewayHubInfoService 

type GatewayHubInfoService interface {
	NewSession(...*SessionHelper) (GatewayHubInfoService, error)
	GetByAny(*GatewayHubInfo) (*GatewayHubInfo, bool, error)
	SelectByAny(*GatewayHubInfo) ([]GatewayHubInfo, error)
	Insert(*GatewayHubInfo) error
}

func NewGatewayHubInfoServiceImpl 

func NewGatewayHubInfoServiceImpl() (GatewayHubInfoService, error)

type GatewayHubInfoServiceImpl 

type GatewayHubInfoServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func (*GatewayHubInfoServiceImpl) GetByAny 

func (impl *GatewayHubInfoServiceImpl) GetByAny(cond *orm.GatewayHubInfo) (*orm.GatewayHubInfo, bool, error)

func (*GatewayHubInfoServiceImpl) Insert 

func (impl *GatewayHubInfoServiceImpl) Insert(dao *orm.GatewayHubInfo) error

func (*GatewayHubInfoServiceImpl) NewSession 

func (impl *GatewayHubInfoServiceImpl) NewSession(helper ...*SessionHelper) (GatewayHubInfoService, error)

func (*GatewayHubInfoServiceImpl) SelectByAny 

func (impl *GatewayHubInfoServiceImpl) SelectByAny(cond *orm.GatewayHubInfo) ([]orm.GatewayHubInfo, error)

type GatewayIngressPolicyService 

type GatewayIngressPolicyService interface {
	NewSession(...*SessionHelper) (GatewayIngressPolicyService, error)
	Insert(*GatewayIngressPolicy) error
	GetByAny(*GatewayIngressPolicy) (*GatewayIngressPolicy, error)
	SelectByAny(*GatewayIngressPolicy) ([]GatewayIngressPolicy, error)
	Update(*GatewayIngressPolicy) error
	UpdatePartial(*GatewayIngressPolicy, ...string) error
	CreateOrUpdate(*GatewayIngressPolicy) error
	GetChangesByRegions(az, regions string, zoneId ...string) (*IngressChanges, error)
	GetChangesByRegionsImpl(az, regions string, zoneId ...string) (*IngressChanges, error)
}

type GatewayIngressPolicyServiceImpl 

type GatewayIngressPolicyServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayIngressPolicyServiceImpl 

func NewGatewayIngressPolicyServiceImpl() (*GatewayIngressPolicyServiceImpl, error)

func (*GatewayIngressPolicyServiceImpl) CreateOrUpdate 

func (impl *GatewayIngressPolicyServiceImpl) CreateOrUpdate(dao *orm.GatewayIngressPolicy) error

func (*GatewayIngressPolicyServiceImpl) GetByAny 

func (impl *GatewayIngressPolicyServiceImpl) GetByAny(cond *orm.GatewayIngressPolicy) (*orm.GatewayIngressPolicy, error)

func (*GatewayIngressPolicyServiceImpl) GetChangesByRegions 

func (impl *GatewayIngressPolicyServiceImpl) GetChangesByRegions(az, regions string, zoneId ...string) (*IngressChanges, error)

func (*GatewayIngressPolicyServiceImpl) GetChangesByRegionsImpl 

func (impl *GatewayIngressPolicyServiceImpl) GetChangesByRegionsImpl(az, regions string, zoneId ...string) (*IngressChanges, error)

func (*GatewayIngressPolicyServiceImpl) Insert 

func (impl *GatewayIngressPolicyServiceImpl) Insert(ingressPolicy *orm.GatewayIngressPolicy) error

func (*GatewayIngressPolicyServiceImpl) NewSession 

func (impl *GatewayIngressPolicyServiceImpl) NewSession(helper ...*SessionHelper) (GatewayIngressPolicyService, error)

func (*GatewayIngressPolicyServiceImpl) SelectByAny 

func (impl *GatewayIngressPolicyServiceImpl) SelectByAny(cond *orm.GatewayIngressPolicy) ([]orm.GatewayIngressPolicy, error)

func (*GatewayIngressPolicyServiceImpl) Update 

func (impl *GatewayIngressPolicyServiceImpl) Update(policy *orm.GatewayIngressPolicy) error

func (*GatewayIngressPolicyServiceImpl) UpdatePartial 

func (impl *GatewayIngressPolicyServiceImpl) UpdatePartial(policy *orm.GatewayIngressPolicy, fields ...string) error

type GatewayKongInfoService 

type GatewayKongInfoService interface {
	NewSession(...*SessionHelper) (GatewayKongInfoService, error)
	Update(*GatewayKongInfo) error
	Insert(*GatewayKongInfo) error
	GetTenantId(projectId, env, az string) (string, error)
	GetByAny(*GatewayKongInfo) (*GatewayKongInfo, error)
	SelectByAny(cond *orm.GatewayKongInfo) ([]orm.GatewayKongInfo, error)
	GetForUpdate(projectId, env, az string) (*GatewayKongInfo, error)
	GenK8SInfo(kongInfo *orm.GatewayKongInfo) (string, string, error)
	GetKongInfo(*GatewayKongInfo) (*GatewayKongInfo, error)
	GetK8SInfo(*GatewayKongInfo) (string, string, error)
	GetBelongTuples(instanceId string) ([]KongBelongTuple, error)
}

type GatewayKongInfoServiceImpl 

type GatewayKongInfoServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayKongInfoServiceImpl 

func NewGatewayKongInfoServiceImpl() (*GatewayKongInfoServiceImpl, error)

func (*GatewayKongInfoServiceImpl) GenK8SInfo 

func (impl *GatewayKongInfoServiceImpl) GenK8SInfo(kongInfo *orm.GatewayKongInfo) (string, string, error)

func (*GatewayKongInfoServiceImpl) GetBelongTuples 

func (impl *GatewayKongInfoServiceImpl) GetBelongTuples(instanceId string) ([]KongBelongTuple, error)

func (*GatewayKongInfoServiceImpl) GetByAny 

func (impl *GatewayKongInfoServiceImpl) GetByAny(cond *orm.GatewayKongInfo) (*orm.GatewayKongInfo, error)

func (*GatewayKongInfoServiceImpl) GetForUpdate 

func (impl *GatewayKongInfoServiceImpl) GetForUpdate(projectId, env, az string) (*orm.GatewayKongInfo, error)

func (*GatewayKongInfoServiceImpl) GetK8SInfo 

func (impl *GatewayKongInfoServiceImpl) GetK8SInfo(cond *orm.GatewayKongInfo) (string, string, error)

func (*GatewayKongInfoServiceImpl) GetKongInfo 

func (impl *GatewayKongInfoServiceImpl) GetKongInfo(cond *orm.GatewayKongInfo) (*orm.GatewayKongInfo, error)

func (*GatewayKongInfoServiceImpl) GetTenantId 

func (impl *GatewayKongInfoServiceImpl) GetTenantId(projectId, env, az string) (string, error)

func (*GatewayKongInfoServiceImpl) Insert 

func (impl *GatewayKongInfoServiceImpl) Insert(info *orm.GatewayKongInfo) error

func (*GatewayKongInfoServiceImpl) NewSession 

func (impl *GatewayKongInfoServiceImpl) NewSession(helper ...*SessionHelper) (GatewayKongInfoService, error)

func (*GatewayKongInfoServiceImpl) SelectByAny 

func (impl *GatewayKongInfoServiceImpl) SelectByAny(cond *orm.GatewayKongInfo) ([]orm.GatewayKongInfo, error)

func (*GatewayKongInfoServiceImpl) Update 

func (impl *GatewayKongInfoServiceImpl) Update(info *orm.GatewayKongInfo) error

type GatewayMockService 

type GatewayMockService interface {
	Update(*GatewayMock) error
	Insert(*GatewayMock) error
	GetMockByAny(*GatewayMock) (*GatewayMock, error)
}

type GatewayMockServiceImpl 

type GatewayMockServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayMockServiceImpl 

func NewGatewayMockServiceImpl() (*GatewayMockServiceImpl, error)

func (*GatewayMockServiceImpl) GetMockByAny 

func (impl *GatewayMockServiceImpl) GetMockByAny(cond *orm.GatewayMock) (*orm.GatewayMock, error)

func (*GatewayMockServiceImpl) Insert 

func (impl *GatewayMockServiceImpl) Insert(mock *orm.GatewayMock) error

func (*GatewayMockServiceImpl) Update 

func (impl *GatewayMockServiceImpl) Update(mock *orm.GatewayMock) error

type GatewayOrgClientService 

type GatewayOrgClientService interface {
	NewSession(...*SessionHelper) (GatewayOrgClientService, error)
	Insert(*GatewayOrgClient) error
	GetByAny(*GatewayOrgClient) (*GatewayOrgClient, error)
	GetById(string) (*GatewayOrgClient, error)
	Update(*GatewayOrgClient) error
	DeleteById(string) error
	SelectByAny(*GatewayOrgClient) ([]GatewayOrgClient, error)
	CheckUnique(*GatewayOrgClient) (bool, error)
}

type GatewayOrgClientServiceImpl 

type GatewayOrgClientServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayOrgClientServiceImpl 

func NewGatewayOrgClientServiceImpl() (*GatewayOrgClientServiceImpl, error)

func (*GatewayOrgClientServiceImpl) CheckUnique 

func (impl *GatewayOrgClientServiceImpl) CheckUnique(orgClient *orm.GatewayOrgClient) (bool, error)

func (*GatewayOrgClientServiceImpl) DeleteById 

func (impl *GatewayOrgClientServiceImpl) DeleteById(id string) error

func (*GatewayOrgClientServiceImpl) GetByAny 

func (impl *GatewayOrgClientServiceImpl) GetByAny(cond *orm.GatewayOrgClient) (*orm.GatewayOrgClient, error)

func (*GatewayOrgClientServiceImpl) GetById 

func (impl *GatewayOrgClientServiceImpl) GetById(id string) (*orm.GatewayOrgClient, error)

func (*GatewayOrgClientServiceImpl) Insert 

func (impl *GatewayOrgClientServiceImpl) Insert(orgClient *orm.GatewayOrgClient) error

func (*GatewayOrgClientServiceImpl) NewSession 

func (impl *GatewayOrgClientServiceImpl) NewSession(helper ...*SessionHelper) (GatewayOrgClientService, error)

func (*GatewayOrgClientServiceImpl) SelectByAny 

func (impl *GatewayOrgClientServiceImpl) SelectByAny(cond *orm.GatewayOrgClient) ([]orm.GatewayOrgClient, error)

func (*GatewayOrgClientServiceImpl) Update 

func (impl *GatewayOrgClientServiceImpl) Update(orgClient *orm.GatewayOrgClient) error

type GatewayPackageApiInConsumerService 

type GatewayPackageApiInConsumerService interface {
	NewSession(...*SessionHelper) (GatewayPackageApiInConsumerService, error)
	Insert(*GatewayPackageApiInConsumer) error
	Delete(packageId, packageApiId, consumerId string) error
	DeleteByConsumerId(string) error
	// use for show
	SelectByConsumer(string) ([]GatewayPackageApiInConsumer, error)
	SelectByPackageApi(string, string) ([]GatewayPackageApiInConsumer, error)
}

type GatewayPackageApiInConsumerServiceImpl 

type GatewayPackageApiInConsumerServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayPackageApiInConsumerServiceImpl 

func NewGatewayPackageApiInConsumerServiceImpl() (*GatewayPackageApiInConsumerServiceImpl, error)

func (*GatewayPackageApiInConsumerServiceImpl) Delete 

func (impl *GatewayPackageApiInConsumerServiceImpl) Delete(packageId, packageApiId, consumerId string) error

func (*GatewayPackageApiInConsumerServiceImpl) DeleteByConsumerId 

func (impl *GatewayPackageApiInConsumerServiceImpl) DeleteByConsumerId(id string) error

func (*GatewayPackageApiInConsumerServiceImpl) Get 

func (impl *GatewayPackageApiInConsumerServiceImpl) Get(id string) (*orm.GatewayPackageApiInConsumer, error)

func (*GatewayPackageApiInConsumerServiceImpl) GetByAny 

func (impl *GatewayPackageApiInConsumerServiceImpl) GetByAny(cond *orm.GatewayPackageApiInConsumer) (*orm.GatewayPackageApiInConsumer, error)

func (*GatewayPackageApiInConsumerServiceImpl) Insert 

func (impl *GatewayPackageApiInConsumerServiceImpl) Insert(dao *orm.GatewayPackageApiInConsumer) error

func (*GatewayPackageApiInConsumerServiceImpl) NewSession 

func (impl *GatewayPackageApiInConsumerServiceImpl) NewSession(helper ...*SessionHelper) (GatewayPackageApiInConsumerService, error)

func (*GatewayPackageApiInConsumerServiceImpl) SelectByAny 

func (impl *GatewayPackageApiInConsumerServiceImpl) SelectByAny(cond *orm.GatewayPackageApiInConsumer) ([]orm.GatewayPackageApiInConsumer, error)

func (*GatewayPackageApiInConsumerServiceImpl) SelectByConsumer 

func (impl *GatewayPackageApiInConsumerServiceImpl) SelectByConsumer(id string) ([]orm.GatewayPackageApiInConsumer, error)

func (*GatewayPackageApiInConsumerServiceImpl) SelectByPackageApi 

func (impl *GatewayPackageApiInConsumerServiceImpl) SelectByPackageApi(packageId, packageApiId string) ([]orm.GatewayPackageApiInConsumer, error)

func (*GatewayPackageApiInConsumerServiceImpl) Update 

func (impl *GatewayPackageApiInConsumerServiceImpl) Update(dao *orm.GatewayPackageApiInConsumer) error

type GatewayPackageApiService 

type GatewayPackageApiService interface {
	NewSession(...*SessionHelper) (GatewayPackageApiService, error)
	Insert(*GatewayPackageApi) error
	GetPage(options []SelectOption, page *Page) (*PageQuery, error)
	Count(options []SelectOption) (int64, error)
	Update(*GatewayPackageApi, ...string) error
	Delete(string) error
	DeleteByPackageDiceApi(string, string) error
	Get(string) (*GatewayPackageApi, error)
	SelectByAny(*GatewayPackageApi) ([]GatewayPackageApi, error)
	GetByAny(*GatewayPackageApi) (*GatewayPackageApi, error)
	GetRawByAny(*GatewayPackageApi) (*GatewayPackageApi, error)
	DeleteByPackageId(string) error
	CheckUnique(*GatewayPackageApi) (bool, error)
	SelectByOptions(options []orm.SelectOption) ([]orm.GatewayPackageApi, error)
}

type GatewayPackageApiServiceImpl 

type GatewayPackageApiServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayPackageApiServiceImpl 

func NewGatewayPackageApiServiceImpl() (*GatewayPackageApiServiceImpl, error)

func (*GatewayPackageApiServiceImpl) CheckUnique 

func (impl *GatewayPackageApiServiceImpl) CheckUnique(dao *orm.GatewayPackageApi) (bool, error)

func (*GatewayPackageApiServiceImpl) Count 

func (impl *GatewayPackageApiServiceImpl) Count(options []orm.SelectOption) (int64, error)

func (*GatewayPackageApiServiceImpl) Delete 

func (impl *GatewayPackageApiServiceImpl) Delete(id string) error

func (*GatewayPackageApiServiceImpl) DeleteByPackageDiceApi 

func (impl *GatewayPackageApiServiceImpl) DeleteByPackageDiceApi(packageId, diceApiId string) error

func (*GatewayPackageApiServiceImpl) DeleteByPackageId 

func (impl *GatewayPackageApiServiceImpl) DeleteByPackageId(packageId string) error

func (*GatewayPackageApiServiceImpl) Get 

func (impl *GatewayPackageApiServiceImpl) Get(id string) (*orm.GatewayPackageApi, error)

func (*GatewayPackageApiServiceImpl) GetByAny 

func (impl *GatewayPackageApiServiceImpl) GetByAny(cond *orm.GatewayPackageApi) (*orm.GatewayPackageApi, error)

func (*GatewayPackageApiServiceImpl) GetPage 

func (impl *GatewayPackageApiServiceImpl) GetPage(options []orm.SelectOption, page *common.Page) (*common.PageQuery, error)

func (*GatewayPackageApiServiceImpl) GetRawByAny 

func (impl *GatewayPackageApiServiceImpl) GetRawByAny(cond *orm.GatewayPackageApi) (*orm.GatewayPackageApi, error)

func (*GatewayPackageApiServiceImpl) Insert 

func (impl *GatewayPackageApiServiceImpl) Insert(dao *orm.GatewayPackageApi) error

func (*GatewayPackageApiServiceImpl) NewSession 

func (impl *GatewayPackageApiServiceImpl) NewSession(helper ...*SessionHelper) (GatewayPackageApiService, error)

func (*GatewayPackageApiServiceImpl) SelectByAny 

func (impl *GatewayPackageApiServiceImpl) SelectByAny(cond *orm.GatewayPackageApi) ([]orm.GatewayPackageApi, error)

func (*GatewayPackageApiServiceImpl) SelectByOptions 

func (impl *GatewayPackageApiServiceImpl) SelectByOptions(options []orm.SelectOption) ([]orm.GatewayPackageApi, error)

func (*GatewayPackageApiServiceImpl) Update 

func (impl *GatewayPackageApiServiceImpl) Update(dao *orm.GatewayPackageApi, columns ...string) error

type GatewayPackageInConsumerService 

type GatewayPackageInConsumerService interface {
	NewSession(...*SessionHelper) (GatewayPackageInConsumerService, error)
	Insert(*GatewayPackageInConsumer) error
	Delete(packageId, consumerId string) error
	DeleteByConsumerId(string) error
	DeleteByPackageId(string) error
	// use for show
	SelectByConsumer(string) ([]GatewayPackageInConsumer, error)
	// also used for delete package check
	SelectByPackage(string) ([]GatewayPackageInConsumer, error)
}

type GatewayPackageInConsumerServiceImpl 

type GatewayPackageInConsumerServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayPackageInConsumerServiceImpl 

func NewGatewayPackageInConsumerServiceImpl() (*GatewayPackageInConsumerServiceImpl, error)

func (*GatewayPackageInConsumerServiceImpl) Delete 

func (impl *GatewayPackageInConsumerServiceImpl) Delete(packageId, consumerId string) error

func (*GatewayPackageInConsumerServiceImpl) DeleteByConsumerId 

func (impl *GatewayPackageInConsumerServiceImpl) DeleteByConsumerId(id string) error

func (*GatewayPackageInConsumerServiceImpl) DeleteByPackageId 

func (impl *GatewayPackageInConsumerServiceImpl) DeleteByPackageId(id string) error

func (*GatewayPackageInConsumerServiceImpl) Get 

func (impl *GatewayPackageInConsumerServiceImpl) Get(id string) (*orm.GatewayPackageInConsumer, error)

func (*GatewayPackageInConsumerServiceImpl) GetByAny 

func (impl *GatewayPackageInConsumerServiceImpl) GetByAny(cond *orm.GatewayPackageInConsumer) (*orm.GatewayPackageInConsumer, error)

func (*GatewayPackageInConsumerServiceImpl) Insert 

func (impl *GatewayPackageInConsumerServiceImpl) Insert(dao *orm.GatewayPackageInConsumer) error

func (*GatewayPackageInConsumerServiceImpl) NewSession 

func (impl *GatewayPackageInConsumerServiceImpl) NewSession(helper ...*SessionHelper) (GatewayPackageInConsumerService, error)

func (*GatewayPackageInConsumerServiceImpl) SelectByAny 

func (impl *GatewayPackageInConsumerServiceImpl) SelectByAny(cond *orm.GatewayPackageInConsumer) ([]orm.GatewayPackageInConsumer, error)

func (*GatewayPackageInConsumerServiceImpl) SelectByConsumer 

func (impl *GatewayPackageInConsumerServiceImpl) SelectByConsumer(id string) ([]orm.GatewayPackageInConsumer, error)

func (*GatewayPackageInConsumerServiceImpl) SelectByPackage 

func (impl *GatewayPackageInConsumerServiceImpl) SelectByPackage(id string) ([]orm.GatewayPackageInConsumer, error)

func (*GatewayPackageInConsumerServiceImpl) Update 

func (impl *GatewayPackageInConsumerServiceImpl) Update(dao *orm.GatewayPackageInConsumer) error

type GatewayPackageRuleService 

type GatewayPackageRuleService interface {
	NewSession(...*SessionHelper) (GatewayPackageRuleService, error)
	Insert(*GatewayPackageRule) error
	GetPage(options []SelectOption, page *Page) (*PageQuery, error)
	Count(options []SelectOption) (int64, error)
	Update(*GatewayPackageRule) error
	Delete(string) error
	Get(string) (*GatewayPackageRule, error)
	GetByAny(cond *GatewayPackageRule) (*GatewayPackageRule, error)
	SelectByAny(*GatewayPackageRule) ([]GatewayPackageRule, error)
	DeleteByPackageId(string) error
}

type GatewayPackageRuleServiceImpl 

type GatewayPackageRuleServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayPackageRuleServiceImpl 

func NewGatewayPackageRuleServiceImpl() (*GatewayPackageRuleServiceImpl, error)

func (*GatewayPackageRuleServiceImpl) Count 

func (impl *GatewayPackageRuleServiceImpl) Count(options []orm.SelectOption) (int64, error)

func (*GatewayPackageRuleServiceImpl) Delete 

func (impl *GatewayPackageRuleServiceImpl) Delete(id string) error

func (*GatewayPackageRuleServiceImpl) DeleteByPackageId 

func (impl *GatewayPackageRuleServiceImpl) DeleteByPackageId(packageId string) error

func (*GatewayPackageRuleServiceImpl) Get 

func (impl *GatewayPackageRuleServiceImpl) Get(id string) (*orm.GatewayPackageRule, error)

func (*GatewayPackageRuleServiceImpl) GetByAny 

func (impl *GatewayPackageRuleServiceImpl) GetByAny(cond *orm.GatewayPackageRule) (*orm.GatewayPackageRule, error)

func (*GatewayPackageRuleServiceImpl) GetPage 

func (impl *GatewayPackageRuleServiceImpl) GetPage(options []orm.SelectOption, page *common.Page) (*common.PageQuery, error)

func (*GatewayPackageRuleServiceImpl) Insert 

func (impl *GatewayPackageRuleServiceImpl) Insert(dao *orm.GatewayPackageRule) error

func (*GatewayPackageRuleServiceImpl) NewSession 

func (impl *GatewayPackageRuleServiceImpl) NewSession(helper ...*SessionHelper) (GatewayPackageRuleService, error)

func (*GatewayPackageRuleServiceImpl) SelectByAny 

func (impl *GatewayPackageRuleServiceImpl) SelectByAny(cond *orm.GatewayPackageRule) ([]orm.GatewayPackageRule, error)

func (*GatewayPackageRuleServiceImpl) Update 

func (impl *GatewayPackageRuleServiceImpl) Update(dao *orm.GatewayPackageRule) error

type GatewayPackageService 

type GatewayPackageService interface {
	NewSession(...*SessionHelper) (GatewayPackageService, error)
	Insert(*GatewayPackage) error
	GetPage(options []SelectOption, page *Page) (*PageQuery, error)
	Count(options []SelectOption) (int64, error)
	Update(*GatewayPackage, ...string) error
	Delete(string, ...bool) error
	Get(string) (*GatewayPackage, error)
	GetByAny(cond *GatewayPackage) (*GatewayPackage, error)
	SelectByAny(*GatewayPackage) ([]GatewayPackage, error)
	//check id when update
	CheckUnique(*GatewayPackage) (bool, error)
}

type GatewayPackageServiceImpl 

type GatewayPackageServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayPackageServiceImpl 

func NewGatewayPackageServiceImpl() (*GatewayPackageServiceImpl, error)

func (*GatewayPackageServiceImpl) CheckUnique 

func (impl *GatewayPackageServiceImpl) CheckUnique(dao *orm.GatewayPackage) (bool, error)

func (*GatewayPackageServiceImpl) Count 

func (impl *GatewayPackageServiceImpl) Count(options []orm.SelectOption) (int64, error)

func (*GatewayPackageServiceImpl) Delete 

func (impl *GatewayPackageServiceImpl) Delete(id string, realDelete ...bool) error

func (*GatewayPackageServiceImpl) Get 

func (impl *GatewayPackageServiceImpl) Get(id string) (*orm.GatewayPackage, error)

func (*GatewayPackageServiceImpl) GetByAny 

func (impl *GatewayPackageServiceImpl) GetByAny(cond *orm.GatewayPackage) (*orm.GatewayPackage, error)

func (*GatewayPackageServiceImpl) GetPage 

func (impl *GatewayPackageServiceImpl) GetPage(options []orm.SelectOption, page *common.Page) (*common.PageQuery, error)

func (*GatewayPackageServiceImpl) Insert 

func (impl *GatewayPackageServiceImpl) Insert(dao *orm.GatewayPackage) error

func (*GatewayPackageServiceImpl) NewSession 

func (impl *GatewayPackageServiceImpl) NewSession(helper ...*SessionHelper) (GatewayPackageService, error)

func (*GatewayPackageServiceImpl) SelectByAny 

func (impl *GatewayPackageServiceImpl) SelectByAny(cond *orm.GatewayPackage) ([]orm.GatewayPackage, error)

func (*GatewayPackageServiceImpl) Update 

func (impl *GatewayPackageServiceImpl) Update(dao *orm.GatewayPackage, columns ...string) error

type GatewayPluginInstanceService 

type GatewayPluginInstanceService interface {
	NewSession(...*SessionHelper) (GatewayPluginInstanceService, error)
	Insert(*GatewayPluginInstance) error
	DeleteByRouteId(routeId string) error
	DeleteByApiId(routeId string) error
	DeleteByServiceId(serviceId string) error
	DeleteByConsumerId(consumerId string) error
	Update(*GatewayPluginInstance) error
	GetByPluginNameAndApiId(pluginName string, apiId string) (*GatewayPluginInstance, error)
	GetByAny(*GatewayPluginInstance) (*GatewayPluginInstance, error)
	DeleteById(string) error
	SelectByOnlyApiId(apiId string) ([]GatewayPluginInstance, error)
	SelectByPolicyId(policyId string) ([]GatewayPluginInstance, error)
}

type GatewayPluginInstanceServiceImpl 

type GatewayPluginInstanceServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayPluginInstanceServiceImpl 

func NewGatewayPluginInstanceServiceImpl() (*GatewayPluginInstanceServiceImpl, error)

func (*GatewayPluginInstanceServiceImpl) DeleteByApiId 

func (impl *GatewayPluginInstanceServiceImpl) DeleteByApiId(apiId string) error

func (*GatewayPluginInstanceServiceImpl) DeleteByConsumerId 

func (impl *GatewayPluginInstanceServiceImpl) DeleteByConsumerId(consumerId string) error

func (*GatewayPluginInstanceServiceImpl) DeleteById 

func (impl *GatewayPluginInstanceServiceImpl) DeleteById(id string) error

func (*GatewayPluginInstanceServiceImpl) DeleteByRouteId 

func (impl *GatewayPluginInstanceServiceImpl) DeleteByRouteId(routeId string) error

func (*GatewayPluginInstanceServiceImpl) DeleteByServiceId 

func (impl *GatewayPluginInstanceServiceImpl) DeleteByServiceId(serviceId string) error

func (*GatewayPluginInstanceServiceImpl) GetByAny 

func (impl *GatewayPluginInstanceServiceImpl) GetByAny(cond *orm.GatewayPluginInstance) (*orm.GatewayPluginInstance, error)

func (*GatewayPluginInstanceServiceImpl) GetByPluginNameAndApiId 

func (impl *GatewayPluginInstanceServiceImpl) GetByPluginNameAndApiId(name string, id string) (*orm.GatewayPluginInstance, error)

func (*GatewayPluginInstanceServiceImpl) Insert 

func (impl *GatewayPluginInstanceServiceImpl) Insert(instance *orm.GatewayPluginInstance) error

func (*GatewayPluginInstanceServiceImpl) NewSession 

func (impl *GatewayPluginInstanceServiceImpl) NewSession(helper ...*SessionHelper) (GatewayPluginInstanceService, error)

func (*GatewayPluginInstanceServiceImpl) SelectByOnlyApiId 

func (impl *GatewayPluginInstanceServiceImpl) SelectByOnlyApiId(id string) ([]orm.GatewayPluginInstance, error)

func (*GatewayPluginInstanceServiceImpl) SelectByPolicyId 

func (impl *GatewayPluginInstanceServiceImpl) SelectByPolicyId(id string) ([]orm.GatewayPluginInstance, error)

func (*GatewayPluginInstanceServiceImpl) Update 

func (impl *GatewayPluginInstanceServiceImpl) Update(instance *orm.GatewayPluginInstance) error

type GatewayPolicyService 

type GatewayPolicyService interface {
	GetById(policyId string) (*GatewayPolicy, error)
	SelectByCategory(category string) ([]GatewayPolicy, error)
	Insert(*GatewayPolicy) error
	Update(*GatewayPolicy) error
	GetByPolicyName(policyName string, consumerId string) (*GatewayPolicy, error)
	DeleteById(string) error
	SelectByCategoryAndConsumer(category string, consumerId string) ([]GatewayPolicy, error)
	SelectInIds(ids ...string) ([]GatewayPolicy, error)
	SelectByAny(*GatewayPolicy) ([]GatewayPolicy, error)
	GetByAny(*GatewayPolicy) (*GatewayPolicy, error)
}

type GatewayPolicyServiceImpl 

type GatewayPolicyServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayPolicyServiceImpl 

func NewGatewayPolicyServiceImpl() (*GatewayPolicyServiceImpl, error)

func (*GatewayPolicyServiceImpl) DeleteById 

func (impl *GatewayPolicyServiceImpl) DeleteById(id string) error

func (*GatewayPolicyServiceImpl) GetByAny 

func (impl *GatewayPolicyServiceImpl) GetByAny(cond *orm.GatewayPolicy) (*orm.GatewayPolicy, error)

func (*GatewayPolicyServiceImpl) GetById 

func (impl *GatewayPolicyServiceImpl) GetById(id string) (*orm.GatewayPolicy, error)

func (*GatewayPolicyServiceImpl) GetByPolicyName 

func (impl *GatewayPolicyServiceImpl) GetByPolicyName(name string, consumerId string) (*orm.GatewayPolicy, error)

func (*GatewayPolicyServiceImpl) Insert 

func (impl *GatewayPolicyServiceImpl) Insert(policy *orm.GatewayPolicy) error

func (*GatewayPolicyServiceImpl) SelectByAny 

func (impl *GatewayPolicyServiceImpl) SelectByAny(cond *orm.GatewayPolicy) ([]orm.GatewayPolicy, error)

func (*GatewayPolicyServiceImpl) SelectByCategory 

func (impl *GatewayPolicyServiceImpl) SelectByCategory(category string) ([]orm.GatewayPolicy, error)

func (*GatewayPolicyServiceImpl) SelectByCategoryAndConsumer 

func (impl *GatewayPolicyServiceImpl) SelectByCategoryAndConsumer(category string, consumerId string) ([]orm.GatewayPolicy, error)

func (*GatewayPolicyServiceImpl) SelectInIds 

func (impl *GatewayPolicyServiceImpl) SelectInIds(ids ...string) ([]orm.GatewayPolicy, error)

func (*GatewayPolicyServiceImpl) Update 

func (impl *GatewayPolicyServiceImpl) Update(policy *orm.GatewayPolicy) error

type GatewayRouteService 

type GatewayRouteService interface {
	NewSession(...*SessionHelper) (GatewayRouteService, error)
	GetById(string) (*GatewayRoute, error)
	Insert(*GatewayRoute) error
	GetByApiId(apiId string) (*GatewayRoute, error)
	DeleteById(string) error
	Update(*GatewayRoute) error
}

type GatewayRouteServiceImpl 

type GatewayRouteServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayRouteServiceImpl 

func NewGatewayRouteServiceImpl() (*GatewayRouteServiceImpl, error)

func (*GatewayRouteServiceImpl) DeleteById 

func (impl *GatewayRouteServiceImpl) DeleteById(id string) error

func (*GatewayRouteServiceImpl) GetByApiId 

func (impl *GatewayRouteServiceImpl) GetByApiId(id string) (*orm.GatewayRoute, error)

func (*GatewayRouteServiceImpl) GetById 

func (impl *GatewayRouteServiceImpl) GetById(id string) (*orm.GatewayRoute, error)

func (*GatewayRouteServiceImpl) Insert 

func (impl *GatewayRouteServiceImpl) Insert(route *orm.GatewayRoute) error

func (*GatewayRouteServiceImpl) NewSession 

func (impl *GatewayRouteServiceImpl) NewSession(helper ...*SessionHelper) (GatewayRouteService, error)

func (*GatewayRouteServiceImpl) Update 

func (impl *GatewayRouteServiceImpl) Update(route *orm.GatewayRoute) error

type GatewayRuntimeServiceService 

type GatewayRuntimeServiceService interface {
	NewSession(...*SessionHelper) (GatewayRuntimeServiceService, error)
	CreateIfNotExist(session *xorm.Session, dao *GatewayRuntimeService) (*GatewayRuntimeService, error)
	Insert(*GatewayRuntimeService) error
	Update(*GatewayRuntimeService) error
	Delete(string) error
	Get(string) (*GatewayRuntimeService, error)
	SelectByAny(*GatewayRuntimeService) ([]GatewayRuntimeService, error)
	GetByAny(*GatewayRuntimeService) (*GatewayRuntimeService, error)
}

type GatewayRuntimeServiceServiceImpl 

type GatewayRuntimeServiceServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayRuntimeServiceServiceImpl 

func NewGatewayRuntimeServiceServiceImpl() (*GatewayRuntimeServiceServiceImpl, error)

func (*GatewayRuntimeServiceServiceImpl) CreateIfNotExist 

func (impl *GatewayRuntimeServiceServiceImpl) CreateIfNotExist(session *xorm.Session, dao *orm.GatewayRuntimeService) (*orm.GatewayRuntimeService, error)

func (*GatewayRuntimeServiceServiceImpl) Delete 

func (impl *GatewayRuntimeServiceServiceImpl) Delete(id string) error

func (*GatewayRuntimeServiceServiceImpl) Get 

func (impl *GatewayRuntimeServiceServiceImpl) Get(id string) (*orm.GatewayRuntimeService, error)

func (*GatewayRuntimeServiceServiceImpl) GetByAny 

func (impl *GatewayRuntimeServiceServiceImpl) GetByAny(cond *orm.GatewayRuntimeService) (*orm.GatewayRuntimeService, error)

func (*GatewayRuntimeServiceServiceImpl) Insert 

func (impl *GatewayRuntimeServiceServiceImpl) Insert(dao *orm.GatewayRuntimeService) error

func (*GatewayRuntimeServiceServiceImpl) NewSession 

func (impl *GatewayRuntimeServiceServiceImpl) NewSession(helper ...*SessionHelper) (GatewayRuntimeServiceService, error)

func (*GatewayRuntimeServiceServiceImpl) SelectByAny 

func (impl *GatewayRuntimeServiceServiceImpl) SelectByAny(cond *orm.GatewayRuntimeService) ([]orm.GatewayRuntimeService, error)

func (*GatewayRuntimeServiceServiceImpl) Update 

func (impl *GatewayRuntimeServiceServiceImpl) Update(dao *orm.GatewayRuntimeService) error

type GatewayServiceService 

type GatewayServiceService interface {
	NewSession(...*SessionHelper) (GatewayServiceService, error)
	GetById(string) (*GatewayService, error)
	Insert(*GatewayService) error
	GetByApiId(apiId string) (*GatewayService, error)
	DeleteById(string) error
	Update(*GatewayService) error
}

type GatewayServiceServiceImpl 

type GatewayServiceServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayServiceServiceImpl 

func NewGatewayServiceServiceImpl() (*GatewayServiceServiceImpl, error)

func (*GatewayServiceServiceImpl) DeleteById 

func (impl *GatewayServiceServiceImpl) DeleteById(id string) error

func (*GatewayServiceServiceImpl) GetByApiId 

func (impl *GatewayServiceServiceImpl) GetByApiId(id string) (*orm.GatewayService, error)

func (*GatewayServiceServiceImpl) GetById 

func (impl *GatewayServiceServiceImpl) GetById(id string) (*orm.GatewayService, error)

func (*GatewayServiceServiceImpl) Insert 

func (impl *GatewayServiceServiceImpl) Insert(service *orm.GatewayService) error

func (*GatewayServiceServiceImpl) NewSession 

func (impl *GatewayServiceServiceImpl) NewSession(helper ...*SessionHelper) (GatewayServiceService, error)

func (*GatewayServiceServiceImpl) Update 

func (impl *GatewayServiceServiceImpl) Update(service *orm.GatewayService) error

type GatewayUpstreamApiService 

type GatewayUpstreamApiService interface {
	GetById(string) (*GatewayUpstreamApi, error)
	DeleteById(string) error
	Recover(string) error
	Insert(*xorm.Session, *GatewayUpstreamApi) (string, error)
	GetLastApiId(*GatewayUpstreamApi) string
	UpdateApiId(*GatewayUpstreamApi) error
	GetPage(ids []string, page *Page) (*PageQuery, error)
	SelectInIdsAndDeleted(ids []string) ([]GatewayUpstreamApi, error)
	SelectInIds(ids []string) ([]GatewayUpstreamApi, error)
}

type GatewayUpstreamApiServiceImpl 

type GatewayUpstreamApiServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayUpstreamApiServiceImpl 

func NewGatewayUpstreamApiServiceImpl() (*GatewayUpstreamApiServiceImpl, error)

func (*GatewayUpstreamApiServiceImpl) DeleteById 

func (impl *GatewayUpstreamApiServiceImpl) DeleteById(id string) error

func (*GatewayUpstreamApiServiceImpl) GetById 

func (impl *GatewayUpstreamApiServiceImpl) GetById(id string) (*orm.GatewayUpstreamApi, error)

func (*GatewayUpstreamApiServiceImpl) GetLastApiId 

func (impl *GatewayUpstreamApiServiceImpl) GetLastApiId(cond *orm.GatewayUpstreamApi) string

func (*GatewayUpstreamApiServiceImpl) GetPage 

func (impl *GatewayUpstreamApiServiceImpl) GetPage(ids []string, page *common.Page) (*common.PageQuery, error)

func (*GatewayUpstreamApiServiceImpl) Insert 

func (impl *GatewayUpstreamApiServiceImpl) Insert(session *xorm.Session, item *orm.GatewayUpstreamApi) (string, error)

func (*GatewayUpstreamApiServiceImpl) Recover 

func (impl *GatewayUpstreamApiServiceImpl) Recover(id string) error

func (*GatewayUpstreamApiServiceImpl) SelectInIds 

func (impl *GatewayUpstreamApiServiceImpl) SelectInIds(ids []string) ([]orm.GatewayUpstreamApi, error)

func (*GatewayUpstreamApiServiceImpl) SelectInIdsAndDeleted 

func (impl *GatewayUpstreamApiServiceImpl) SelectInIdsAndDeleted(ids []string) ([]orm.GatewayUpstreamApi, error)

func (*GatewayUpstreamApiServiceImpl) UpdateApiId 

func (impl *GatewayUpstreamApiServiceImpl) UpdateApiId(update *orm.GatewayUpstreamApi) error

type GatewayUpstreamLbService 

type GatewayUpstreamLbService interface {
	Get(*GatewayUpstreamLb) (*GatewayUpstreamLb, error)
	GetForUpdate(*xorm.Session, *GatewayUpstreamLb) (*GatewayUpstreamLb, error)
	Insert(*xorm.Session, *GatewayUpstreamLb) error
	UpdateDeploymentId(string, int) error
	GetById(string) (*GatewayUpstreamLb, error)
	GetByKongId(string) (*GatewayUpstreamLb, error)
}

type GatewayUpstreamLbServiceImpl 

type GatewayUpstreamLbServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayUpstreamLbServiceImpl 

func NewGatewayUpstreamLbServiceImpl() (*GatewayUpstreamLbServiceImpl, error)

func (GatewayUpstreamLbServiceImpl) Get 

func (impl GatewayUpstreamLbServiceImpl) Get(cond *orm.GatewayUpstreamLb) (*orm.GatewayUpstreamLb, error)

func (GatewayUpstreamLbServiceImpl) GetById 

func (impl GatewayUpstreamLbServiceImpl) GetById(id string) (*orm.GatewayUpstreamLb, error)

func (GatewayUpstreamLbServiceImpl) GetByKongId 

func (impl GatewayUpstreamLbServiceImpl) GetByKongId(id string) (*orm.GatewayUpstreamLb, error)

func (GatewayUpstreamLbServiceImpl) GetForUpdate 

func (impl GatewayUpstreamLbServiceImpl) GetForUpdate(session *xorm.Session, cond *orm.GatewayUpstreamLb) (*orm.GatewayUpstreamLb, error)

func (GatewayUpstreamLbServiceImpl) Insert 

func (impl GatewayUpstreamLbServiceImpl) Insert(session *xorm.Session, dao *orm.GatewayUpstreamLb) error

func (GatewayUpstreamLbServiceImpl) UpdateDeploymentId 

func (impl GatewayUpstreamLbServiceImpl) UpdateDeploymentId(id string, deploymentId int) error

type GatewayUpstreamLbTargetService 

type GatewayUpstreamLbTargetService interface {
	Insert(*GatewayUpstreamLbTarget) error
	SelectByDeploymentId(int) ([]GatewayUpstreamLbTarget, error)
	Select(lbId, target string) ([]GatewayUpstreamLbTarget, error)
	Delete(string) error
}

type GatewayUpstreamLbTargetServiceImpl 

type GatewayUpstreamLbTargetServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayUpstreamLbTargetServiceImpl 

func NewGatewayUpstreamLbTargetServiceImpl() (*GatewayUpstreamLbTargetServiceImpl, error)

func (GatewayUpstreamLbTargetServiceImpl) Delete 

func (impl GatewayUpstreamLbTargetServiceImpl) Delete(id string) error

func (GatewayUpstreamLbTargetServiceImpl) Insert 

func (impl GatewayUpstreamLbTargetServiceImpl) Insert(dao *orm.GatewayUpstreamLbTarget) error

func (GatewayUpstreamLbTargetServiceImpl) Select 

func (impl GatewayUpstreamLbTargetServiceImpl) Select(lbId, target string) ([]orm.GatewayUpstreamLbTarget, error)

func (GatewayUpstreamLbTargetServiceImpl) SelectByDeploymentId 

func (impl GatewayUpstreamLbTargetServiceImpl) SelectByDeploymentId(id int) ([]orm.GatewayUpstreamLbTarget, error)

type GatewayUpstreamRegisterRecordService 

type GatewayUpstreamRegisterRecordService interface {
	Insert(*xorm.Session, *GatewayUpstreamRegisterRecord) error
	GetPage(upstreamId string, page *Page) (*PageQuery, error)
	Get(upstreamId string, registerId string) (*GatewayUpstreamRegisterRecord, error)
}

type GatewayUpstreamRegisterRecordServiceImpl 

type GatewayUpstreamRegisterRecordServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayUpstreamRegisterRecordServiceImpl 

func NewGatewayUpstreamRegisterRecordServiceImpl() (*GatewayUpstreamRegisterRecordServiceImpl, error)

func (*GatewayUpstreamRegisterRecordServiceImpl) Get 

func (impl *GatewayUpstreamRegisterRecordServiceImpl) Get(upstreamId string, registerId string) (*orm.GatewayUpstreamRegisterRecord, error)

func (*GatewayUpstreamRegisterRecordServiceImpl) GetPage 

func (impl *GatewayUpstreamRegisterRecordServiceImpl) GetPage(upstreamId string, page *common.Page) (*common.PageQuery, error)

func (*GatewayUpstreamRegisterRecordServiceImpl) Insert 

func (impl *GatewayUpstreamRegisterRecordServiceImpl) Insert(session *xorm.Session, item *orm.GatewayUpstreamRegisterRecord) error

type GatewayUpstreamService 

type GatewayUpstreamService interface {
	// UpdateRegister .
	// To find orm.GatewayUpstream by orgID,projectID,env,az,upstreamName,runtimeServiceID,
	// If find it, and LastRegisterId from req is same as the exists one, returns need not save and need not new create.
	// If find it, and LastRegisterId from req is not same as the exists one, update lastRegisterID and zoneID, returns need update and need not create.
	// If not find it, find it again with table lock, if not success, create it, returns need update and need create.
	UpdateRegister(context.Context, *xorm.Session, *GatewayUpstream) (bool, bool, string, error)
	GetValidIdForUpdate(string, *xorm.Session) (string, error)
	UpdateValidId(*GatewayUpstream, ...*xorm.Session) error
	UpdateAutoBind(*GatewayUpstream) error
	SelectByAny(*GatewayUpstream) ([]GatewayUpstream, error)
}

type GatewayUpstreamServiceImpl 

type GatewayUpstreamServiceImpl struct {
	// contains filtered or unexported fields
}

func NewGatewayUpstreamServiceImpl 

func NewGatewayUpstreamServiceImpl() (*GatewayUpstreamServiceImpl, error)

func (*GatewayUpstreamServiceImpl) GetValidIdForUpdate 

func (impl *GatewayUpstreamServiceImpl) GetValidIdForUpdate(id string, session *xorm.Session) (string, error)

func (*GatewayUpstreamServiceImpl) SelectByAny 

func (impl *GatewayUpstreamServiceImpl) SelectByAny(cond *orm.GatewayUpstream) ([]orm.GatewayUpstream, error)

func (*GatewayUpstreamServiceImpl) UpdateAutoBind 

func (impl *GatewayUpstreamServiceImpl) UpdateAutoBind(update *orm.GatewayUpstream) error

func (*GatewayUpstreamServiceImpl) UpdateRegister 

func (impl *GatewayUpstreamServiceImpl) UpdateRegister(ctx context.Context, session *xorm.Session, dao *orm.GatewayUpstream) (bool, bool, string, error)

UpdateRegister . To find orm.GatewayUpstream by orgID,projectID,env,az,upstreamName,runtimeServiceID, If find it, and LastRegisterId from req is same as the exists one, returns need not save and need not new create. If find it, and LastRegisterId from req is not same as the exists one, update lastRegisterID and zoneID, returns need update and need not create. If not find it, find it again with table lock, if not success, create it, returns need update and need create.

func (*GatewayUpstreamServiceImpl) UpdateValidId 

func (impl *GatewayUpstreamServiceImpl) UpdateValidId(update *orm.GatewayUpstream, session ...*xorm.Session) error

type GatewayZoneInPackageService 

type GatewayZoneInPackageService interface {
	NewSession(...*SessionHelper) (GatewayZoneInPackageService, error)
	Insert(*GatewayZoneInPackage) error
	Update(*GatewayZoneInPackage) error
	GetByAny(*GatewayZoneInPackage) (*GatewayZoneInPackage, error)
	DeleteByPackageId(string) error
	// use for create/update zone's domain binded ingress
	SelectByZoneId(string) ([]GatewayZoneInPackage, error)
	SelectByPackageId(string) ([]GatewayZoneInPackage, error)
}

type GatewayZoneInPackageServiceImpl 

type GatewayZoneInPackageServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayZoneInPackageServiceImpl 

func NewGatewayZoneInPackageServiceImpl() (*GatewayZoneInPackageServiceImpl, error)

func (*GatewayZoneInPackageServiceImpl) Delete 

func (impl *GatewayZoneInPackageServiceImpl) Delete(id string) error

func (*GatewayZoneInPackageServiceImpl) DeleteByPackageId 

func (impl *GatewayZoneInPackageServiceImpl) DeleteByPackageId(packageId string) error

func (*GatewayZoneInPackageServiceImpl) Get 

func (impl *GatewayZoneInPackageServiceImpl) Get(id string) (*orm.GatewayZoneInPackage, error)

func (*GatewayZoneInPackageServiceImpl) GetByAny 

func (impl *GatewayZoneInPackageServiceImpl) GetByAny(cond *orm.GatewayZoneInPackage) (*orm.GatewayZoneInPackage, error)

func (*GatewayZoneInPackageServiceImpl) Insert 

func (impl *GatewayZoneInPackageServiceImpl) Insert(dao *orm.GatewayZoneInPackage) error

func (*GatewayZoneInPackageServiceImpl) NewSession 

func (impl *GatewayZoneInPackageServiceImpl) NewSession(helper ...*SessionHelper) (GatewayZoneInPackageService, error)

func (*GatewayZoneInPackageServiceImpl) SelectByAny 

func (impl *GatewayZoneInPackageServiceImpl) SelectByAny(cond *orm.GatewayZoneInPackage) ([]orm.GatewayZoneInPackage, error)

func (*GatewayZoneInPackageServiceImpl) SelectByPackageId 

func (impl *GatewayZoneInPackageServiceImpl) SelectByPackageId(id string) ([]orm.GatewayZoneInPackage, error)

func (*GatewayZoneInPackageServiceImpl) SelectByZoneId 

func (impl *GatewayZoneInPackageServiceImpl) SelectByZoneId(id string) ([]orm.GatewayZoneInPackage, error)

func (*GatewayZoneInPackageServiceImpl) Update 

func (impl *GatewayZoneInPackageServiceImpl) Update(dao *orm.GatewayZoneInPackage) error

type GatewayZoneService 

type GatewayZoneService interface {
	NewSession(...*SessionHelper) (GatewayZoneService, error)
	Insert(*GatewayZone) error
	GetByAny(*GatewayZone) (*GatewayZone, error)
	GetById(string) (*GatewayZone, error)
	Update(*GatewayZone) error
	DeleteById(string) error
	SelectByAny(*GatewayZone) ([]GatewayZone, error)
	SelectPolicyZones(clusterName string) ([]GatewayZone, error)
}

type GatewayZoneServiceImpl 

type GatewayZoneServiceImpl struct {
	*SessionHelper
	// contains filtered or unexported fields
}

func NewGatewayZoneServiceImpl 

func NewGatewayZoneServiceImpl() (*GatewayZoneServiceImpl, error)

func (*GatewayZoneServiceImpl) DeleteById 

func (impl *GatewayZoneServiceImpl) DeleteById(id string) error

func (*GatewayZoneServiceImpl) GetByAny 

func (impl *GatewayZoneServiceImpl) GetByAny(cond *orm.GatewayZone) (*orm.GatewayZone, error)

func (*GatewayZoneServiceImpl) GetById 

func (impl *GatewayZoneServiceImpl) GetById(id string) (*orm.GatewayZone, error)

func (*GatewayZoneServiceImpl) Insert 

func (impl *GatewayZoneServiceImpl) Insert(zone *orm.GatewayZone) error

func (*GatewayZoneServiceImpl) NewSession 

func (impl *GatewayZoneServiceImpl) NewSession(helper ...*SessionHelper) (GatewayZoneService, error)

func (*GatewayZoneServiceImpl) SelectByAny 

func (impl *GatewayZoneServiceImpl) SelectByAny(cond *orm.GatewayZone) ([]orm.GatewayZone, error)

func (*GatewayZoneServiceImpl) SelectPolicyZones 

func (impl *GatewayZoneServiceImpl) SelectPolicyZones(clusterName string) ([]orm.GatewayZone, error)

func (*GatewayZoneServiceImpl) Update 

func (impl *GatewayZoneServiceImpl) Update(zone *orm.GatewayZone) error

type IngressChanges 

type IngressChanges struct {
	// use to merge configMap
	ConfigmapOptions []map[string]*string
	MainSnippets     *[]string
	HttpSnippets     *[]string
	ServerSnippets   *[]string

	// use to merge ingress
	Annotations      []map[string]*string
	LocationSnippets *[]string
}

type IniService 

type IniService interface {
	GetValueByName(name string) (string, error)
}

type IniServiceImpl 

type IniServiceImpl struct {
	// contains filtered or unexported fields
}

func NewIniServiceImpl 

func NewIniServiceImpl() (*IniServiceImpl, error)

func (*IniServiceImpl) GetValueByName 

func (impl *IniServiceImpl) GetValueByName(name string) (string, error)

type KongBelongTuple 

type KongBelongTuple struct {
	Az        string
	ProjectId string
	Env       string
}

type SessionHelper 

type SessionHelper struct {
	// contains filtered or unexported fields
}

func NewSessionHelper 

func NewSessionHelper() (*SessionHelper, error)

func (*SessionHelper) Begin 

func (impl *SessionHelper) Begin() error

func (*SessionHelper) Close 

func (impl *SessionHelper) Close()

func (*SessionHelper) Commit 

func (impl *SessionHelper) Commit() error

func (*SessionHelper) GetSessionHelper 

func (impl *SessionHelper) GetSessionHelper() *SessionHelper

func (*SessionHelper) Rollback 

func (impl *SessionHelper) Rollback() error

func (*SessionHelper) Session 

func (impl *SessionHelper) Session() *xorm.Session

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.