env

Documentation

Index

• type CtrlChannel
• type NetworkController
• type NetworkControllers
  • func NewNetworkControllers(defaultRequestTimeout time.Duration) NetworkControllers
• type RouterEnv
• type Xrctrl

Types

type CtrlChannel

type CtrlChannel interface {
	Channel() channel.Channel
	DefaultRequestTimeout() time.Duration
}

type NetworkController

type NetworkController interface {
	Channel() channel.Channel
	Latency() time.Duration
	HeartbeatCallback() channel.HeartbeatCallback
	IsUnresponsive() bool
	// contains filtered or unexported methods
}

type NetworkControllers

type NetworkControllers interface {
	Add(ch channel.Channel) NetworkController
	GetAll() map[string]NetworkController
	AnyCtrlChannel() channel.Channel
	GetCtrlChannel(ctrlId string) channel.Channel
	DefaultRequestTimeout() time.Duration
	ForEach(f func(ctrlId string, ch channel.Channel))
	Close() error
}

func NewNetworkControllers

func NewNetworkControllers(defaultRequestTimeout time.Duration) NetworkControllers

type RouterEnv

type RouterEnv interface {
	GetNetworkControllers() NetworkControllers
	GetRouterId() *identity.TokenId
	GetDialerCfg() map[string]xgress.OptionsData
	GetXlinkDialer() []xlink.Dialer
	GetXrctrls() []Xrctrl
	GetTraceHandler() *channel.TraceHandler
	GetXlinkRegistry() xlink.Registry
	GetCloseNotify() <-chan struct{}
	GetMetricsRegistry() metrics.UsageRegistry
}

type Xrctrl

type Xrctrl interface {
	config.Subconfig
	channel.BindHandler
	Enabled() bool
	Run(env RouterEnv) error
	NotifyOfReconnect(ch channel.Channel)
	GetTraceDecoders() []channel.TraceMessageDecoder
}

An Xrctrl allows adding handlers to the router <-> controller connection on the router side. This means you can support additional message types/flows to extend the basic fabric functionality.

There is a corresponding Xctrl interface for extending communication on the controller side