xdsserverv3

Documentation

Index

• Constants
• func NewSnapshotCache(xdsCache cachev3.SnapshotCache, hook CacheHook) cachev3.SnapshotCache
• type CDSBuilder
  • func (cds *CDSBuilder) Generate(option *resource.BuildOption) (interface{}, error)
  • func (cds *CDSBuilder) GenerateByDirection(option *resource.BuildOption, direction corev3.TrafficDirection) ([]types.Resource, error)
  • func (cds *CDSBuilder) Init(client *resource.XDSClient, svr service.DiscoverServer)
• type CacheHook
• type EDSBuilder
  • func (eds *EDSBuilder) Generate(option *resource.BuildOption) (interface{}, error)
  • func (eds *EDSBuilder) Init(client *resource.XDSClient, svr service.DiscoverServer)
• type LDSBuilder
  • func (lds *LDSBuilder) Generate(option *resource.BuildOption) (interface{}, error)
  • func (lds *LDSBuilder) Init(clien *resource.XDSClient, svr service.DiscoverServer)
• type RDSBuilder
  • func (rds *RDSBuilder) Generate(option *resource.BuildOption) (interface{}, error)
  • func (rds *RDSBuilder) Init(client *resource.XDSClient, svr service.DiscoverServer)
• type ResourceServer
• type XDSServer
  • func (x *XDSServer) Generate(needPush map[string]map[model.ServiceKey]*resource.ServiceInfo)
  • 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) OnCreateDeltaWatch(request *cachev3.DeltaRequest, state stream.StreamState, ...)
  • func (x *XDSServer) OnCreateWatch(request *cachev3.Request, streamState stream.StreamState, ...)
  • func (x *XDSServer) OnFetch(ctx context.Context, request *cachev3.Request)
  • 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()
• type XdsResourceGenerator
  • func (x *XdsResourceGenerator) Generate(versionLocal string, ...)

Constants

const (
	SniTemp = "outbound_.default_.%s.%s.svc.cluster.local"
)

Functions

func NewSnapshotCache

func NewSnapshotCache(xdsCache cachev3.SnapshotCache, hook CacheHook) cachev3.SnapshotCache

NewSnapshotCache create a XDS SnapshotCache to proxy cachev3.SnapshotCache

Types

type CDSBuilder

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

CDSBuilder .

func (*CDSBuilder) Generate

func (cds *CDSBuilder) Generate(option *resource.BuildOption) (interface{}, error)

func (*CDSBuilder) GenerateByDirection

func (cds *CDSBuilder) GenerateByDirection(option *resource.BuildOption,
	direction corev3.TrafficDirection) ([]types.Resource, error)

func (*CDSBuilder) Init

func (cds *CDSBuilder) Init(client *resource.XDSClient, svr service.DiscoverServer)

type CacheHook

type CacheHook interface {
	// OnCreateWatch
	OnCreateWatch(request *cachev3.Request, streamState stream.StreamState,
		value chan cachev3.Response)
	// OnCreateDeltaWatch
	OnCreateDeltaWatch(request *cachev3.DeltaRequest, state stream.StreamState,
		value chan cachev3.DeltaResponse)
	// OnFetch
	OnFetch(ctx context.Context, request *cachev3.Request)
}

CacheHook

type EDSBuilder

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

EDSBuilder .

func (*EDSBuilder) Generate

func (eds *EDSBuilder) Generate(option *resource.BuildOption) (interface{}, error)

func (*EDSBuilder) Init

func (eds *EDSBuilder) Init(client *resource.XDSClient, svr service.DiscoverServer)

type LDSBuilder

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

LDSBuilder .

func (*LDSBuilder) Generate

func (lds *LDSBuilder) Generate(option *resource.BuildOption) (interface{}, error)

func (*LDSBuilder) Init

func (lds *LDSBuilder) Init(clien *resource.XDSClient, svr service.DiscoverServer)

type RDSBuilder

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

RDSBuilder .

func (*RDSBuilder) Generate

func (rds *RDSBuilder) Generate(option *resource.BuildOption) (interface{}, error)

func (*RDSBuilder) Init

func (rds *RDSBuilder) Init(client *resource.XDSClient, svr service.DiscoverServer)

type ResourceServer

type ResourceServer interface {
	Generate(versionLocal string, registryInfo map[string]map[model.ServiceKey]*resource.ServiceInfo)
}

type XDSServer

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

XDSServer is the xDS server

func (*XDSServer) Generate

func (x *XDSServer) Generate(needPush map[string]map[model.ServiceKey]*resource.ServiceInfo)

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

func (x *XDSServer) OnCreateDeltaWatch(request *cachev3.DeltaRequest, state stream.StreamState,
	value chan cachev3.DeltaResponse)

OnCreateDeltaWatch before call cachev3.SnapshotCache OnCreateDeltaWatch

func (*XDSServer) OnCreateWatch

func (x *XDSServer) OnCreateWatch(request *cachev3.Request, streamState stream.StreamState,
	value chan cachev3.Response)

OnCreateWatch before call cachev3.SnapshotCache CreateWatch

func (*XDSServer) OnFetch

func (x *XDSServer) OnFetch(ctx context.Context, request *cachev3.Request)

OnFetch before call cachev3.SnapshotCache OnFetch

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 停止服务

type XdsResourceGenerator

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

XdsResourceGenerator is the xDS resource generator

func (*XdsResourceGenerator) Generate

func (x *XdsResourceGenerator) Generate(versionLocal string,
	registryInfo map[string]map[model.ServiceKey]*resource.ServiceInfo)