controller

Documentation

Index

• Constants
• type Controller
  • func NewController(cfg *config.Config, versionProvider versions.VersionProvider) (*Controller, error)
  • func (c *Controller) GetApiAddresses() (map[string][]event.ApiAddress, []byte)
  • func (c *Controller) GetCloseNotify() <-chan struct{}
  • func (c *Controller) GetCloseNotifyChannel() <-chan struct{}
  • func (c *Controller) GetCommandDispatcher() command.Dispatcher
  • func (c *Controller) GetCommandRateLimiterConfig() command.RateLimiterConfig
  • func (c *Controller) GetConfig() *config.Config
  • func (c *Controller) GetDb() boltz.Db
  • func (c *Controller) GetEnv() *env.AppEnv
  • func (c *Controller) GetEventDispatcher() event.Dispatcher
  • func (c *Controller) GetHelloHeaderProviders() []mesh.HeaderProvider
  • func (c *Controller) GetId() *identity.TokenId
  • func (c *Controller) GetMetricsRegistry() metrics.Registry
  • func (c *Controller) GetNetwork() *network.Network
  • func (c *Controller) GetOptions() *config.NetworkConfig
  • func (c *Controller) GetPeerAddresses() []string
  • func (c *Controller) GetPeerSigners() []*x509.Certificate
  • func (c *Controller) GetRaftConfig() *config.RaftConfig
  • func (c *Controller) GetRaftIndex() uint64
  • func (c *Controller) GetRaftInfo() (string, string, string)
  • func (c *Controller) GetVersionProvider() versions.VersionProvider
  • func (c *Controller) GetXWebInstance() xweb.Instance
  • func (self *Controller) HandleCustomAgentAsyncOp(conn net.Conn) error
  • func (c *Controller) Identity() identity.Identity
  • func (c *Controller) InitializeRaftFromBoltDb(sourceDbPath string) error
  • func (c *Controller) IsEdgeEnabled() bool
  • func (c *Controller) IsRaftEnabled() bool
  • func (c *Controller) IsRaftLeader() bool
  • func (self *Controller) RegisterAgentBindHandler(bindHandler channel.BindHandler)
  • func (c *Controller) RegisterXctrl(x xctrl.Xctrl) error
  • func (c *Controller) RegisterXmgmt(x xmgmt.Xmgmt) error
  • func (c *Controller) RenderJsonConfig() (string, error)
  • func (c *Controller) Run() error
  • func (c *Controller) Shutdown()
  • func (c *Controller) TryInitializeRaftFromBoltDb() error
  • func (c *Controller) ValidateMigrationEnvironment() error
• type OnConnectCtrlAddressesUpdateHandler
  • func NewOnConnectCtrlAddressesUpdateHandler(ctrlAddress string, raft *raft.Controller) *OnConnectCtrlAddressesUpdateHandler
  • func (o OnConnectCtrlAddressesUpdateHandler) RouterConnected(r *model.Router)
  • func (o *OnConnectCtrlAddressesUpdateHandler) RouterDisconnected(r *model.Router)
• type OnConnectSettingsHandler
  • func (o OnConnectSettingsHandler) RouterConnected(r *model.Router)
  • func (o *OnConnectSettingsHandler) RouterDisconnected(r *model.Router)

Constants

const (
	AgentAppId byte = 1

	AgentIdHeader         = 10
	AgentAddrHeader       = 11
	AgentIsVoterHeader    = 12
	AgentSnapshotFileName = 13
)

Types

type Controller

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

func NewController

func NewController(cfg *config.Config, versionProvider versions.VersionProvider) (*Controller, error)

func (*Controller) GetApiAddresses

func (c *Controller) GetApiAddresses() (map[string][]event.ApiAddress, []byte)

func (*Controller) GetCloseNotify

func (c *Controller) GetCloseNotify() <-chan struct{}

func (*Controller) GetCloseNotifyChannel

func (c *Controller) GetCloseNotifyChannel() <-chan struct{}

func (*Controller) GetCommandDispatcher

func (c *Controller) GetCommandDispatcher() command.Dispatcher

func (*Controller) GetCommandRateLimiterConfig

func (c *Controller) GetCommandRateLimiterConfig() command.RateLimiterConfig

func (*Controller) GetConfig

