service

package
v1.2.2 Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2021 License: AGPL-3.0 Imports: 52 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeEndpointMaterial 

func MakeEndpointMaterial(runtimeService *orm.GatewayRuntimeService) (endpoint.EndpointMaterial, error)

Types

type DiceInfo 

type DiceInfo struct {
	OrgId       string
	ProjectId   string
	Env         string
	Az          string
	AppName     string
	ServiceName string
}

type EndpointDto 

type EndpointDto struct {
	orm.GatewayRuntimeService
	EndpointDomains []gw.EndpointDomainDto
}

type GatewayApiPolicyService 

type GatewayApiPolicyService interface {
	SetPackageDefaultPolicyConfig(category, packageId string, az *orm.GatewayAzInfo, config []byte, helper ...*db.SessionHelper) (string, error)
	GetPolicyConfig(category, packageId, packageApiId string) *common.StandardResult
	SetPolicyConfig(category, packageId, packageApiId string, config []byte) *common.StandardResult
	RefreshZoneIngress(zone orm.GatewayZone, az orm.GatewayAzInfo) error
	SetZonePolicyConfig(zone *orm.GatewayZone, category string, config []byte, helper *db.SessionHelper, needDeployTag ...bool) (apipolicy.PolicyDto, string, error)
	SetZoneDefaultPolicyConfig(packageId string, zone *orm.GatewayZone, az *orm.GatewayAzInfo, session ...*db.SessionHelper) (map[string]*string, *string, *db.SessionHelper, error)
}

type GatewayApiPolicyServiceImpl 

type GatewayApiPolicyServiceImpl struct {
	ReqCtx *gin.Context
	// contains filtered or unexported fields
}

func NewGatewayApiPolicyServiceImpl 

func NewGatewayApiPolicyServiceImpl() (*GatewayApiPolicyServiceImpl, error)

func (GatewayApiPolicyServiceImpl) GetPolicyConfig 

func (impl GatewayApiPolicyServiceImpl) GetPolicyConfig(category, packageId, packageApiId string) *common.StandardResult

func (GatewayApiPolicyServiceImpl) RefreshZoneIngress 

func (impl GatewayApiPolicyServiceImpl) RefreshZoneIngress(zone orm.GatewayZone, az orm.GatewayAzInfo) error

func (GatewayApiPolicyServiceImpl) SetPackageDefaultPolicyConfig 

func (impl GatewayApiPolicyServiceImpl) SetPackageDefaultPolicyConfig(category, packageId string, az *orm.GatewayAzInfo, config []byte, helperOption ...*db.SessionHelper) (string, error)

func (GatewayApiPolicyServiceImpl) SetPolicyConfig 

func (impl GatewayApiPolicyServiceImpl) SetPolicyConfig(category, packageId, packageApiId string, config []byte) *common.StandardResult

func (GatewayApiPolicyServiceImpl) SetZoneDefaultPolicyConfig 

func (impl GatewayApiPolicyServiceImpl) SetZoneDefaultPolicyConfig(packageId string, zone *orm.GatewayZone, az *orm.GatewayAzInfo, helper ...*db.SessionHelper) (map[string]*string, *string, *db.SessionHelper, error)

func (GatewayApiPolicyServiceImpl) SetZonePolicyConfig 

func (impl GatewayApiPolicyServiceImpl) SetZonePolicyConfig(zone *orm.GatewayZone, category string, config []byte, helper *db.SessionHelper, needDeployTag ...bool) (apipolicy.PolicyDto, string, error)

type GatewayApiService 

type GatewayApiService interface {
	GetRuntimeApis(runtimeServiceId string, registerType ...string) ([]gw.ApiDto, error)
	CreateRuntimeApi(dto *gw.ApiDto, session ...*db.SessionHelper) (string, vars.StandardErrorCode, error)
	CreateApi(*gw.ApiReqDto) *common.StandardResult
	GetApiInfos(*gw.GetApisDto) *common.StandardResult
	DeleteApi(string) *common.StandardResult
	UpdateApi(string, *gw.ApiReqDto) *common.StandardResult
	CreateUpstreamBindApi(*orm.GatewayConsumer, string, string, string, *orm.GatewayUpstreamApi, string) (string, error)
	UpdateUpstreamBindApi(*orm.GatewayConsumer, string, string, *orm.GatewayUpstreamApi, string) error
	DeleteUpstreamBindApi(*orm.GatewayUpstreamApi) error
	TouchRuntimeApi(*orm.GatewayRuntimeService, *db.SessionHelper, bool) error
	ClearRuntimeApi(*orm.GatewayRuntimeService) error
}

type GatewayApiServiceImpl 

type GatewayApiServiceImpl struct {
	ReqCtx *gin.Context
	// contains filtered or unexported fields
}

func NewGatewayApiServiceImpl 

func NewGatewayApiServiceImpl() (*GatewayApiServiceImpl, error)

func (GatewayApiServiceImpl) ClearRuntimeApi added in v1.1.0 

func (impl GatewayApiServiceImpl) ClearRuntimeApi(dao *orm.GatewayRuntimeService) error

func (GatewayApiServiceImpl) CreateApi 

func (impl GatewayApiServiceImpl) CreateApi(req *gw.ApiReqDto) *common.StandardResult

func (GatewayApiServiceImpl) CreateRuntimeApi 

func (impl GatewayApiServiceImpl) CreateRuntimeApi(dto *gw.ApiDto, session ...*db.SessionHelper) (string, StandardErrorCode, error)

func (GatewayApiServiceImpl) CreateUnitiyPackageShadowApi 

func (impl GatewayApiServiceImpl) CreateUnitiyPackageShadowApi(apiId, projectId, env, az string) error

func (GatewayApiServiceImpl) CreateUpstreamBindApi 

func (impl GatewayApiServiceImpl) CreateUpstreamBindApi(consumer *orm.GatewayConsumer, appName, srvName, runtimeServiceId string, upstreamApi *orm.GatewayUpstreamApi, aliasPath string) (string, error)

func (GatewayApiServiceImpl) DeleteApi 

func (impl GatewayApiServiceImpl) DeleteApi(apiId string) *common.StandardResult

func (GatewayApiServiceImpl) DeleteUpstreamBindApi 

func (impl GatewayApiServiceImpl) DeleteUpstreamBindApi(upstreamApi *orm.GatewayUpstreamApi) error

func (GatewayApiServiceImpl) GetApiInfos 

func (impl GatewayApiServiceImpl) GetApiInfos(dto *gw.GetApisDto) *common.StandardResult

func (GatewayApiServiceImpl) GetRuntimeApis 

