xdsserverv3

Documentation

Index

• Constants
• type Callbacks
  • func (cb *Callbacks) OnDeltaStreamClosed(id int64)
  • func (cb *Callbacks) OnDeltaStreamOpen(_ context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnFetchRequest(_ context.Context, req *discovery.DiscoveryRequest) error
  • func (cb *Callbacks) OnFetchResponse(req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse)
  • func (cb *Callbacks) OnStreamClosed(id int64)
  • func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error
  • func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, ...)
  • func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnStreamRequest(id int64, req *discovery.DiscoveryRequest) error
  • func (cb *Callbacks) OnStreamResponse(_ context.Context, id int64, req *discovery.DiscoveryRequest, ...)
  • func (cb *Callbacks) Report()
• type CircuitBreakerConfigGetter
• type PolarisNodeHash
  • func (PolarisNodeHash) ID(node *core.Node) string
• type RatelimitConfigGetter
• type ServiceInfo
• type XDSServer
  • func (x *XDSServer) GetPort() uint32
  • func (x *XDSServer) GetProtocol() string
  • func (x *XDSServer) Initialize(ctx context.Context, option map[string]interface{}, ...) error
  • func (x *XDSServer) Restart(option map[string]interface{}, apiConf map[string]apiserver.APIConfig, ...) error
  • func (x *XDSServer) Run(errCh chan error)
  • func (x *XDSServer) Stop()

Constants

const (
	K8sDnsResolveSuffixSvc             = ".svc"
	K8sDnsResolveSuffixSvcCluster      = ".svc.cluster"
	K8sDnsResolveSuffixSvcClusterLocal = ".svc.cluster.local"
)

const (
	TLSModeTag        = "polarismesh.cn/tls-mode"
	TLSModeNone       = "none"
	TLSModeStrict     = "strict"
	TLSModePermissive = "permissive"
)

Types

type Callbacks

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

func (*Callbacks) OnDeltaStreamClosed

func (cb *Callbacks) OnDeltaStreamClosed(id int64)

func (*Callbacks) OnDeltaStreamOpen

func (cb *Callbacks) OnDeltaStreamOpen(_ context.Context, id int64, typ string) error

func (*Callbacks) OnFetchRequest

func (cb *Callbacks) OnFetchRequest(_ context.Context, req *discovery.DiscoveryRequest) error

func (*Callbacks) OnFetchResponse

func (cb *Callbacks) OnFetchResponse(req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse)

func (*Callbacks) OnStreamClosed

func (cb *Callbacks) OnStreamClosed(id int64)

func (*Callbacks) OnStreamDeltaRequest

func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error

func (*Callbacks) OnStreamDeltaResponse

func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, resp *discovery.DeltaDiscoveryResponse)

func (*Callbacks) OnStreamOpen

func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error

func (*Callbacks) OnStreamRequest

func (cb *Callbacks) OnStreamRequest(id int64, req *discovery.DiscoveryRequest) error

func (*Callbacks) OnStreamResponse

func (cb *Callbacks) OnStreamResponse(_ context.Context, id int64, req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse)

func (*Callbacks) Report

func (cb *Callbacks) Report()

type CircuitBreakerConfigGetter

type CircuitBreakerConfigGetter func(id string) *model.ServiceWithCircuitBreaker

type PolarisNodeHash

type PolarisNodeHash struct{}

PolarisNodeHash 存放 hash 方法

func (PolarisNodeHash) ID

func (PolarisNodeHash) ID(node *core.Node) string

ID id 的格式是 namespace/uuid~hostIp

type RatelimitConfigGetter

type RatelimitConfigGetter func(serviceID string) []*model.RateLimit

type ServiceInfo

type ServiceInfo struct {
	ID                   string
	Name                 string
	Namespace            string
	Instances            []*api.Instance
	SvcInsRevision       string
	Routing              *api.Routing
	SvcRoutingRevision   string
	Ports                string
	RateLimit            *api.RateLimit
	SvcRateLimitRevision string
}

ServiceInfo 北极星服务结构体

type XDSServer

type XDSServer struct {
	CircuitBreakerConfigGetter CircuitBreakerConfigGetter
	RatelimitConfigGetter      RatelimitConfigGetter
	// contains filtered or unexported fields
}

XDSServer is the xDS server

func (*XDSServer) GetPort

func (x *XDSServer) GetPort() uint32

GetPort 服务注册到北极星中的端口

func (*XDSServer) GetProtocol

func (x *XDSServer) GetProtocol() string

GetProtocol 服务注册到北极星中的协议

func (*XDSServer) Initialize

func (x *XDSServer) Initialize(ctx context.Context, option map[string]interface{},
	apiConf map[string]apiserver.APIConfig,
) error

Initialize 初始化

func (*XDSServer) Restart

func (x *XDSServer) Restart(option map[string]interface{}, apiConf map[string]apiserver.APIConfig, errCh chan error) error

Restart 重启服务

func (*XDSServer) Run

func (x *XDSServer) Run(errCh chan error)

Run 启动运行

func (*XDSServer) Stop

func (x *XDSServer) Stop()

Stop 停止服务