service_auth

package
v1.18.0 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 3 more Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewServerAuthAbility 

func NewServerAuthAbility(targetServer *service.Server,
	userMgn auth.UserServer, strategyMgn auth.StrategyServer) service.DiscoverServer

Types

type ServerAuthAbility 

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

ServerAuthAbility 带有鉴权能力的 discoverServer 

该层会对请求参数做一些调整，根据具体的请求发起人，设置为数据对应的 owner，不可为为别人进行创建资源

func (*ServerAuthAbility) After 

func (svr *ServerAuthAbility) After(ctx context.Context, resourceType model.Resource, res *service.ResourceEvent) error

After this function is called after the resource operation

func (*ServerAuthAbility) AppendServiceContractInterfaces 

func (svr *ServerAuthAbility) AppendServiceContractInterfaces(ctx context.Context,
	contract *apiservice.ServiceContract, source apiservice.InterfaceDescriptor_Source) *apiservice.Response

AppendServiceContractInterfaces .

func (*ServerAuthAbility) Before 

func (svr *ServerAuthAbility) Before(ctx context.Context, resourceType model.Resource)

Before this function is called before the resource operation

func (*ServerAuthAbility) Cache 

func (svr *ServerAuthAbility) Cache() *cache.CacheManager

Cache Get cache management

func (*ServerAuthAbility) CreateCircuitBreakerRules 

func (svr *ServerAuthAbility) CreateCircuitBreakerRules(
	ctx context.Context, request []*apifault.CircuitBreakerRule) *apiservice.BatchWriteResponse

func (*ServerAuthAbility) CreateCircuitBreakerVersions 

func (svr *ServerAuthAbility) CreateCircuitBreakerVersions(ctx context.Context,
	reqs []*apifault.CircuitBreaker) *apiservice.BatchWriteResponse

CreateCircuitBreakerVersions creates circuit breaker versions

func (*ServerAuthAbility) CreateCircuitBreakers 

func (svr *ServerAuthAbility) CreateCircuitBreakers(ctx context.Context,
	reqs []*apifault.CircuitBreaker) *apiservice.BatchWriteResponse

CreateCircuitBreakers creates circuit breakers

func (*ServerAuthAbility) CreateFaultDetectRules 

func (svr *ServerAuthAbility) CreateFaultDetectRules(
	ctx context.Context, request []*apifault.FaultDetectRule) *apiservice.BatchWriteResponse

func (*ServerAuthAbility) CreateInstances 

func (svr *ServerAuthAbility) CreateInstances(ctx context.Context,
	reqs []*apiservice.Instance) *apiservice.BatchWriteResponse

CreateInstances create instances

func (*ServerAuthAbility) CreateRateLimits 

func (svr *ServerAuthAbility) CreateRateLimits(
	ctx context.Context, reqs []*apitraffic.Rule) *apiservice.BatchWriteResponse

CreateRateLimits creates rate limits for a namespace.

func (*ServerAuthAbility) CreateRoutingConfigs 

func (svr *ServerAuthAbility) CreateRoutingConfigs(
	ctx context.Context, reqs []*apitraffic.Routing) *apiservice.BatchWriteResponse

CreateRoutingConfigs creates routing configs

func (*ServerAuthAbility) CreateRoutingConfigsV2 

func (svr *ServerAuthAbility) CreateRoutingConfigsV2(ctx context.Context,
	req []*apitraffic.RouteRule) *apiservice.BatchWriteResponse

CreateRoutingConfigsV2 批量创建路由配置

func (*ServerAuthAbility) CreateServiceAlias 

func (svr *ServerAuthAbility) CreateServiceAlias(
	ctx context.Context, req *apiservice.ServiceAlias) *apiservice.Response

CreateServiceAlias creates a service alias

func (*ServerAuthAbility) CreateServiceContractInterfaces 

func (svr *ServerAuthAbility) CreateServiceContractInterfaces(ctx context.Context, contract *apiservice.ServiceContract,
	source apiservice.InterfaceDescriptor_Source) *apiservice.Response

CreateServiceContractInterfaces .

func (*ServerAuthAbility) CreateServiceContracts 