func (impl GatewayApiServiceImpl) GetRuntimeApis(runtimeServiceId string, registerType ...string) ([]gw.ApiDto, error)

func (GatewayApiServiceImpl) TouchRuntimeApi 

func (impl GatewayApiServiceImpl) TouchRuntimeApi(dao *orm.GatewayRuntimeService, session *db.SessionHelper, newCreated bool) error

func (GatewayApiServiceImpl) UpdateApi 

func (impl GatewayApiServiceImpl) UpdateApi(apiId string, req *gw.ApiReqDto) *common.StandardResult

func (GatewayApiServiceImpl) UpdateUpstreamBindApi 

func (impl GatewayApiServiceImpl) UpdateUpstreamBindApi(consumer *orm.GatewayConsumer, appName, serviceName string, upstreamApi *orm.GatewayUpstreamApi, aliasPath string) error

type GatewayCategoryService 

type GatewayCategoryService interface {
	CreatePolicy(string, *gw.PolicyCreateDto) *common.StandardResult
	UpdatePolicy(string, string, *gw.PolicyCreateDto) *common.StandardResult
	DeletePolicy(string) *common.StandardResult
	GetCategoryInfo(string, string, string, string) *common.StandardResult
}

type GatewayCategoryServiceImpl 

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

func NewGatewayCategoryServiceImpl 

func NewGatewayCategoryServiceImpl() (*GatewayCategoryServiceImpl, error)

func (GatewayCategoryServiceImpl) CreatePolicy 

func (impl GatewayCategoryServiceImpl) CreatePolicy(category string, createDto *gw.PolicyCreateDto) *common.StandardResult

func (GatewayCategoryServiceImpl) DeletePolicy 

func (impl GatewayCategoryServiceImpl) DeletePolicy(policyId string) *common.StandardResult

func (GatewayCategoryServiceImpl) GetCategoryInfo 

func (impl GatewayCategoryServiceImpl) GetCategoryInfo(category string, orgId string, projectId string, env string) *common.StandardResult

func (GatewayCategoryServiceImpl) UpdatePolicy 

func (impl GatewayCategoryServiceImpl) UpdatePolicy(policyId string, category string, createDto *gw.PolicyCreateDto) *common.StandardResult

type GatewayConsumerApiService 

type GatewayConsumerApiService interface {
	Create(string, string) (string, error)
	Delete(string) error
	UpdateConsumerApi(*gw.ConsumerApiReqDto) *common.StandardResult
}

type GatewayConsumerApiServiceImpl 

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

func NewGatewayConsumerApiServiceImpl 

func NewGatewayConsumerApiServiceImpl() (*GatewayConsumerApiServiceImpl, error)

func (GatewayConsumerApiServiceImpl) Create 

func (impl GatewayConsumerApiServiceImpl) Create(consumerId string, apiId string) (string, error)

func (GatewayConsumerApiServiceImpl) Delete 

func (impl GatewayConsumerApiServiceImpl) Delete(id string) error

func (GatewayConsumerApiServiceImpl) UpdateConsumerApi 

func (impl GatewayConsumerApiServiceImpl) UpdateConsumerApi(reqDto *gw.ConsumerApiReqDto) *common.StandardResult

type GatewayConsumerService 

type GatewayConsumerService interface {
	CreateDefaultConsumer(string, string, string, string) (*orm.GatewayConsumer, *orm.ConsumerAuthConfig, vars.StandardErrorCode, error)
	CreateConsumer(*gw.ConsumerCreateDto) *common.StandardResult
	GetProjectConsumerInfo(string, string, string) *common.StandardResult
	GetConsumerInfo(string) *common.StandardResult
	UpdateConsumerInfo(string, *gw.ConsumerDto) *common.StandardResult
	UpdateConsumerApi(*gw.ConsumerEditDto) *common.StandardResult
	GetConsumerList(string, string, string) *common.StandardResult
	DeleteConsumer(string) *common.StandardResult
}

type GatewayConsumerServiceImpl 

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

func NewGatewayConsumerServiceImpl 

func NewGatewayConsumerServiceImpl() (*GatewayConsumerServiceImpl, error)

func (GatewayConsumerServiceImpl) CreateConsumer 

func (impl GatewayConsumerServiceImpl) CreateConsumer(createDto *gw.ConsumerCreateDto) *common.StandardResult

func (GatewayConsumerServiceImpl) CreateDefaultConsumer 

func (impl GatewayConsumerServiceImpl) CreateDefaultConsumer(orgId, projectId, env, az string) (*orm.GatewayConsumer, *orm.ConsumerAuthConfig, StandardErrorCode, error)

func (GatewayConsumerServiceImpl) DeleteConsumer 

func (impl GatewayConsumerServiceImpl) DeleteConsumer(consumerId string) *common.StandardResult

func (GatewayConsumerServiceImpl) GetConsumerInfo 

func (impl GatewayConsumerServiceImpl) GetConsumerInfo(consumerId string) *common.StandardResult

func (GatewayConsumerServiceImpl) GetConsumerList 

func (impl GatewayConsumerServiceImpl) GetConsumerList(orgId string, projectId string, env string) *common.StandardResult

func (GatewayConsumerServiceImpl) GetProjectConsumerInfo 

func (impl GatewayConsumerServiceImpl) GetProjectConsumerInfo(orgId string, projectId string, env string) *common.StandardResult

func (GatewayConsumerServiceImpl) UpdateConsumerApi 

func (impl GatewayConsumerServiceImpl) UpdateConsumerApi(dto *gw.ConsumerEditDto) *common.StandardResult

func (GatewayConsumerServiceImpl) UpdateConsumerInfo 

func (impl GatewayConsumerServiceImpl) UpdateConsumerInfo(consumerId string, consumerInfo *gw.ConsumerDto) *common.StandardResult

type GatewayDomainService 

