mux

Documentation

Index

• func NewClient(globalURL string, clientID string, callbacks Callbacks, ...) component.Component
• func NewServer(callbacks []Callbacks, config multizone.KdsServerConfig, ...) component.Component
• type Callbacks
• type MultiplexStream
• type OnSessionStartedFunc
  • func (f OnSessionStartedFunc) OnSessionStarted(session Session) error
• type Session
  • func NewSession(peerID string, stream MultiplexStream, stop <-chan struct{}) Session

Functions

func NewClient

func NewClient(globalURL string, clientID string, callbacks Callbacks, config multizone.KdsClientConfig, metrics metrics.Metrics, ctx context.Context) component.Component

func NewServer

func NewServer(callbacks []Callbacks, config multizone.KdsServerConfig, metrics core_metrics.Metrics) component.Component

Types

type Callbacks

type Callbacks interface {
	OnSessionStarted(session Session) error
}

type MultiplexStream

type MultiplexStream interface {
	Send(*mesh_proto.Message) error
	Recv() (*mesh_proto.Message, error)
	Context() context.Context
}

type OnSessionStartedFunc

type OnSessionStartedFunc func(session Session) error

func (OnSessionStartedFunc) OnSessionStarted

func (f OnSessionStartedFunc) OnSessionStarted(session Session) error

type Session

type Session interface {
	ServerStream() mesh_proto.KumaDiscoveryService_StreamKumaResourcesServer
	ClientStream() mesh_proto.KumaDiscoveryService_StreamKumaResourcesClient
	PeerID() string
	Done() <-chan struct{}
	Error() error
}

func NewSession

func NewSession(peerID string, stream MultiplexStream, stop <-chan struct{}) Session