func (c *Controller) GetConfig() *config.Config

func (*Controller) GetDb

func (c *Controller) GetDb() boltz.Db

func (*Controller) GetEnv

func (c *Controller) GetEnv() *env.AppEnv

func (*Controller) GetEventDispatcher

func (c *Controller) GetEventDispatcher() event.Dispatcher

func (*Controller) GetHelloHeaderProviders

func (c *Controller) GetHelloHeaderProviders() []mesh.HeaderProvider

func (*Controller) GetId

func (c *Controller) GetId() *identity.TokenId

func (*Controller) GetMetricsRegistry

func (c *Controller) GetMetricsRegistry() metrics.Registry

func (*Controller) GetNetwork

func (c *Controller) GetNetwork() *network.Network

func (*Controller) GetOptions

func (c *Controller) GetOptions() *config.NetworkConfig

func (*Controller) GetPeerAddresses

func (c *Controller) GetPeerAddresses() []string

func (*Controller) GetPeerSigners

func (c *Controller) GetPeerSigners() []*x509.Certificate

func (*Controller) GetRaftConfig

func (c *Controller) GetRaftConfig() *config.RaftConfig

func (*Controller) GetRaftIndex

func (c *Controller) GetRaftIndex() uint64

func (*Controller) GetRaftInfo

func (c *Controller) GetRaftInfo() (string, string, string)

func (*Controller) GetVersionProvider

func (c *Controller) GetVersionProvider() versions.VersionProvider

func (*Controller) GetXWebInstance

func (c *Controller) GetXWebInstance() xweb.Instance

func (*Controller) HandleCustomAgentAsyncOp

func (self *Controller) HandleCustomAgentAsyncOp(conn net.Conn) error

func (*Controller) Identity

func (c *Controller) Identity() identity.Identity

func (*Controller) InitializeRaftFromBoltDb

func (c *Controller) InitializeRaftFromBoltDb(sourceDbPath string) error

func (*Controller) IsEdgeEnabled

func (c *Controller) IsEdgeEnabled() bool

func (*Controller) IsRaftEnabled

func (c *Controller) IsRaftEnabled() bool

func (*Controller) IsRaftLeader

func (c *Controller) IsRaftLeader() bool

func (*Controller) RegisterAgentBindHandler

func (self *Controller) RegisterAgentBindHandler(bindHandler channel.BindHandler)

func (*Controller) RegisterXctrl

func (c *Controller) RegisterXctrl(x xctrl.Xctrl) error

func (*Controller) RegisterXmgmt

func (c *Controller) RegisterXmgmt(x xmgmt.Xmgmt) error

func (*Controller) RenderJsonConfig

func (c *Controller) RenderJsonConfig() (string, error)

func (*Controller) Run

func (c *Controller) Run() error

func (*Controller) Shutdown

func (c *Controller) Shutdown()

func (*Controller) TryInitializeRaftFromBoltDb

func (c *Controller) TryInitializeRaftFromBoltDb() error

func (*Controller) ValidateMigrationEnvironment

func (c *Controller) ValidateMigrationEnvironment() error

type OnConnectCtrlAddressesUpdateHandler

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

func NewOnConnectCtrlAddressesUpdateHandler

func NewOnConnectCtrlAddressesUpdateHandler(ctrlAddress string, raft *raft.Controller) *OnConnectCtrlAddressesUpdateHandler

func (OnConnectCtrlAddressesUpdateHandler) RouterConnected

func (o OnConnectCtrlAddressesUpdateHandler) RouterConnected(r *model.Router)

func (*OnConnectCtrlAddressesUpdateHandler) RouterDisconnected

func (o *OnConnectCtrlAddressesUpdateHandler) RouterDisconnected(r *model.Router)

type OnConnectSettingsHandler

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

OnConnectSettingsHandler sends a ctrl_pb.ContentType_SettingsType message when routers connect if necessary Settings are a map of int32 -> []byte data. The type should be used to determine how the setting's []byte array is consumed.

func (OnConnectSettingsHandler) RouterConnected

func (o OnConnectSettingsHandler) RouterConnected(r *model.Router)

func (*OnConnectSettingsHandler) RouterDisconnected

func (o *OnConnectSettingsHandler) RouterDisconnected(r *model.Router)