type GatewayDomainService interface {
	FindDomains(domain, projectId, workspace string, matchType orm.OptionType, domainType ...string) ([]orm.GatewayDomain, error)
	GetOrgDomainInfo(gw.DiceArgsDto, *gw.ManageDomainReq) *common.StandardResult
	UpdateRuntimeServicePort(runtimeService *orm.GatewayRuntimeService, releaseInfo *diceyml.Object) error
	RefreshRuntimeDomain(runtimeService *orm.GatewayRuntimeService, session *db.SessionHelper) error
	GiveRuntimeDomainToPackage(runtimeService *orm.GatewayRuntimeService, session *db.SessionHelper) (bool, error)
	TouchRuntimeDomain(runtimeService *orm.GatewayRuntimeService, material endpoint.EndpointMaterial, domains []gw.EndpointDomainDto, audits *[]apistructs.Audit, session *db.SessionHelper) (string, error)
	TouchPackageDomain(packageId, clusterName string, domains []string, session *db.SessionHelper) ([]string, error)
	GetPackageDomains(packageId string, session ...*db.SessionHelper) ([]string, error)
	IsPackageDomainsDiff(packageId, clusterName string, domains []string, session *db.SessionHelper) (bool, error)
	GetTenantDomains(projectId, env string) *common.StandardResult
	GetRuntimeDomains(runtimeId string) *common.StandardResult
	UpdateRuntimeServiceDomain(orgId, runtimeId, serviceName string, reqDto *gw.ServiceDomainReqDto) *common.StandardResult
	SetCloudapiDomain(pack *orm.GatewayPackage, domains []string) error
	CreateOrUpdateComponentIngress(apistructs.ComponentIngressUpdateRequest) *common.StandardResult
}

type GatewayDomainServiceImpl 

type GatewayDomainServiceImpl struct {
	ReqCtx *gin.Context
	// contains filtered or unexported fields
}

func NewGatewayDomainServiceImpl 

func NewGatewayDomainServiceImpl() (*GatewayDomainServiceImpl, error)

func (GatewayDomainServiceImpl) CreateOrUpdateComponentIngress 

func (impl GatewayDomainServiceImpl) CreateOrUpdateComponentIngress(req apistructs.ComponentIngressUpdateRequest) (res *common.StandardResult)

func (GatewayDomainServiceImpl) FindDomains 

func (impl GatewayDomainServiceImpl) FindDomains(domain, projectId, workspace string, matchType orm.OptionType, domainType ...string) ([]orm.GatewayDomain, error)

func (GatewayDomainServiceImpl) GetOrgDomainInfo 

func (impl GatewayDomainServiceImpl) GetOrgDomainInfo(dice gw.DiceArgsDto, reqDto *gw.ManageDomainReq) (res *common.StandardResult)

func (GatewayDomainServiceImpl) GetPackageDomains 

func (impl GatewayDomainServiceImpl) GetPackageDomains(packageId string, session ...*db.SessionHelper) ([]string, error)

func (GatewayDomainServiceImpl) GetRuntimeDomains 

func (impl GatewayDomainServiceImpl) GetRuntimeDomains(runtimeId string) *common.StandardResult

func (GatewayDomainServiceImpl) GetTenantDomains 

func (impl GatewayDomainServiceImpl) GetTenantDomains(projectId, env string) *common.StandardResult

func (GatewayDomainServiceImpl) GiveRuntimeDomainToPackage 

func (impl GatewayDomainServiceImpl) GiveRuntimeDomainToPackage(runtimeService *orm.GatewayRuntimeService, session *db.SessionHelper) (bool, error)

func (GatewayDomainServiceImpl) IsPackageDomainsDiff 

func (impl GatewayDomainServiceImpl) IsPackageDomainsDiff(packageId, clusterName string, domains []string, session *db.SessionHelper) (bool, error)

func (GatewayDomainServiceImpl) RefreshRuntimeDomain 

func (impl GatewayDomainServiceImpl) RefreshRuntimeDomain(runtimeService *orm.GatewayRuntimeService, session *db.SessionHelper) error

func (GatewayDomainServiceImpl) SetCloudapiDomain 

func (impl GatewayDomainServiceImpl) SetCloudapiDomain(pack *orm.GatewayPackage, domains []string) error

func (GatewayDomainServiceImpl) TouchPackageDomain 

func (impl GatewayDomainServiceImpl) TouchPackageDomain(packageId, clusterName string, domains []string,
	session *db.SessionHelper) ([]string, error)

func (GatewayDomainServiceImpl) TouchRuntimeDomain 

func (impl GatewayDomainServiceImpl) TouchRuntimeDomain(runtimeService *orm.GatewayRuntimeService, material endpoint.EndpointMaterial, domains []gw.EndpointDomainDto, audits *[]apistructs.Audit, session *db.SessionHelper) (string, error)

func (GatewayDomainServiceImpl) UpdateRuntimeServiceDomain 

func (impl GatewayDomainServiceImpl) UpdateRuntimeServiceDomain(orgId, runtimeId, serviceName string, reqDto *gw.ServiceDomainReqDto) *common.StandardResult

func (GatewayDomainServiceImpl) UpdateRuntimeServicePort 

func (impl GatewayDomainServiceImpl) UpdateRuntimeServicePort(runtimeService *orm.GatewayRuntimeService, releaseInfo *diceyml.Object) error

type GatewayGlobalService 

type GatewayGlobalService interface {
	GetDiceHealth() gw.DiceHealthDto
	GenTenantGroup(projectId, env, clusterName string) string
	GetGatewayFeatures(clusterName string) *common.StandardResult
	GetTenantGroup(projectId, env string) *common.StandardResult
	GetOrgId(string) (string, error)
	GetClusterUIType(string, string, string) *common.StandardResult
	GenerateEndpoint(DiceInfo, ...*db.SessionHelper) (string, string, error)
	GenerateDefaultPath(string, ...*db.SessionHelper) (string, error)
	GetProjectName(DiceInfo, ...*db.SessionHelper) (string, error)
	GetProjectNameFromCmdb(string) (string, error)
	GetClustersByOrg(string) ([]string, error)
	GetServiceAddr(string) string
	GetRuntimeServicePrefix(*orm.GatewayRuntimeService) (string, error)
	CreateTenant(*gw.TenantDto) *common.StandardResult
}

type GatewayGlobalServiceImpl 

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

func NewGatewayGlobalServiceImpl 

func NewGatewayGlobalServiceImpl() (*GatewayGlobalServiceImpl, error)

func (*GatewayGlobalServiceImpl) CreateTenant 

func (impl *GatewayGlobalServiceImpl) CreateTenant(tenant *gw.TenantDto) *common.StandardResult

func (*GatewayGlobalServiceImpl) GenTenantGroup 

func (impl *GatewayGlobalServiceImpl) GenTenantGroup(projectId, env, clusterName string) string

func (*GatewayGlobalServiceImpl) GenerateDefaultPath 

func (impl *GatewayGlobalServiceImpl) GenerateDefaultPath(projectId string, session ...*db.SessionHelper) (string, error)

func (*GatewayGlobalServiceImpl) GenerateEndpoint 

func (impl *GatewayGlobalServiceImpl) GenerateEndpoint(info DiceInfo, session ...*db.SessionHelper) (string, string, error)

func (*GatewayGlobalServiceImpl) GetClusterUIType 