func (svr *ServerAuthAbility) CreateServiceContracts(ctx context.Context,
	req []*apiservice.ServiceContract) *apiservice.BatchWriteResponse

CreateServiceContracts .

func (*ServerAuthAbility) CreateServices 

func (svr *ServerAuthAbility) CreateServices(
	ctx context.Context, reqs []*apiservice.Service) *apiservice.BatchWriteResponse

CreateServices 批量创建服务

func (*ServerAuthAbility) DeleteCircuitBreakerRules 

func (svr *ServerAuthAbility) DeleteCircuitBreakerRules(
	ctx context.Context, request []*apifault.CircuitBreakerRule) *apiservice.BatchWriteResponse

func (*ServerAuthAbility) DeleteCircuitBreakers 

func (svr *ServerAuthAbility) DeleteCircuitBreakers(ctx context.Context,
	reqs []*apifault.CircuitBreaker) *apiservice.BatchWriteResponse

DeleteCircuitBreakers delete circuit breakers

func (*ServerAuthAbility) DeleteFaultDetectRules 

func (svr *ServerAuthAbility) DeleteFaultDetectRules(
	ctx context.Context, request []*apifault.FaultDetectRule) *apiservice.BatchWriteResponse

func (*ServerAuthAbility) DeleteInstances 

func (svr *ServerAuthAbility) DeleteInstances(ctx context.Context,
	reqs []*apiservice.Instance) *apiservice.BatchWriteResponse

DeleteInstances delete instances

func (*ServerAuthAbility) DeleteInstancesByHost 

func (svr *ServerAuthAbility) DeleteInstancesByHost(ctx context.Context,
	reqs []*apiservice.Instance) *apiservice.BatchWriteResponse

DeleteInstancesByHost 目前只允许 super account 进行数据删除

func (*ServerAuthAbility) DeleteRateLimits 

func (svr *ServerAuthAbility) DeleteRateLimits(
	ctx context.Context, reqs []*apitraffic.Rule) *apiservice.BatchWriteResponse

DeleteRateLimits deletes rate limits for a namespace.

func (*ServerAuthAbility) DeleteRoutingConfigs 

func (svr *ServerAuthAbility) DeleteRoutingConfigs(
	ctx context.Context, reqs []*apitraffic.Routing) *apiservice.BatchWriteResponse

DeleteRoutingConfigs deletes routing configs

func (*ServerAuthAbility) DeleteRoutingConfigsV2 

func (svr *ServerAuthAbility) DeleteRoutingConfigsV2(ctx context.Context,
	req []*apitraffic.RouteRule) *apiservice.BatchWriteResponse

DeleteRoutingConfigsV2 批量删除路由配置

func (*ServerAuthAbility) DeleteServiceAliases 

func (svr *ServerAuthAbility) DeleteServiceAliases(ctx context.Context,
	reqs []*apiservice.ServiceAlias) *apiservice.BatchWriteResponse

DeleteServiceAliases deletes service aliases

func (*ServerAuthAbility) DeleteServiceContractInterfaces 

func (svr *ServerAuthAbility) DeleteServiceContractInterfaces(ctx context.Context,
	contract *apiservice.ServiceContract) *apiservice.Response

DeleteServiceContractInterfaces .

func (*ServerAuthAbility) DeleteServiceContracts 

func (svr *ServerAuthAbility) DeleteServiceContracts(ctx context.Context,
	req []*apiservice.ServiceContract) *apiservice.BatchWriteResponse

DeleteServiceContracts .

func (*ServerAuthAbility) DeleteServices 

func (svr *ServerAuthAbility) DeleteServices(
	ctx context.Context, reqs []*apiservice.Service) *apiservice.BatchWriteResponse

DeleteServices 批量删除服务

func (*ServerAuthAbility) DeregisterInstance 

func (svr *ServerAuthAbility) DeregisterInstance(ctx context.Context, req *apiservice.Instance) *apiservice.Response

DeregisterInstance delete onr instance

func (*ServerAuthAbility) EnableCircuitBreakerRules 

func (svr *ServerAuthAbility) EnableCircuitBreakerRules(
	ctx context.Context, request []*apifault.CircuitBreakerRule) *apiservice.BatchWriteResponse

func (*ServerAuthAbility) EnableRateLimits 

