service

package

Go to main page

Versions in this module

v1

v1.18.1-alpha.0

Apr 16, 2024

v1.18.0

Mar 4, 2024

Changes in this version

+ func AllowAutoCreate(ctx context.Context) context.Context

+ func GetAllCaches() []cachetypes.ConfigEntry

+ func GetChainOrder() []string

+ func GetRegisterCaches() []cachetypes.ConfigEntry

+ func RegisterServerProxy(name string, factor ServerProxyFactory) error

type ClientServer

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

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

type Config

+ AutoCreate *bool

+ Interceptors []string

+ L5Open bool

type Server

+ func (s *Server) AppendServiceContractInterfaces(ctx context.Context, contract *apiservice.ServiceContract, ...) *apiservice.Response

+ func (s *Server) CreateServiceContract(ctx context.Context, contract *apiservice.ServiceContract) *apiservice.Response

+ func (s *Server) CreateServiceContractInterfaces(ctx context.Context, contract *apiservice.ServiceContract, ...) *apiservice.Response

+ func (s *Server) CreateServiceContracts(ctx context.Context, req []*apiservice.ServiceContract) *apiservice.BatchWriteResponse

+ func (s *Server) DeleteServiceContract(ctx context.Context, contract *apiservice.ServiceContract) *apiservice.Response

+ func (s *Server) DeleteServiceContractInterfaces(ctx context.Context, contract *apiservice.ServiceContract) *apiservice.Response

+ func (s *Server) DeleteServiceContracts(ctx context.Context, req []*apiservice.ServiceContract) *apiservice.BatchWriteResponse

+ func (s *Server) GetServiceContractVersions(ctx context.Context, filter map[string]string) *apiservice.BatchQueryResponse

+ func (s *Server) GetServiceContractWithCache(ctx context.Context, req *apiservice.ServiceContract) *apiservice.Response