func (impl *GatewayGlobalServiceImpl) GetClusterUIType(orgId, projectId, env string) *common.StandardResult

func (*GatewayGlobalServiceImpl) GetClustersByOrg 

func (impl *GatewayGlobalServiceImpl) GetClustersByOrg(orgId string) ([]string, error)

func (*GatewayGlobalServiceImpl) GetDiceHealth 

func (impl *GatewayGlobalServiceImpl) GetDiceHealth() gw.DiceHealthDto

func (GatewayGlobalServiceImpl) GetGatewayFeatures 

func (impl GatewayGlobalServiceImpl) GetGatewayFeatures(clusterName string) *common.StandardResult

func (*GatewayGlobalServiceImpl) GetOrgId 

func (impl *GatewayGlobalServiceImpl) GetOrgId(projectId string) (string, error)

func (*GatewayGlobalServiceImpl) GetProjectName 

func (impl *GatewayGlobalServiceImpl) GetProjectName(info DiceInfo, session ...*db.SessionHelper) (string, error)

func (*GatewayGlobalServiceImpl) GetProjectNameFromCmdb 

func (impl *GatewayGlobalServiceImpl) GetProjectNameFromCmdb(projectId string) (string, error)

func (GatewayGlobalServiceImpl) GetRuntimeServicePrefix 

func (impl GatewayGlobalServiceImpl) GetRuntimeServicePrefix(dao *orm.GatewayRuntimeService) (string, error)

func (*GatewayGlobalServiceImpl) GetServiceAddr 

func (impl *GatewayGlobalServiceImpl) GetServiceAddr(env string) string

func (*GatewayGlobalServiceImpl) GetTenantGroup 

func (impl *GatewayGlobalServiceImpl) GetTenantGroup(projectId, env string) (res *common.StandardResult)

type GatewayMockService 

type GatewayMockService interface {
	RegisterMockApi(*gw.MockInfoDto) *common.StandardResult
	CallMockApi(string, string, string) *common.StandardResult
}

type GatewayMockServiceImpl 

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

func NewGatewayMockServiceImpl 

func NewGatewayMockServiceImpl() (*GatewayMockServiceImpl, error)

func (GatewayMockServiceImpl) CallMockApi 

func (impl GatewayMockServiceImpl) CallMockApi(headKey, pathUrl, method string) *common.StandardResult

func (GatewayMockServiceImpl) RegisterMockApi 

func (impl GatewayMockServiceImpl) RegisterMockApi(dto *gw.MockInfoDto) *common.StandardResult

type GatewayOpenapiConsumerService 

type GatewayOpenapiConsumerService interface {
	GrantPackageToConsumer(consumerId, packageId string) error
	RevokePackageFromConsumer(consumerId, packageId string) error
	CreateClientConsumer(clientName, clientId, clientSecret, clusterName string) (*orm.GatewayConsumer, error)
	CreateConsumer(*gw.DiceArgsDto, *gw.OpenConsumerDto) *common.StandardResult
	GetConsumers(*gw.GetOpenConsumersDto) *common.StandardResult
	GetConsumersName(*gw.GetOpenConsumersDto) *common.StandardResult
	UpdateConsumer(string, *gw.OpenConsumerDto) *common.StandardResult
	DeleteConsumer(string) *common.StandardResult
	GetConsumerCredentials(string) *common.StandardResult
	UpdateConsumerCredentials(string, *gw.ConsumerCredentialsDto) *common.StandardResult
	GetConsumerAcls(string) *common.StandardResult
	UpdateConsumerAcls(string, *gw.ConsumerAclsDto) *common.StandardResult
	GetConsumersOfPackage(string) ([]orm.GatewayConsumer, error)
	GetKongConsumerName(consumer *orm.GatewayConsumer) string
	GetPackageAcls(string) *common.StandardResult
	UpdatePackageAcls(string, *gw.PackageAclsDto) *common.StandardResult
	GetPackageApiAcls(string, string) *common.StandardResult
	UpdatePackageApiAcls(string, string, *gw.PackageAclsDto) *common.StandardResult
	// 获取阿里云APP凭证
	GetCloudapiAppCredential(string) *common.StandardResult
	// 生成阿里云APP凭证
	SetCloudapiAppCredential(string, ...bool) *common.StandardResult
	// 删除阿里云APP凭证
	DeleteCloudapiAppCredential(string) *common.StandardResult
}

type GatewayOpenapiConsumerServiceImpl 

type GatewayOpenapiConsumerServiceImpl struct {
	ReqCtx *gin.Context
	// contains filtered or unexported fields
}

func NewGatewayOpenapiConsumerServiceImpl 

func NewGatewayOpenapiConsumerServiceImpl() (*GatewayOpenapiConsumerServiceImpl, error)

func (GatewayOpenapiConsumerServiceImpl) CreateClientConsumer 

func (impl GatewayOpenapiConsumerServiceImpl) CreateClientConsumer(clientName, clientId, clientSecret, clusterName string) (consumer *orm.GatewayConsumer, err error)

func (GatewayOpenapiConsumerServiceImpl) CreateConsumer 

func (impl GatewayOpenapiConsumerServiceImpl) CreateConsumer(args *gw.DiceArgsDto, dto *gw.OpenConsumerDto) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) DeleteCloudapiAppCredential 

func (impl GatewayOpenapiConsumerServiceImpl) DeleteCloudapiAppCredential(consumerId string) (res *common.StandardResult)

删除阿里云APP凭证

func (GatewayOpenapiConsumerServiceImpl) DeleteConsumer 

func (impl GatewayOpenapiConsumerServiceImpl) DeleteConsumer(id string) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) GetCloudapiAppCredential 

func (impl GatewayOpenapiConsumerServiceImpl) GetCloudapiAppCredential(consumerId string) (res *common.StandardResult)

获取阿里云APP凭证

func (GatewayOpenapiConsumerServiceImpl) GetConsumerAcls 

func (impl GatewayOpenapiConsumerServiceImpl) GetConsumerAcls(id string) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) GetConsumerCredentials 

func (impl GatewayOpenapiConsumerServiceImpl) GetConsumerCredentials(id string) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) GetConsumers 

func (impl GatewayOpenapiConsumerServiceImpl) GetConsumers(args *gw.GetOpenConsumersDto) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) GetConsumersName 

func (impl GatewayOpenapiConsumerServiceImpl) GetConsumersName(args *gw.GetOpenConsumersDto) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) GetConsumersOfPackage 

func (impl GatewayOpenapiConsumerServiceImpl) GetConsumersOfPackage(packageId string) ([]orm.GatewayConsumer, error)

