service

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: Jan 6, 2022 License: Apache-2.0 Imports: 14 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"
)

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"`
}

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 (*GatewayApiInPackageServiceImpl) GetByAny

func (*GatewayApiInPackageServiceImpl) Insert

func (*GatewayApiInPackageServiceImpl) NewSession

func (*GatewayApiInPackageServiceImpl) SelectByAny

func (*GatewayApiInPackageServiceImpl) SelectByApi

func (*GatewayApiInPackageServiceImpl) Update

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 added in v1.1.0

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

func (*GatewayApiServiceImpl) RealDeleteByRuntimeServiceId added in v1.1.0

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, 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, 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 (*GatewayConsumerApiServiceImpl) Insert

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

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)
}

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 (*GatewayConsumerServiceImpl) GetByAny

func (*GatewayConsumerServiceImpl) GetById

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 (*GatewayConsumerServiceImpl) SelectByOptions

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

func (*GatewayConsumerServiceImpl) Update

func (impl *GatewayConsumerServiceImpl) Update(consumer *orm.GatewayConsumer) 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 (*GatewayDefaultPolicyServiceImpl) GetByAny

func (*GatewayDefaultPolicyServiceImpl) Insert

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

func (*GatewayDefaultPolicyServiceImpl) NewSession

func (*GatewayDefaultPolicyServiceImpl) SelectByAny

func (*GatewayDefaultPolicyServiceImpl) Update

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 (*GatewayDomainServiceImpl) GetByAny

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 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 (*GatewayIngressPolicyServiceImpl) GetByAny

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 (*GatewayIngressPolicyServiceImpl) SelectByAny

func (*GatewayIngressPolicyServiceImpl) Update

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)
	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 (*GatewayKongInfoServiceImpl) GetForUpdate added in v1.3.0

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 (*GatewayKongInfoServiceImpl) GetTenantId

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

func (*GatewayKongInfoServiceImpl) Insert

func (*GatewayKongInfoServiceImpl) NewSession

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

func (*GatewayKongInfoServiceImpl) Update

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 (*GatewayOrgClientServiceImpl) GetById

func (*GatewayOrgClientServiceImpl) Insert

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

func (*GatewayOrgClientServiceImpl) NewSession

func (*GatewayOrgClientServiceImpl) SelectByAny

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 (*GatewayPackageApiInConsumerServiceImpl) GetByAny

func (*GatewayPackageApiInConsumerServiceImpl) Insert

func (*GatewayPackageApiInConsumerServiceImpl) NewSession

func (*GatewayPackageApiInConsumerServiceImpl) SelectByAny

func (*GatewayPackageApiInConsumerServiceImpl) SelectByConsumer

func (*GatewayPackageApiInConsumerServiceImpl) SelectByPackageApi

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

func (*GatewayPackageApiInConsumerServiceImpl) Update

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)
}

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 (*GatewayPackageApiServiceImpl) GetByAny

func (*GatewayPackageApiServiceImpl) GetPage

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

func (*GatewayPackageApiServiceImpl) GetRawByAny

func (*GatewayPackageApiServiceImpl) Insert

func (*GatewayPackageApiServiceImpl) NewSession

func (*GatewayPackageApiServiceImpl) SelectByAny

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 (*GatewayPackageInConsumerServiceImpl) GetByAny

func (*GatewayPackageInConsumerServiceImpl) Insert

func (*GatewayPackageInConsumerServiceImpl) NewSession

func (*GatewayPackageInConsumerServiceImpl) SelectByAny

func (*GatewayPackageInConsumerServiceImpl) SelectByConsumer

func (*GatewayPackageInConsumerServiceImpl) SelectByPackage

func (*GatewayPackageInConsumerServiceImpl) Update

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 (*GatewayPackageRuleServiceImpl) GetByAny

func (*GatewayPackageRuleServiceImpl) GetPage

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

func (*GatewayPackageRuleServiceImpl) Insert

func (*GatewayPackageRuleServiceImpl) NewSession

func (*GatewayPackageRuleServiceImpl) SelectByAny

func (*GatewayPackageRuleServiceImpl) Update

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 (*GatewayPackageServiceImpl) GetByAny

func (*GatewayPackageServiceImpl) GetPage

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

func (*GatewayPackageServiceImpl) Insert

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 (*GatewayPluginInstanceServiceImpl) GetByPluginNameAndApiId

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

func (*GatewayPluginInstanceServiceImpl) Insert

func (*GatewayPluginInstanceServiceImpl) NewSession

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

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 (*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 (*GatewayRuntimeServiceServiceImpl) Delete

func (*GatewayRuntimeServiceServiceImpl) Get

func (*GatewayRuntimeServiceServiceImpl) GetByAny

func (*GatewayRuntimeServiceServiceImpl) Insert

func (*GatewayRuntimeServiceServiceImpl) NewSession

func (*GatewayRuntimeServiceServiceImpl) SelectByAny

func (*GatewayRuntimeServiceServiceImpl) Update

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 (*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 (*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 (GatewayUpstreamLbServiceImpl) GetById

func (GatewayUpstreamLbServiceImpl) GetByKongId

func (GatewayUpstreamLbServiceImpl) GetForUpdate

func (GatewayUpstreamLbServiceImpl) Insert

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 (GatewayUpstreamLbTargetServiceImpl) Insert

func (GatewayUpstreamLbTargetServiceImpl) Select

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 (*GatewayUpstreamRegisterRecordServiceImpl) GetPage

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

func (*GatewayUpstreamRegisterRecordServiceImpl) Insert

type GatewayUpstreamService

type GatewayUpstreamService interface {
	UpdateRegister(*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 (*GatewayUpstreamServiceImpl) UpdateAutoBind

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

func (*GatewayUpstreamServiceImpl) UpdateRegister

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

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 (*GatewayZoneInPackageServiceImpl) GetByAny

func (*GatewayZoneInPackageServiceImpl) Insert

func (*GatewayZoneInPackageServiceImpl) NewSession

func (*GatewayZoneInPackageServiceImpl) SelectByAny

func (*GatewayZoneInPackageServiceImpl) SelectByPackageId

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

func (*GatewayZoneInPackageServiceImpl) SelectByZoneId

func (*GatewayZoneInPackageServiceImpl) Update

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

Jump to

Keyboard shortcuts

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