+ func (s *Server) GetServiceContracts(ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

+ func (s *Server) ReportServiceContract(ctx context.Context, req *apiservice.ServiceContract) *apiservice.Response

+ type ServerProxyFactory func(svr *Server, pre DiscoverServer) (DiscoverServer, error)

+ type ServiceContractOperateServer interface

+ AppendServiceContractInterfaces func(ctx context.Context, contract *apiservice.ServiceContract, ...) *apiservice.Response

+ CreateServiceContractInterfaces func(ctx context.Context, contract *apiservice.ServiceContract, ...) *apiservice.Response

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

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

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

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

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

v1.18.0-beta.2

Feb 3, 2024

v1.18.0-beta.1

Jan 11, 2024

v1.18.0-beta

Jan 8, 2024

v1.18.0-alpha.1

Jan 2, 2024

v1.18.0-alpha

Dec 21, 2023

v1.17.9

Jan 8, 2024

v1.17.8

Nov 16, 2023

v1.17.7

Oct 24, 2023

v1.17.6

Oct 15, 2023

Changes in this version

+ type InstanceChain interface

+ AfterUpdate func(ctx context.Context, instances ...*model.Instance)

type Server

+ func (s *Server) AddInstanceChain(chains ...InstanceChain)

v1.17.5

Sep 17, 2023

v1.17.4

Sep 6, 2023

v1.17.3

Aug 28, 2023

v1.17.2

Jun 1, 2023

v1.17.1

May 9, 2023

v1.17.0

May 4, 2023

Changes in this version

+ const ContextDiscoverParam

+ const ParamKeyInstanceId

v1.16.5

May 26, 2023

v1.16.4

Apr 28, 2023

v1.16.3

Apr 18, 2023

v1.16.2

Apr 15, 2023

v1.16.1

Apr 7, 2023

v1.16.0

Mar 31, 2023

Changes in this version

type Server

+ func (s *Server) GetAllServices(ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

type ServiceOperateServer

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

v1.15.2

Mar 25, 2023

v1.15.1

Mar 20, 2023

Changes in this version

+ func Api2RoutingConfigV2(req *apitraffic.RouteRule) (*model.RouterConfig, error)

+ func TestCheckCreateInstance(req *apiservice.Instance) (string, *apiservice.Response)

+ func TestIsEmptyLocation(loc *apimodel.Location) bool

type Server

+ func TestNewServer(mockStore store.Store, nsSvr namespace.NamespaceOperateServer, ...) *Server

+ func (s *Server) GetBatchController() *batch.Controller

+ func (s *Server) MockBatchController(bc *batch.Controller)

+ func (s *Server) TestSerialCreateInstance(ctx context.Context, svcId string, req *apiservice.Instance, ...) (*model.Instance, *apiservice.Response)

v1.15.0

Mar 12, 2023

Changes in this version

+ type BaseInstanceEventHandler struct

+ func NewBaseInstanceEventHandler(namingServer DiscoverServer) *BaseInstanceEventHandler

+ func (b *BaseInstanceEventHandler) PreProcess(ctx context.Context, value any) any

+ type Bootstrap struct

+ Logger map[string]*commonlog.Options

+ type DiscoverTestSuit struct

+ func (d *DiscoverTestSuit) CheckGetService(t *testing.T, expectReqs []*apiservice.Service, ...)

+ func (d *DiscoverTestSuit) Destroy()

+ func (d *DiscoverTestSuit) DiscoverServer() DiscoverServer

+ func (d *DiscoverTestSuit) GetLastHeartBeat(t *testing.T, service *apiservice.Service, instanceID string) *apiservice.Response

+ func (d *DiscoverTestSuit) HealthCheckServer() *healthcheck.Server

+ func (d *DiscoverTestSuit) HeartBeat(t *testing.T, service *apiservice.Service, instanceID string)

+ func (d *DiscoverTestSuit) Initialize(opts ...options) error

+ type PluginInstanceEventHandler struct

+ func (p *PluginInstanceEventHandler) OnEvent(ctx context.Context, any2 any) error

type RouterRuleOperateServer

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

type Server

+ func (s *Server) QueryRoutingConfigsV2(ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

+ type TestConfig struct

+ Auth auth.Config

+ Bootstrap Bootstrap

+ Cache cache.Config

+ Config Config

+ HealthChecks healthcheck.Config

+ Namespace ns.Config

+ Naming Config

+ Plugin plugin.Config

+ Store store.Config

v1.14.2

Feb 27, 2023

v1.14.1

Feb 16, 2023

v1.14.0

Feb 14, 2023

Changes in this version

+ const MaxRuleName

+ var CircuitBreakerRuleFilters = map[string]bool

+ var FaultDetectRuleFilters = map[string]bool

type CircuitBreakerOperateServer

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

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

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

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

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

type ClientServer

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

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

+ GetRouterConfigWithCache func(ctx context.Context, req *apiservice.Service) *apiservice.DiscoverResponse

+ type FaultDetectRuleOperateServer interface

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

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

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

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

+ type RouterRuleOperateServer interface

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

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

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

+ GetRoutingConfigsV2 func(ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

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

type Server

+ func (s *Server) CreateCircuitBreakerRules(ctx context.Context, request []*apifault.CircuitBreakerRule) *apiservice.BatchWriteResponse

+ func (s *Server) CreateFaultDetectRules(ctx context.Context, request []*apifault.FaultDetectRule) *apiservice.BatchWriteResponse

+ func (s *Server) DeleteCircuitBreakerRules(ctx context.Context, request []*apifault.CircuitBreakerRule) *apiservice.BatchWriteResponse

+ func (s *Server) DeleteFaultDetectRules(ctx context.Context, request []*apifault.FaultDetectRule) *apiservice.BatchWriteResponse

+ func (s *Server) EnableCircuitBreakerRules(ctx context.Context, request []*apifault.CircuitBreakerRule) *apiservice.BatchWriteResponse

+ func (s *Server) GetCircuitBreakerRules(ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

+ func (s *Server) GetFaultDetectRules(ctx context.Context, query map[string]string) *apiservice.BatchQueryResponse

+ func (s *Server) GetFaultDetectWithCache(ctx context.Context, req *apiservice.Service) *apiservice.DiscoverResponse

+ func (s *Server) GetPrometheusTargets(ctx context.Context, query map[string]string) *model.PrometheusDiscoveryResponse

+ func (s *Server) GetRouterConfigWithCache(ctx context.Context, req *apiservice.Service) *apiservice.DiscoverResponse

+ func (s *Server) UpdateCircuitBreakerRules(ctx context.Context, request []*apifault.CircuitBreakerRule) *apiservice.BatchWriteResponse

+ func (s *Server) UpdateFaultDetectRules(ctx context.Context, request []*apifault.FaultDetectRule) *apiservice.BatchWriteResponse

v1.14.0-alpha

Dec 28, 2022

v1.13.9

Feb 27, 2023

Changes in this version

type ClientServer

+ UpdateInstance func(ctx context.Context, req *api.Instance) *api.Response

v1.13.8

Feb 9, 2023

v1.13.7

Jan 16, 2023

v1.13.6

Jan 4, 2023

v1.13.5

Dec 31, 2022

v1.13.4

Dec 24, 2022

v1.13.3

Dec 8, 2022

v1.13.2

Dec 2, 2022

v1.13.1

Dec 2, 2022

v1.13.0

Nov 29, 2022

Changes in this version

+ const DefaultNamespace

+ const DefaultTLL

+ const ID

+ const Master

+ const MaxBatchSize

+ const MaxBusinessLength

+ const MaxCommentLength

+ const MaxDbCircuitbreakerBusiness

+ const MaxDbCircuitbreakerComment

+ const MaxDbCircuitbreakerDepartment

+ const MaxDbCircuitbreakerName

+ const MaxDbCircuitbreakerNamespace

+ const MaxDbCircuitbreakerOwner

+ const MaxDbCircuitbreakerVersion

+ const MaxDbInsHostLength

+ const MaxDbInsLogicSetLength

+ const MaxDbInsProtocolLength

+ const MaxDbInsVersionLength

+ const MaxDbRateLimitName

+ const MaxDbRoutingName

+ const MaxDbServiceBusinessLength

+ const MaxDbServiceCMDBLength

+ const MaxDbServiceCommentLength

+ const MaxDbServiceDeptLength

+ const MaxDbServiceNameLength

+ const MaxDbServiceNamespaceLength

+ const MaxDbServiceOwnerLength

+ const MaxDbServicePortsLength

+ const MaxDbServiceToken

+ const MaxDepartmentLength

+ const MaxMetadataLength

+ const MaxOwnersLength

+ const MaxPlatformDomainLength

+ const MaxPlatformIDLength

+ const MaxPlatformNameLength

+ const MaxPlatformQPS

+ const MaxQuerySize

+ const MetadataInternalAutoCreated

+ const Namespace

+ const ProductionNamespace

+ const QueryDefaultLimit

+ const QueryDefaultOffset

+ const QueryMaxLimit

+ const Service

+ const SystemNamespace

+ const Version

+ var AliasFilterAttributes = map[string]bool

+ var InsFilter2toreAttr = map[string]string

+ var InstanceFilterAttributes = map[string]bool

+ var MasterCircuitBreakers = map[string]bool

+ var Namespace2SidLayoutID = map[string]uint32

+ var NotInsFilterAttr = map[string]bool

+ var RateLimitFilters = map[string]bool

+ var ReleaseCircuitBreakers = map[string]bool

+ var RoutingConfigFilterAttrs = map[string]bool

+ var RoutingConfigV2FilterAttrs = map[string]bool

+ var ServiceFilterAttributes = map[string]int

+ var ServiceParams = map[string]bool

+ var SidLayoutID2Namespace = map[uint32]string

+ func CalculateInstanceID(namespace string, service string, vpcID string, host string, port uint32) (string, error)

+ func CalculateRuleID(name, namespace string) string

+ func CheckDbCircuitBreakerFieldLen(req *api.CircuitBreaker) (*api.Response, bool)

+ func CheckDbInstanceFieldLen(req *api.Instance) (*api.Response, bool)

+ func CheckDbMetaDataFieldLen(metaData map[string]string) error

+ func CheckDbServiceAliasFieldLen(req *api.ServiceAlias) (*api.Response, bool)

+ func CheckDbServiceFieldLen(req *api.Service) (*api.Response, bool)

+ func CheckDbStrFieldLen(param *wrappers.StringValue, dbLen int) error

+ func ComputeNamespace(modID uint32, cmdID uint32) []string

+ func CreateCl5SidList(sidConfigs []*model.SidConfig) *l5.Cl5SidList

+ func Initialize(ctx context.Context, namingOpt *Config, opts ...InitOption) error

+ func ParseIPInt2Str(ip uint32) string

+ func ParseIPStr2Int(ip string) (uint32, error)

+ func ParseIPStr2IntV2(ip string) uint32

+ func ParseInstanceArgs(query map[string]string) (*store.InstanceArgs, error)

+ func ParseOffsetAndLimit(query map[string]string) (uint32, uint32, error)

+ func ParseOperator(ctx context.Context) string

+ func ParsePlatformID(ctx context.Context) string

+ func ParsePlatformToken(ctx context.Context) string

+ func ParseQueryLimit(limit string) (uint32, error)

+ func ParseQueryOffset(offset string) (uint32, error)

+ func ParseRequestID(ctx context.Context) string

+ func ParseSetID(str string) []string

+ func ParseToken(ctx context.Context) string

+ func ParseWeight(str string) []uint32

+ func ZapInstanceID(id string) zap.Field

+ func ZapPlatformID(id string) zap.Field

+ func ZapRequestID(id string) zap.Field

+ type CircuitBreakerOperateServer interface

+ CreateCircuitBreakerVersions func(ctx context.Context, req []*api.CircuitBreaker) *api.BatchWriteResponse

+ CreateCircuitBreakers func(ctx context.Context, req []*api.CircuitBreaker) *api.BatchWriteResponse

+ DeleteCircuitBreakers func(ctx context.Context, req []*api.CircuitBreaker) *api.BatchWriteResponse

+ GetCircuitBreaker func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ GetCircuitBreakerByService func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ GetCircuitBreakerToken func(ctx context.Context, req *api.CircuitBreaker) *api.Response

+ GetCircuitBreakerVersions func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ GetMasterCircuitBreakers func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ GetReleaseCircuitBreakers func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ ReleaseCircuitBreakers func(ctx context.Context, req []*api.ConfigRelease) *api.BatchWriteResponse

+ UnBindCircuitBreakers func(ctx context.Context, req []*api.ConfigRelease) *api.BatchWriteResponse

+ UpdateCircuitBreakers func(ctx context.Context, req []*api.CircuitBreaker) *api.BatchWriteResponse

+ type Client2Api func(client *model.Client) *api.Client

+ type ClientServer interface

+ DeregisterInstance func(ctx context.Context, req *api.Instance) *api.Response

+ GetCircuitBreakerWithCache func(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ GetRateLimitWithCache func(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ GetReportClientWithCache func(ctx context.Context, query map[string]string) *model.PrometheusDiscoveryResponse

+ GetRoutingConfigWithCache func(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ GetServiceWithCache func(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ RegisterInstance func(ctx context.Context, req *api.Instance) *api.Response

+ ReportClient func(ctx context.Context, req *api.Client) *api.Response

+ ServiceInstancesCache func(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ type ClientV2Server interface

+ GetCircuitBreakerV2WithCache func(ctx context.Context, req *apiv2.Service) *apiv2.DiscoverResponse

+ GetRoutingConfigV2WithCache func(ctx context.Context, req *apiv2.Service) *apiv2.DiscoverResponse

+ type Config struct

+ Auth map[string]interface{}

+ Batch map[string]interface{}

+ type DiscoverServer interface

+ Cache func() *cache.CacheManager

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

+ func GetServer() (DiscoverServer, error)

+ func TestInitialize(ctx context.Context, namingOpt *Config, cacheOpt *cache.Config, ...) (DiscoverServer, error)

+ type DiscoverServerV1 interface

+ type DiscoverServerV2 interface

+ type InitOption func(s *Server)

+ func WithBatchController(c *batch.Controller) InitOption

+ func WithCacheManager(cacheOpt *cache.Config, c *cache.CacheManager) InitOption

+ func WithHealthCheckSvr(svr *healthcheck.Server) InitOption

+ func WithHiddenService(c map[model.ServiceKey]struct{}) InitOption

+ func WithNamespaceSvr(svr namespace.NamespaceOperateServer) InitOption

+ func WithStorage(storage store.Store) InitOption

+ type InstanceOperateServer interface

+ CleanInstance func(ctx context.Context, req *api.Instance) *api.Response

+ CreateInstances func(ctx context.Context, reqs []*api.Instance) *api.BatchWriteResponse

+ DeleteInstances func(ctx context.Context, req []*api.Instance) *api.BatchWriteResponse

+ DeleteInstancesByHost func(ctx context.Context, req []*api.Instance) *api.BatchWriteResponse

+ GetInstanceLabels func(ctx context.Context, query map[string]string) *api.Response

+ GetInstances func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ GetInstancesCount func(ctx context.Context) *api.BatchQueryResponse

+ UpdateInstances func(ctx context.Context, req []*api.Instance) *api.BatchWriteResponse

+ UpdateInstancesIsolate func(ctx context.Context, req []*api.Instance) *api.BatchWriteResponse

+ type L5OperateServer interface

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

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

+ type RateLimitOperateServer interface

+ CreateRateLimits func(ctx context.Context, request []*api.Rule) *api.BatchWriteResponse

+ DeleteRateLimits func(ctx context.Context, request []*api.Rule) *api.BatchWriteResponse

+ EnableRateLimits func(ctx context.Context, request []*api.Rule) *api.BatchWriteResponse

+ GetRateLimits func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ UpdateRateLimits func(ctx context.Context, request []*api.Rule) *api.BatchWriteResponse

+ type ReportClientOperateServer interface

+ GetReportClients func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ type ResourceEvent struct

+ IsRemove bool

+ ReqService *api.Service

+ Service *model.Service

+ type ResourceHook interface

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

+ Before func(ctx context.Context, resourceType model.Resource)

+ type RouteRuleOperateServer interface

+ CreateRoutingConfigs func(ctx context.Context, req []*api.Routing) *api.BatchWriteResponse

+ DeleteRoutingConfigs func(ctx context.Context, req []*api.Routing) *api.BatchWriteResponse

+ GetRoutingConfigs func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ UpdateRoutingConfigs func(ctx context.Context, req []*api.Routing) *api.BatchWriteResponse

+ type RouteRuleV2OperateServer interface

+ CreateRoutingConfigsV2 func(ctx context.Context, req []*apiv2.Routing) *apiv2.BatchWriteResponse

+ DeleteRoutingConfigsV2 func(ctx context.Context, req []*apiv2.Routing) *apiv2.BatchWriteResponse

+ EnableRoutings func(ctx context.Context, req []*apiv2.Routing) *apiv2.BatchWriteResponse

+ GetRoutingConfigsV2 func(ctx context.Context, query map[string]string) *apiv2.BatchQueryResponse

+ UpdateRoutingConfigsV2 func(ctx context.Context, req []*apiv2.Routing) *apiv2.BatchWriteResponse

+ type Server struct

+ func GetOriginServer() (*Server, error)

+ func (s *Server) Cache() *cache.CacheManager

+ func (s *Server) CleanInstance(ctx context.Context, req *api.Instance) *api.Response

+ func (s *Server) CreateCircuitBreaker(ctx context.Context, req *api.CircuitBreaker) *api.Response

+ func (s *Server) CreateCircuitBreakerVersion(ctx context.Context, req *api.CircuitBreaker) *api.Response

+ func (s *Server) CreateCircuitBreakerVersions(ctx context.Context, req []*api.CircuitBreaker) *api.BatchWriteResponse

+ func (s *Server) CreateCircuitBreakers(ctx context.Context, req []*api.CircuitBreaker) *api.BatchWriteResponse

+ func (s *Server) CreateInstance(ctx context.Context, req *api.Instance) *api.Response

+ func (s *Server) CreateInstances(ctx context.Context, reqs []*api.Instance) *api.BatchWriteResponse

+ func (s *Server) CreateRateLimit(ctx context.Context, req *api.Rule, svcId string) *api.Response

+ func (s *Server) CreateRateLimits(ctx context.Context, request []*api.Rule) *api.BatchWriteResponse

+ func (s *Server) CreateRoutingConfig(ctx context.Context, req *api.Routing) *api.Response

+ func (s *Server) CreateRoutingConfigs(ctx context.Context, req []*api.Routing) *api.BatchWriteResponse

+ func (s *Server) CreateRoutingConfigsV2(ctx context.Context, req []*apiv2.Routing) *apiv2.BatchWriteResponse

+ func (s *Server) CreateService(ctx context.Context, req *api.Service) *api.Response

+ func (s *Server) CreateServiceAlias(ctx context.Context, req *api.ServiceAlias) *api.Response

+ func (s *Server) CreateServices(ctx context.Context, req []*api.Service) *api.BatchWriteResponse

+ func (s *Server) DeleteCircuitBreaker(ctx context.Context, req *api.CircuitBreaker) *api.Response

+ func (s *Server) DeleteCircuitBreakers(ctx context.Context, req []*api.CircuitBreaker) *api.BatchWriteResponse

+ func (s *Server) DeleteInstance(ctx context.Context, req *api.Instance) *api.Response

+ func (s *Server) DeleteInstanceByHost(ctx context.Context, req *api.Instance) *api.Response

+ func (s *Server) DeleteInstances(ctx context.Context, req []*api.Instance) *api.BatchWriteResponse

+ func (s *Server) DeleteInstancesByHost(ctx context.Context, req []*api.Instance) *api.BatchWriteResponse

+ func (s *Server) DeleteRateLimit(ctx context.Context, req *api.Rule) *api.Response

+ func (s *Server) DeleteRateLimits(ctx context.Context, request []*api.Rule) *api.BatchWriteResponse

+ func (s *Server) DeleteRoutingConfig(ctx context.Context, req *api.Routing) *api.Response

+ func (s *Server) DeleteRoutingConfigs(ctx context.Context, req []*api.Routing) *api.BatchWriteResponse

+ func (s *Server) DeleteRoutingConfigsV2(ctx context.Context, req []*apiv2.Routing) *apiv2.BatchWriteResponse

+ func (s *Server) DeleteService(ctx context.Context, req *api.Service) *api.Response

+ func (s *Server) DeleteServiceAlias(ctx context.Context, req *api.ServiceAlias) *api.Response

+ func (s *Server) DeleteServiceAliases(ctx context.Context, req []*api.ServiceAlias) *api.BatchWriteResponse

+ func (s *Server) DeleteServices(ctx context.Context, req []*api.Service) *api.BatchWriteResponse

+ func (s *Server) DeregisterInstance(ctx context.Context, req *api.Instance) *api.Response

+ func (s *Server) EnableRateLimit(ctx context.Context, req *api.Rule) *api.Response

+ func (s *Server) EnableRateLimits(ctx context.Context, request []*api.Rule) *api.BatchWriteResponse

+ func (s *Server) EnableRoutings(ctx context.Context, req []*apiv2.Routing) *apiv2.BatchWriteResponse

+ func (s *Server) GetCircuitBreaker(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetCircuitBreakerByService(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetCircuitBreakerToken(ctx context.Context, req *api.CircuitBreaker) *api.Response

+ func (s *Server) GetCircuitBreakerV2WithCache(ctx context.Context, req *apiv2.Service) *apiv2.DiscoverResponse

+ func (s *Server) GetCircuitBreakerVersions(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetCircuitBreakerWithCache(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ func (s *Server) GetInstanceLabels(ctx context.Context, query map[string]string) *api.Response

+ func (s *Server) GetInstances(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetInstancesCount(ctx context.Context) *api.BatchQueryResponse

+ func (s *Server) GetMasterCircuitBreakers(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetRateLimitWithCache(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ func (s *Server) GetRateLimits(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetReleaseCircuitBreakers(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetReportClientWithCache(ctx context.Context, query map[string]string) *model.PrometheusDiscoveryResponse

+ func (s *Server) GetReportClients(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetRoutingConfigV2WithCache(ctx context.Context, req *apiv2.Service) *apiv2.DiscoverResponse

+ func (s *Server) GetRoutingConfigWithCache(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ func (s *Server) GetRoutingConfigs(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetRoutingConfigsV2(ctx context.Context, query map[string]string) *apiv2.BatchQueryResponse

+ func (s *Server) GetServiceAliases(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetServiceInstanceRevision(serviceID string, instances []*model.Instance) (string, error)

+ func (s *Server) GetServiceOwner(ctx context.Context, req []*api.Service) *api.BatchQueryResponse

+ func (s *Server) GetServiceToken(ctx context.Context, req *api.Service) *api.Response

+ func (s *Server) GetServiceWithCache(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ func (s *Server) GetServices(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ func (s *Server) GetServicesCount(ctx context.Context) *api.BatchQueryResponse

+ func (s *Server) HealthServer() *healthcheck.Server

+ func (s *Server) Namespace() namespace.NamespaceOperateServer

+ func (s *Server) RecordDiscoverStatis(service, discoverNamespace string)

+ func (s *Server) RecordHistory(entry *model.RecordEntry)

+ func (s *Server) RegisterByNameCmd(rbnc *l5.Cl5RegisterByNameCmd) (*l5.Cl5RegisterByNameAckCmd, error)

+ func (s *Server) RegisterInstance(ctx context.Context, req *api.Instance) *api.Response

+ func (s *Server) ReleaseCircuitBreaker(ctx context.Context, req *api.ConfigRelease) *api.Response

+ func (s *Server) ReleaseCircuitBreakers(ctx context.Context, req []*api.ConfigRelease) *api.BatchWriteResponse

+ func (s *Server) ReportClient(ctx context.Context, req *api.Client) *api.Response

+ func (s *Server) ServiceInstancesCache(ctx context.Context, req *api.Service) *api.DiscoverResponse

+ func (s *Server) SetResourceHooks(hooks ...ResourceHook)

+ func (s *Server) SyncByAgentCmd(ctx context.Context, sbac *l5.Cl5SyncByAgentCmd) (*l5.Cl5SyncByAgentAckCmd, error)

+ func (s *Server) UnBindCircuitBreaker(ctx context.Context, req *api.ConfigRelease) *api.Response

+ func (s *Server) UnBindCircuitBreakers(ctx context.Context, req []*api.ConfigRelease) *api.BatchWriteResponse

+ func (s *Server) UpdateCircuitBreaker(ctx context.Context, req *api.CircuitBreaker) *api.Response

+ func (s *Server) UpdateCircuitBreakers(ctx context.Context, req []*api.CircuitBreaker) *api.BatchWriteResponse

+ func (s *Server) UpdateInstance(ctx context.Context, req *api.Instance) *api.Response

+ func (s *Server) UpdateInstanceIsolate(ctx context.Context, req *api.Instance) *api.Response

+ func (s *Server) UpdateInstances(ctx context.Context, req []*api.Instance) *api.BatchWriteResponse

+ func (s *Server) UpdateInstancesIsolate(ctx context.Context, req []*api.Instance) *api.BatchWriteResponse

+ func (s *Server) UpdateRateLimit(ctx context.Context, req *api.Rule) *api.Response

+ func (s *Server) UpdateRateLimits(ctx context.Context, request []*api.Rule) *api.BatchWriteResponse

+ func (s *Server) UpdateRoutingConfig(ctx context.Context, req *api.Routing) *api.Response

+ func (s *Server) UpdateRoutingConfigs(ctx context.Context, req []*api.Routing) *api.BatchWriteResponse

+ func (s *Server) UpdateRoutingConfigsV2(ctx context.Context, req []*apiv2.Routing) *apiv2.BatchWriteResponse

+ func (s *Server) UpdateService(ctx context.Context, req *api.Service) *api.Response

+ func (s *Server) UpdateServiceAlias(ctx context.Context, req *api.ServiceAlias) *api.Response

+ func (s *Server) UpdateServiceToken(ctx context.Context, req *api.Service) *api.Response

+ func (s *Server) UpdateServices(ctx context.Context, req []*api.Service) *api.BatchWriteResponse

+ type Service2Api func(service *model.Service) *api.Service

+ type ServiceAliasOperateServer interface

+ CreateServiceAlias func(ctx context.Context, req *api.ServiceAlias) *api.Response

+ DeleteServiceAliases func(ctx context.Context, req []*api.ServiceAlias) *api.BatchWriteResponse

+ GetServiceAliases func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ UpdateServiceAlias func(ctx context.Context, req *api.ServiceAlias) *api.Response

+ type ServiceOperateServer interface

+ CreateServices func(ctx context.Context, req []*api.Service) *api.BatchWriteResponse

+ DeleteServices func(ctx context.Context, req []*api.Service) *api.BatchWriteResponse

+ GetServiceOwner func(ctx context.Context, req []*api.Service) *api.BatchQueryResponse

+ GetServiceToken func(ctx context.Context, req *api.Service) *api.Response

+ GetServices func(ctx context.Context, query map[string]string) *api.BatchQueryResponse

+ GetServicesCount func(ctx context.Context) *api.BatchQueryResponse

+ UpdateServiceToken func(ctx context.Context, req *api.Service) *api.Response

+ UpdateServices func(ctx context.Context, req []*api.Service) *api.BatchWriteResponse

v1.13.0-alpha.4

Nov 29, 2022

v1.13.0-alpha.3

Nov 25, 2022

v1.13.0-alpha.2

Nov 24, 2022

v1.13.0-alpha.1

Nov 1, 2022

v1.13.0-alpha.0

Oct 11, 2022

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