func (GatewayOpenapiConsumerServiceImpl) GetConsumersOfPackageApi 

func (impl GatewayOpenapiConsumerServiceImpl) GetConsumersOfPackageApi(packageId, packageApiId string) ([]orm.GatewayConsumer, error)

func (GatewayOpenapiConsumerServiceImpl) GetKongConsumerName 

func (impl GatewayOpenapiConsumerServiceImpl) GetKongConsumerName(consumer *orm.GatewayConsumer) string

func (GatewayOpenapiConsumerServiceImpl) GetPackageAcls 

func (impl GatewayOpenapiConsumerServiceImpl) GetPackageAcls(id string) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) GetPackageApiAcls 

func (impl GatewayOpenapiConsumerServiceImpl) GetPackageApiAcls(packageId string, packageApiId string) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) GrantPackageToConsumer 

func (impl GatewayOpenapiConsumerServiceImpl) GrantPackageToConsumer(consumerId, packageId string) error

func (GatewayOpenapiConsumerServiceImpl) RevokePackageFromConsumer 

func (impl GatewayOpenapiConsumerServiceImpl) RevokePackageFromConsumer(consumerId, packageId string) error

func (GatewayOpenapiConsumerServiceImpl) SetCloudapiAppCredential 

func (impl GatewayOpenapiConsumerServiceImpl) SetCloudapiAppCredential(consumerId string, async ...bool) (res *common.StandardResult)

生成阿里云APP凭证

func (GatewayOpenapiConsumerServiceImpl) UpdateConsumer 

func (impl GatewayOpenapiConsumerServiceImpl) UpdateConsumer(id string, dto *gw.OpenConsumerDto) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) UpdateConsumerAcls 

func (impl GatewayOpenapiConsumerServiceImpl) UpdateConsumerAcls(id string, dto *gw.ConsumerAclsDto) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) UpdateConsumerCredentials 

func (impl GatewayOpenapiConsumerServiceImpl) UpdateConsumerCredentials(id string, dto *gw.ConsumerCredentialsDto) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) UpdatePackageAcls 

func (impl GatewayOpenapiConsumerServiceImpl) UpdatePackageAcls(id string, dto *gw.PackageAclsDto) *common.StandardResult

func (GatewayOpenapiConsumerServiceImpl) UpdatePackageApiAcls 

func (impl GatewayOpenapiConsumerServiceImpl) UpdatePackageApiAcls(packageId, packageApiId string, dto *gw.PackageAclsDto) *common.StandardResult

type GatewayOpenapiRuleService 

type GatewayOpenapiRuleService interface {
	CreateOrUpdateLimitRule(consumerId, packageId string, limits []exdto.LimitType) error
	CreateLimitRule(*gw.DiceArgsDto, *gw.OpenLimitRuleDto) *common.StandardResult
	UpdateLimitRule(string, *gw.OpenLimitRuleDto) *common.StandardResult
	GetLimitRules(*gw.GetOpenLimitRulesDto) *common.StandardResult
	DeleteLimitRule(string) *common.StandardResult
	CreateRule(DiceInfo, *gw.OpenapiRule, *db.SessionHelper) error
	UpdateRule(string, *gw.OpenapiRule) (*orm.GatewayPackageRule, error)
	// use session if helper not nil
	GetPackageRules(string, *db.SessionHelper, ...gw.RuleCategory) ([]gw.OpenapiRuleInfo, error)
	GetApiRules(string, ...gw.RuleCategory) ([]gw.OpenapiRuleInfo, error)
	DeleteRule(string, *db.SessionHelper) error
	// recycle plugins
	DeleteByPackage(*orm.GatewayPackage) error
	DeleteByPackageApi(*orm.GatewayPackage, *orm.GatewayPackageApi) error
	SetPackageKongPolicies(*orm.GatewayPackage, *db.SessionHelper) error
	SetPackageApiKongPolicies(packageApi *orm.GatewayPackageApi, session *db.SessionHelper) error
}

type GatewayOpenapiRuleServiceImpl 

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

func NewGatewayOpenapiRuleServiceImpl 

func NewGatewayOpenapiRuleServiceImpl() (*GatewayOpenapiRuleServiceImpl, error)

func (GatewayOpenapiRuleServiceImpl) CreateLimitRule 

func (impl GatewayOpenapiRuleServiceImpl) CreateLimitRule(args *gw.DiceArgsDto, dto *gw.OpenLimitRuleDto) *common.StandardResult

func (GatewayOpenapiRuleServiceImpl) CreateOrUpdateLimitRule 

func (impl GatewayOpenapiRuleServiceImpl) CreateOrUpdateLimitRule(consumerId, packageId string, limits []exdto.LimitType) (err error)

func (GatewayOpenapiRuleServiceImpl) CreateRule 

func (impl GatewayOpenapiRuleServiceImpl) CreateRule(diceInfo DiceInfo, rule *gw.OpenapiRule, helper *db.SessionHelper) error

func (GatewayOpenapiRuleServiceImpl) DeleteByPackage 

func (impl GatewayOpenapiRuleServiceImpl) DeleteByPackage(pack *orm.GatewayPackage) error

func (GatewayOpenapiRuleServiceImpl) DeleteByPackageApi 

func (impl GatewayOpenapiRuleServiceImpl) DeleteByPackageApi(pack *orm.GatewayPackage, api *orm.GatewayPackageApi) error

func (GatewayOpenapiRuleServiceImpl) DeleteLimitRule 

func (impl GatewayOpenapiRuleServiceImpl) DeleteLimitRule(id string) *common.StandardResult

func (GatewayOpenapiRuleServiceImpl) DeleteRule 

func (impl GatewayOpenapiRuleServiceImpl) DeleteRule(ruleId string, helper *db.SessionHelper) error

func (GatewayOpenapiRuleServiceImpl) GetApiRules 

func (impl GatewayOpenapiRuleServiceImpl) GetApiRules(apiId string, category ...gw.RuleCategory) ([]gw.OpenapiRuleInfo, error)

func (GatewayOpenapiRuleServiceImpl) GetLimitRules 

func (impl GatewayOpenapiRuleServiceImpl) GetLimitRules(args *gw.GetOpenLimitRulesDto) *common.StandardResult

func (GatewayOpenapiRuleServiceImpl) GetPackageRules 

func (impl GatewayOpenapiRuleServiceImpl) GetPackageRules(packageId string, helper *db.SessionHelper, category ...gw.RuleCategory) ([]gw.OpenapiRuleInfo, error)

func (GatewayOpenapiRuleServiceImpl) SetPackageApiKongPolicies 