func (svr *ServerAuthAbility) EnableRateLimits(
	ctx context.Context, reqs []*apitraffic.Rule) *apiservice.BatchWriteResponse

EnableRateLimits 启用限流规则

func (*ServerAuthAbility) EnableRoutings 

func (svr *ServerAuthAbility) EnableRoutings(ctx context.Context,
	req []*apitraffic.RouteRule) *apiservice.BatchWriteResponse

EnableRoutings batch enable routing rules

func (*ServerAuthAbility) GetAllServices 

func (svr *ServerAuthAbility) GetAllServices(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

func (*ServerAuthAbility) GetCircuitBreaker 

func (svr *ServerAuthAbility) GetCircuitBreaker(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

GetCircuitBreaker get circuit breaker

func (*ServerAuthAbility) GetCircuitBreakerByService 

func (svr *ServerAuthAbility) GetCircuitBreakerByService(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

GetCircuitBreakerByService get circuit breaker by service

func (*ServerAuthAbility) GetCircuitBreakerRules 

func (svr *ServerAuthAbility) GetCircuitBreakerRules(
	ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

func (*ServerAuthAbility) GetCircuitBreakerToken 

func (svr *ServerAuthAbility) GetCircuitBreakerToken(
	ctx context.Context, req *apifault.CircuitBreaker) *apiservice.Response

GetCircuitBreakerToken get circuit breaker token

func (*ServerAuthAbility) GetCircuitBreakerVersions 

func (svr *ServerAuthAbility) GetCircuitBreakerVersions(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

GetCircuitBreakerVersions get circuit breaker versions

func (*ServerAuthAbility) GetCircuitBreakerWithCache 

func (svr *ServerAuthAbility) GetCircuitBreakerWithCache(
	ctx context.Context, req *apiservice.Service) *apiservice.DiscoverResponse

GetCircuitBreakerWithCache is the interface for getting a circuit breaker with cache

func (*ServerAuthAbility) GetFaultDetectRules 

func (svr *ServerAuthAbility) GetFaultDetectRules(
	ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

func (*ServerAuthAbility) GetFaultDetectWithCache 

func (svr *ServerAuthAbility) GetFaultDetectWithCache(
	ctx context.Context, req *apiservice.Service) *apiservice.DiscoverResponse

func (*ServerAuthAbility) GetInstanceLabels 

func (svr *ServerAuthAbility) GetInstanceLabels(ctx context.Context,
	query map[string]string) *apiservice.Response

func (*ServerAuthAbility) GetInstances 

func (svr *ServerAuthAbility) GetInstances(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

GetInstances get instances

func (*ServerAuthAbility) GetInstancesCount 

func (svr *ServerAuthAbility) GetInstancesCount(ctx context.Context) *apiservice.BatchQueryResponse

GetInstancesCount get instances to count

func (*ServerAuthAbility) GetMasterCircuitBreakers 

func (svr *ServerAuthAbility) GetMasterCircuitBreakers(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

GetMasterCircuitBreakers get master circuit breakers

func (*ServerAuthAbility) GetPrometheusTargets 

func (svr *ServerAuthAbility) GetPrometheusTargets(ctx context.Context,
	query map[string]string) *model.PrometheusDiscoveryResponse

GetPrometheusTargets Used for client acquisition service information

func (*ServerAuthAbility) GetRateLimitWithCache 

func (svr *ServerAuthAbility) GetRateLimitWithCache(
	ctx context.Context, req *apiservice.Service) *apiservice.DiscoverResponse

GetRateLimitWithCache is the interface for getting rate limit with cache

func (*ServerAuthAbility) GetRateLimits 

func (svr *ServerAuthAbility) GetRateLimits(
	ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

GetRateLimits gets rate limits for a namespace.

func (*ServerAuthAbility) GetReleaseCircuitBreakers 

func (svr *ServerAuthAbility) GetReleaseCircuitBreakers(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

GetReleaseCircuitBreakers get release circuit breakers

func (*ServerAuthAbility) GetRoutingConfigWithCache 

func (svr *ServerAuthAbility) GetRoutingConfigWithCache(
	ctx context.Context, req *apiservice.Service) *apiservice.DiscoverResponse

GetRoutingConfigWithCache is the interface for getting routing config with cache

func (*ServerAuthAbility) GetRoutingConfigs 

func (svr *ServerAuthAbility) GetRoutingConfigs(
	ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

GetRoutingConfigs gets routing configs

func (*ServerAuthAbility) GetServiceAliases 

func (svr *ServerAuthAbility) GetServiceAliases(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

GetServiceAliases gets service aliases

func (*ServerAuthAbility) GetServiceContractVersions 

func (svr *ServerAuthAbility) GetServiceContractVersions(ctx context.Context,
	filter map[string]string) *apiservice.BatchQueryResponse

GetServiceContractVersions .

func (*ServerAuthAbility) GetServiceContractWithCache 

func (svr *ServerAuthAbility) GetServiceContractWithCache(ctx context.Context,
	req *apiservice.ServiceContract) *apiservice.Response

GetServiceContractWithCache User Client Get ServiceContract Rule Information

func (*ServerAuthAbility) GetServiceContracts 

func (svr *ServerAuthAbility) GetServiceContracts(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

GetServiceContracts .

func (*ServerAuthAbility) GetServiceInstanceRevision 

func (svr *ServerAuthAbility) GetServiceInstanceRevision(serviceID string,
	instances []*model.Instance) (string, error)

GetServiceInstanceRevision 获取服务实例的版本号

func (*ServerAuthAbility) GetServiceOwner 

func (svr *ServerAuthAbility) GetServiceOwner(
	ctx context.Context, req []*apiservice.Service) *apiservice.BatchQueryResponse

GetServiceOwner 获取服务的 owner

func (*ServerAuthAbility) GetServiceToken 

func (svr *ServerAuthAbility) GetServiceToken(ctx context.Context, req *apiservice.Service) *apiservice.Response

GetServiceToken 获取服务的 token

func (*ServerAuthAbility) GetServiceWithCache 

func (svr *ServerAuthAbility) GetServiceWithCache(
	ctx context.Context, req *apiservice.Service) *apiservice.DiscoverResponse

GetServiceWithCache is the interface for getting service with cache

func (*ServerAuthAbility) GetServices 

func (svr *ServerAuthAbility) GetServices(
	ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

GetServices 批量获取服务

func (*ServerAuthAbility) GetServicesCount 

func (svr *ServerAuthAbility) GetServicesCount(ctx context.Context) *apiservice.BatchQueryResponse

GetServicesCount 批量获取服务数量

func (*ServerAuthAbility) QueryRoutingConfigsV2 

func (svr *ServerAuthAbility) QueryRoutingConfigsV2(ctx context.Context,
	query map[string]string) *apiservice.BatchQueryResponse

QueryRoutingConfigsV2 提供给OSS的查询路由配置的接口

func (*ServerAuthAbility) RegisterByNameCmd 

func (svr *ServerAuthAbility) RegisterByNameCmd(rbnc *l5.Cl5RegisterByNameCmd) (*l5.Cl5RegisterByNameAckCmd, error)

RegisterByNameCmd 根据名字获取sid信息

func (*ServerAuthAbility) RegisterInstance 

func (svr *ServerAuthAbility) RegisterInstance(ctx context.Context, req *apiservice.Instance) *apiservice.Response

RegisterInstance create one instance

func (*ServerAuthAbility) ReleaseCircuitBreakers 

func (svr *ServerAuthAbility) ReleaseCircuitBreakers(ctx context.Context,
	reqs []*apiservice.ConfigRelease) *apiservice.BatchWriteResponse

ReleaseCircuitBreakers release circuit breakers

func (*ServerAuthAbility) ReportClient 

func (svr *ServerAuthAbility) ReportClient(ctx context.Context, req *apiservice.Client) *apiservice.Response

ReportClient is the interface for reporting client authability

func (*ServerAuthAbility) ReportServiceContract 

func (svr *ServerAuthAbility) ReportServiceContract(ctx context.Context, req *apiservice.ServiceContract) *apiservice.Response

ReportServiceContract .

func (*ServerAuthAbility) ServiceInstancesCache 

func (svr *ServerAuthAbility) ServiceInstancesCache(
	ctx context.Context, filter *apiservice.DiscoverFilter, req *apiservice.Service) *apiservice.DiscoverResponse

ServiceInstancesCache is the interface for getting service instances cache

func (*ServerAuthAbility) SyncByAgentCmd 

func (svr *ServerAuthAbility) SyncByAgentCmd(ctx context.Context, sbac *l5.Cl5SyncByAgentCmd) (
	*l5.Cl5SyncByAgentAckCmd, error)

SyncByAgentCmd 根据sid获取路由信息 老函数： Stat::instance()->inc_sync_req_cnt(); 保存client的IP，该函数只是存储到本地的缓存中 Stat::instance()->add_agent(sbac.agent_ip());

func (*ServerAuthAbility) UnBindCircuitBreakers 

func (svr *ServerAuthAbility) UnBindCircuitBreakers(ctx context.Context,
	reqs []*apiservice.ConfigRelease) *apiservice.BatchWriteResponse

UnBindCircuitBreakers unbind circuit breakers

func (*ServerAuthAbility) UpdateCircuitBreakerRules 

func (svr *ServerAuthAbility) UpdateCircuitBreakerRules(
	ctx context.Context, request []*apifault.CircuitBreakerRule) *apiservice.BatchWriteResponse

func (*ServerAuthAbility) UpdateCircuitBreakers 

func (svr *ServerAuthAbility) UpdateCircuitBreakers(ctx context.Context,
	reqs []*apifault.CircuitBreaker) *apiservice.BatchWriteResponse

UpdateCircuitBreakers update circuit breakers

func (*ServerAuthAbility) UpdateFaultDetectRules 

func (svr *ServerAuthAbility) UpdateFaultDetectRules(
	ctx context.Context, request []*apifault.FaultDetectRule) *apiservice.BatchWriteResponse

func (*ServerAuthAbility) UpdateInstance 

func (svr *ServerAuthAbility) UpdateInstance(ctx context.Context, req *apiservice.Instance) *apiservice.Response

UpdateInstance update single instance

func (*ServerAuthAbility) UpdateInstances 

func (svr *ServerAuthAbility) UpdateInstances(ctx context.Context,
	reqs []*apiservice.Instance) *apiservice.BatchWriteResponse

UpdateInstances update instances

func (*ServerAuthAbility) UpdateInstancesIsolate 

func (svr *ServerAuthAbility) UpdateInstancesIsolate(ctx context.Context,
	reqs []*apiservice.Instance) *apiservice.BatchWriteResponse

UpdateInstancesIsolate update instances

func (*ServerAuthAbility) UpdateRateLimits 

func (svr *ServerAuthAbility) UpdateRateLimits(
	ctx context.Context, reqs []*apitraffic.Rule) *apiservice.BatchWriteResponse

UpdateRateLimits updates rate limits for a namespace.

func (*ServerAuthAbility) UpdateRoutingConfigs 

func (svr *ServerAuthAbility) UpdateRoutingConfigs(
	ctx context.Context, reqs []*apitraffic.Routing) *apiservice.BatchWriteResponse

UpdateRoutingConfigs updates routing configs

func (*ServerAuthAbility) UpdateRoutingConfigsV2 

func (svr *ServerAuthAbility) UpdateRoutingConfigsV2(ctx context.Context,
	req []*apitraffic.RouteRule) *apiservice.BatchWriteResponse

UpdateRoutingConfigsV2 批量更新路由配置

func (*ServerAuthAbility) UpdateServiceAlias 

func (svr *ServerAuthAbility) UpdateServiceAlias(
	ctx context.Context, req *apiservice.ServiceAlias) *apiservice.Response

UpdateServiceAlias updates service alias

func (*ServerAuthAbility) UpdateServiceToken 

func (svr *ServerAuthAbility) UpdateServiceToken(
	ctx context.Context, req *apiservice.Service) *apiservice.Response

UpdateServiceToken 更新服务的 token

func (*ServerAuthAbility) UpdateServices 

func (svr *ServerAuthAbility) UpdateServices(
	ctx context.Context, reqs []*apiservice.Service) *apiservice.BatchWriteResponse

UpdateServices 对于服务修改来说，只针对服务本身，而不需要检查命名空间

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.