func (impl GatewayOpenapiRuleServiceImpl) SetPackageApiKongPolicies(packageApi *orm.GatewayPackageApi, session *db.SessionHelper) error

func (GatewayOpenapiRuleServiceImpl) SetPackageKongPolicies 

func (impl GatewayOpenapiRuleServiceImpl) SetPackageKongPolicies(pack *orm.GatewayPackage, helper *db.SessionHelper) error

func (GatewayOpenapiRuleServiceImpl) UpdateLimitRule 

func (impl GatewayOpenapiRuleServiceImpl) UpdateLimitRule(ruleId string, dto *gw.OpenLimitRuleDto) *common.StandardResult

func (GatewayOpenapiRuleServiceImpl) UpdateRule 

func (impl GatewayOpenapiRuleServiceImpl) UpdateRule(ruleId string, rule *gw.OpenapiRule) (*orm.GatewayPackageRule, error)

type GatewayOpenapiService 

type GatewayOpenapiService interface {
	ClearRuntimeRoute(id string) error
	SetRuntimeEndpoint(RuntimeEndpointInfo) error
	TouchPackageRootApi(packageId string, reqDto *gw.OpenapiDto) *common.StandardResult
	TryClearRuntimePackage(*orm.GatewayRuntimeService, *db.SessionHelper, ...bool) error
	TouchRuntimePackageMeta(*orm.GatewayRuntimeService, *db.SessionHelper) (string, bool, error)
	RefreshRuntimePackage(string, *orm.GatewayRuntimeService, *db.SessionHelper) error
	//用于补偿迁移数据生成的unity package
	CreateUnityPackageZone(string, *db.SessionHelper) (*orm.GatewayZone, error)
	CreateTenantPackage(string, *db.SessionHelper) error
	CreatePackage(*gw.DiceArgsDto, *gw.PackageDto) *common.StandardResult
	GetPackages(*gw.GetPackagesDto) *common.StandardResult
	GetPackage(string) *common.StandardResult
	GetPackagesName(*gw.GetPackagesDto) *common.StandardResult
	UpdatePackage(string, *gw.PackageDto) *common.StandardResult
	DeletePackage(string) *common.StandardResult
	CreatePackageApi(string, *gw.OpenapiDto) *common.StandardResult
	GetPackageApis(string, *gw.GetOpenapiDto) *common.StandardResult
	UpdatePackageApi(string, string, *gw.OpenapiDto) *common.StandardResult
	DeletePackageApi(string, string) *common.StandardResult
	TouchPackageApiZone(info PackageApiInfo, session ...*db.SessionHelper) (string, error)
	// 获取阿里云API网关信息
	GetCloudapiInfo(projectId, env string) *common.StandardResult
	// 获取绑定的阿里云API网关分组域名
	GetCloudapiGroupBind(string) *common.StandardResult
	// 自动绑定阿里云API网关分组
	SetCloudapiGroupBind(orgId, projectId string) *common.StandardResult
}

type GatewayOpenapiServiceImpl 

type GatewayOpenapiServiceImpl struct {
	ReqCtx *gin.Context
	// contains filtered or unexported fields
}

func NewGatewayOpenapiServiceImpl 

func NewGatewayOpenapiServiceImpl() (*GatewayOpenapiServiceImpl, error)

func (GatewayOpenapiServiceImpl) ClearRuntimeRoute 

func (impl GatewayOpenapiServiceImpl) ClearRuntimeRoute(id string) error

func (GatewayOpenapiServiceImpl) CreatePackage 

func (impl GatewayOpenapiServiceImpl) CreatePackage(args *gw.DiceArgsDto, dto *gw.PackageDto) *common.StandardResult

func (GatewayOpenapiServiceImpl) CreatePackageApi 

func (impl GatewayOpenapiServiceImpl) CreatePackageApi(id string, dto *gw.OpenapiDto) *common.StandardResult

func (GatewayOpenapiServiceImpl) CreateTenantPackage 

func (impl GatewayOpenapiServiceImpl) CreateTenantPackage(tenantId string, session *db.SessionHelper) error

func (GatewayOpenapiServiceImpl) CreateUnityPackageZone 

func (impl GatewayOpenapiServiceImpl) CreateUnityPackageZone(packageId string, session *db.SessionHelper) (*orm.GatewayZone, error)

func (GatewayOpenapiServiceImpl) DeletePackage 

func (impl GatewayOpenapiServiceImpl) DeletePackage(id string) *common.StandardResult

func (*GatewayOpenapiServiceImpl) DeletePackageApi 

func (impl *GatewayOpenapiServiceImpl) DeletePackageApi(packageId, apiId string) *common.StandardResult

func (GatewayOpenapiServiceImpl) GetCloudapiGroupBind 

func (impl GatewayOpenapiServiceImpl) GetCloudapiGroupBind(packageId string) *common.StandardResult

获取绑定的阿里云API网关分组域名

func (GatewayOpenapiServiceImpl) GetCloudapiInfo 

func (impl GatewayOpenapiServiceImpl) GetCloudapiInfo(projectId, env string) *common.StandardResult

获取阿里云API网关信息

func (GatewayOpenapiServiceImpl) GetPackage 

func (impl GatewayOpenapiServiceImpl) GetPackage(id string) *common.StandardResult

func (GatewayOpenapiServiceImpl) GetPackageApis 

func (impl GatewayOpenapiServiceImpl) GetPackageApis(id string, args *gw.GetOpenapiDto) *common.StandardResult

func (GatewayOpenapiServiceImpl) GetPackages 

func (impl GatewayOpenapiServiceImpl) GetPackages(args *gw.GetPackagesDto) *common.StandardResult

func (GatewayOpenapiServiceImpl) GetPackagesName 

func (impl GatewayOpenapiServiceImpl) GetPackagesName(args *gw.GetPackagesDto) *common.StandardResult

func (GatewayOpenapiServiceImpl) RefreshRuntimePackage 

func (impl GatewayOpenapiServiceImpl) RefreshRuntimePackage(packageId string, endpoint *orm.GatewayRuntimeService, session *db.SessionHelper) error

func (GatewayOpenapiServiceImpl) SessionCreatePackageApi 

func (impl GatewayOpenapiServiceImpl) SessionCreatePackageApi(id string, dto *gw.OpenapiDto, session *db.SessionHelper, injectRuntimeDomain bool) (bool, string, *apistructs.Audit, error)

func (GatewayOpenapiServiceImpl) SetCloudapiGroupBind 

func (impl GatewayOpenapiServiceImpl) SetCloudapiGroupBind(orgId, packageId string) *common.StandardResult

自动绑定阿里云API网关分组

func (GatewayOpenapiServiceImpl) SetRuntimeEndpoint 

func (impl GatewayOpenapiServiceImpl) SetRuntimeEndpoint(info RuntimeEndpointInfo) error

func (GatewayOpenapiServiceImpl) TouchPackageApiZone 

func (impl GatewayOpenapiServiceImpl) TouchPackageApiZone(info PackageApiInfo, session ...*db.SessionHelper) (string, error)

func (GatewayOpenapiServiceImpl) TouchPackageRootApi 

func (impl GatewayOpenapiServiceImpl) TouchPackageRootApi(packageId string, reqDto *gw.OpenapiDto) (res *common.StandardResult)

func (GatewayOpenapiServiceImpl) TouchRuntimePackageMeta 

func (impl GatewayOpenapiServiceImpl) TouchRuntimePackageMeta(endpoint *orm.GatewayRuntimeService, session *db.SessionHelper) (string, bool, error)

func (GatewayOpenapiServiceImpl) TryClearRuntimePackage 

func (impl GatewayOpenapiServiceImpl) TryClearRuntimePackage(runtimeService *orm.GatewayRuntimeService, session *db.SessionHelper, force ...bool) error

func (GatewayOpenapiServiceImpl) UpdatePackage 

func (impl GatewayOpenapiServiceImpl) UpdatePackage(id string, dto *gw.PackageDto) *common.StandardResult

func (GatewayOpenapiServiceImpl) UpdatePackageApi 

func (impl GatewayOpenapiServiceImpl) UpdatePackageApi(packageId, apiId string, dto *gw.OpenapiDto) *common.StandardResult

type GatewayOrgClientService 

type GatewayOrgClientService interface {
	Create(orgId, name string) *common.StandardResult
	Delete(id string) *common.StandardResult
	GetCredentials(id string) *common.StandardResult
	UpdateCredentials(id string, secret ...string) *common.StandardResult
	GrantPackage(id, packageId string) *common.StandardResult
	RevokePackage(id, packageId string) *common.StandardResult
	CreateOrUpdateLimit(id, packageId string, limits exdto.ChangeLimitsReq) *common.StandardResult
}

type GatewayOrgClientServiceImpl 

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

func NewGatewayOrgClientServiceImpl 

func NewGatewayOrgClientServiceImpl() (*GatewayOrgClientServiceImpl, error)

func (GatewayOrgClientServiceImpl) Create 

func (impl GatewayOrgClientServiceImpl) Create(orgId, name string) (res *common.StandardResult)

func (GatewayOrgClientServiceImpl) CreateOrUpdateLimit 

func (impl GatewayOrgClientServiceImpl) CreateOrUpdateLimit(id, packageId string, req exdto.ChangeLimitsReq) (res *common.StandardResult)

func (GatewayOrgClientServiceImpl) Delete 

func (impl GatewayOrgClientServiceImpl) Delete(id string) (res *common.StandardResult)

func (GatewayOrgClientServiceImpl) GetCredentials 

func (impl GatewayOrgClientServiceImpl) GetCredentials(id string) (res *common.StandardResult)

func (GatewayOrgClientServiceImpl) GrantPackage 

func (impl GatewayOrgClientServiceImpl) GrantPackage(id, packageId string) (res *common.StandardResult)

func (GatewayOrgClientServiceImpl) RevokePackage 

func (impl GatewayOrgClientServiceImpl) RevokePackage(id, packageId string) (res *common.StandardResult)

func (GatewayOrgClientServiceImpl) UpdateCredentials 

func (impl GatewayOrgClientServiceImpl) UpdateCredentials(id string, secret ...string) (res *common.StandardResult)

type GatewayRuntimeServiceService 

type GatewayRuntimeServiceService interface {
	TouchRuntimeComplete(*gin.Context, *gw.RuntimeServiceReqDto) *common.StandardResult
	GetRegisterAppInfo(string, string) *common.StandardResult
	TouchRuntime(*gin.Context, *gw.RuntimeServiceReqDto) *common.StandardResult
	DeleteRuntime(string) *common.StandardResult
	GetServiceRuntimes(projectId, env, app, service string) *common.StandardResult
	// 获取指定服务的API前缀
	GetServiceApiPrefix(*gw.ApiPrefixReqDto) *common.StandardResult
}

type GatewayRuntimeServiceServiceImpl 

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

func NewGatewayRuntimeServiceServiceImpl 

func NewGatewayRuntimeServiceServiceImpl() (*GatewayRuntimeServiceServiceImpl, error)

func (GatewayRuntimeServiceServiceImpl) DeleteRuntime 

func (impl GatewayRuntimeServiceServiceImpl) DeleteRuntime(runtimeId string) *common.StandardResult

func (GatewayRuntimeServiceServiceImpl) GetRegisterAppInfo 

func (impl GatewayRuntimeServiceServiceImpl) GetRegisterAppInfo(projectId, env string) *common.StandardResult

func (GatewayRuntimeServiceServiceImpl) GetServiceApiPrefix 

func (impl GatewayRuntimeServiceServiceImpl) GetServiceApiPrefix(req *gw.ApiPrefixReqDto) (res *common.StandardResult)

获取指定服务的API前缀

func (GatewayRuntimeServiceServiceImpl) GetServiceRuntimes 

func (impl GatewayRuntimeServiceServiceImpl) GetServiceRuntimes(projectId, env, app, service string) *common.StandardResult

func (GatewayRuntimeServiceServiceImpl) TouchRuntime 

func (impl GatewayRuntimeServiceServiceImpl) TouchRuntime(c *gin.Context, reqDto *gw.RuntimeServiceReqDto) *common.StandardResult

func (GatewayRuntimeServiceServiceImpl) TouchRuntimeComplete 

func (impl GatewayRuntimeServiceServiceImpl) TouchRuntimeComplete(c *gin.Context, reqDto *gw.RuntimeServiceReqDto) *common.StandardResult

type GatewayUpstreamLbService 

type GatewayUpstreamLbService interface {
	UpstreamTargetOnline(*gw.UpstreamLbDto) *common.StandardResult
	UpstreamTargetOffline(*gw.UpstreamLbDto) *common.StandardResult
}

type GatewayUpstreamLbServiceImpl 

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

func NewGatewayUpstreamLbServiceImpl 

func NewGatewayUpstreamLbServiceImpl() (*GatewayUpstreamLbServiceImpl, error)

func (GatewayUpstreamLbServiceImpl) UpstreamTargetOffline 

func (impl GatewayUpstreamLbServiceImpl) UpstreamTargetOffline(dto *gw.UpstreamLbDto) *common.StandardResult

func (GatewayUpstreamLbServiceImpl) UpstreamTargetOnline 

func (impl GatewayUpstreamLbServiceImpl) UpstreamTargetOnline(dto *gw.UpstreamLbDto) *common.StandardResult

type GatewayUpstreamService 

type GatewayUpstreamService interface {
	UpstreamValidAsync(*gin.Context, *gw.UpstreamRegisterDto) *common.StandardResult
	UpstreamRegister(*gw.UpstreamRegisterDto) *common.StandardResult
	UpstreamRegisterAsync(*gin.Context, *gw.UpstreamRegisterDto) *common.StandardResult
}

type GatewayUpstreamServiceImpl 

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

func NewGatewayUpstreamServiceImpl 

func NewGatewayUpstreamServiceImpl(consumerService GatewayConsumerService, apiService GatewayApiService) (*GatewayUpstreamServiceImpl, error)

func (GatewayUpstreamServiceImpl) UpstreamRegister 

func (impl GatewayUpstreamServiceImpl) UpstreamRegister(dto *gw.UpstreamRegisterDto) *common.StandardResult

func (GatewayUpstreamServiceImpl) UpstreamRegisterAsync 

func (impl GatewayUpstreamServiceImpl) UpstreamRegisterAsync(c *gin.Context, dto *gw.UpstreamRegisterDto) *common.StandardResult

func (GatewayUpstreamServiceImpl) UpstreamValid 

func (impl GatewayUpstreamServiceImpl) UpstreamValid(consumer *orm.GatewayConsumer, dao *orm.GatewayUpstream, dto *gw.UpstreamRegisterDto) *common.StandardResult

func (GatewayUpstreamServiceImpl) UpstreamValidAsync 

func (impl GatewayUpstreamServiceImpl) UpstreamValidAsync(context *gin.Context, dto *gw.UpstreamRegisterDto) *common.StandardResult

type GatewayZoneService 

type GatewayZoneService interface {
	CreateZoneWithoutIngress(ZoneConfig, ...*db.SessionHelper) (*orm.GatewayZone, error)
	CreateZone(ZoneConfig, ...*db.SessionHelper) (*orm.GatewayZone, error)
	DeleteZoneRoute(string, ...*db.SessionHelper) error
	UpdateZoneRoute(string, ZoneRoute, ...*db.SessionHelper) (bool, error)
	// trigger domain-policy update
	SetZoneKongPolicies(string, gw.ZoneKongPolicies, *db.SessionHelper) error
	SetZoneKongPoliciesWithoutDomainPolicy(zoneId string, policies *gw.ZoneKongPolicies, helper *db.SessionHelper) error
	UpdateKongDomainPolicy(az, projectId, env string, helper *db.SessionHelper) error
	DeleteZone(string) error
	UpdateBuiltinPolicies(string) error
	GetZone(string, ...*db.SessionHelper) (*orm.GatewayZone, error)
}

type GatewayZoneServiceImpl 

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

func NewGatewayZoneServiceImpl 

func NewGatewayZoneServiceImpl() (*GatewayZoneServiceImpl, error)

func (GatewayZoneServiceImpl) CreateZone 

func (impl GatewayZoneServiceImpl) CreateZone(config ZoneConfig, session ...*db.SessionHelper) (*orm.GatewayZone, error)

func (GatewayZoneServiceImpl) CreateZoneWithoutIngress 

func (impl GatewayZoneServiceImpl) CreateZoneWithoutIngress(config ZoneConfig, session ...*db.SessionHelper) (*orm.GatewayZone, error)

func (GatewayZoneServiceImpl) DeleteZone 

func (impl GatewayZoneServiceImpl) DeleteZone(zoneId string) error

func (GatewayZoneServiceImpl) DeleteZoneRoute 

func (impl GatewayZoneServiceImpl) DeleteZoneRoute(zoneId string, session ...*db.SessionHelper) error

func (GatewayZoneServiceImpl) GetRegisterAppInfo 

func (impl GatewayZoneServiceImpl) GetRegisterAppInfo(orgId, projectId, env string) *common.StandardResult

func (GatewayZoneServiceImpl) GetZone 

func (impl GatewayZoneServiceImpl) GetZone(id string, session ...*db.SessionHelper) (*orm.GatewayZone, error)

func (GatewayZoneServiceImpl) SetZoneKongPolicies 

func (impl GatewayZoneServiceImpl) SetZoneKongPolicies(zoneId string, policies gw.ZoneKongPolicies, helper *db.SessionHelper) error

func (GatewayZoneServiceImpl) SetZoneKongPoliciesWithoutDomainPolicy 

func (impl GatewayZoneServiceImpl) SetZoneKongPoliciesWithoutDomainPolicy(zoneId string, policies *gw.ZoneKongPolicies, helper *db.SessionHelper) error

func (GatewayZoneServiceImpl) UpdateBuiltinPolicies 

func (impl GatewayZoneServiceImpl) UpdateBuiltinPolicies(zoneId string) error

func (GatewayZoneServiceImpl) UpdateKongDomainPolicy 

func (impl GatewayZoneServiceImpl) UpdateKongDomainPolicy(az, projectId, env string, helper *db.SessionHelper) error

func (GatewayZoneServiceImpl) UpdateZoneRoute 

func (impl GatewayZoneServiceImpl) UpdateZoneRoute(zoneId string, route ZoneRoute, session ...*db.SessionHelper) (bool, error)

type PackageApiInfo 

type PackageApiInfo struct {
	*orm.GatewayPackageApi
	Hosts               []string
	ProjectId           string
	Env                 string
	Az                  string
	InjectRuntimeDomain bool
}

type RouteConfig 

type RouteConfig struct {
	Hosts []string
	Path  string
	RouteOptions
}

type RuntimeData 

type RuntimeData struct {
	ReleaseId             string `json:"releaseId"`
	ServiceGroupNamespace string `json:"serviceGroupNamespace"`
	ServiceGroupName      string `json:"serviceGroupName"`
}

type RuntimeEndpointInfo 

type RuntimeEndpointInfo struct {
	RuntimeService *orm.GatewayRuntimeService
	Endpoints      []diceyml.Endpoint
}

type RuntimeResponse 

type RuntimeResponse struct {
	Success bool        `json:"success"`
	Data    RuntimeData `json:"data"`
}

type ZoneConfig 

type ZoneConfig struct {
	*ZoneRoute
	Name      string
	ProjectId string
	Env       string
	Az        string
	Type      string
}

type ZoneRoute 

type ZoneRoute struct {
	Route RouteConfig
}

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.