Documentation
¶
Index ¶
- Constants
- type CertValidatingIdentity
- type Config
- type Controller
- func (c *Controller) GetCloseNotify() <-chan struct{}
- func (c *Controller) GetCloseNotifyChannel() <-chan struct{}
- func (c *Controller) GetCommandDispatcher() command.Dispatcher
- func (c *Controller) GetDb() boltz.Db
- func (c *Controller) GetEventDispatcher() event.Dispatcher
- func (c *Controller) GetId() *identity.TokenId
- func (c *Controller) GetMetricsRegistry() metrics.Registry
- func (c *Controller) GetNetwork() *network.Network
- func (c *Controller) GetOptions() *network.Options
- func (c *Controller) GetPeerSigners() []*x509.Certificate
- func (c *Controller) GetRaftConfig() *raft.Config
- 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) IsRaftEnabled() 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
- type CtrlOptions
- type OnConnectCtrlAddressesUpdateHandler
- type OnConnectSettingsHandler
Constants ¶
View Source
const ( AgentAppId byte = 1 AgentIdHeader = 10 AgentAddrHeader = 11 AgentIsVoterHeader = 12 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CertValidatingIdentity ¶ added in v0.21.21
func (*CertValidatingIdentity) ClientTLSConfig ¶ added in v0.21.21
func (self *CertValidatingIdentity) ClientTLSConfig() *tls.Config
func (*CertValidatingIdentity) ServerTLSConfig ¶ added in v0.21.21
func (self *CertValidatingIdentity) ServerTLSConfig() *tls.Config
func (*CertValidatingIdentity) VerifyConnection ¶ added in v0.21.21
func (self *CertValidatingIdentity) VerifyConnection(state tls.ConnectionState) error
type Config ¶
type Config struct { Id *identity.TokenId Raft *raft.Config Network *network.Options Db boltz.Db Trace struct { Handler *channel.TraceHandler } Profile struct { Memory struct { Path string Interval time.Duration } CPU struct { Path string } } Ctrl struct { Listener transport.Address Options *CtrlOptions } HealthChecks struct { BoltCheck struct { Interval time.Duration Timeout time.Duration InitialDelay time.Duration } } // contains filtered or unexported fields }
func LoadConfig ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(cfg *Config, versionProvider versions.VersionProvider) (*Controller, error)
func (*Controller) GetCloseNotify ¶ added in v0.18.0
func (c *Controller) GetCloseNotify() <-chan struct{}
func (*Controller) GetCloseNotifyChannel ¶ added in v0.16.9
func (c *Controller) GetCloseNotifyChannel() <-chan struct{}
func (*Controller) GetCommandDispatcher ¶ added in v0.18.0
func (c *Controller) GetCommandDispatcher() command.Dispatcher
func (*Controller) GetDb ¶ added in v0.18.0
func (c *Controller) GetDb() boltz.Db
func (*Controller) GetEventDispatcher ¶ added in v0.19.28
func (c *Controller) GetEventDispatcher() event.Dispatcher
func (*Controller) GetId ¶ added in v0.18.0
func (c *Controller) GetId() *identity.TokenId
func (*Controller) GetMetricsRegistry ¶ added in v0.18.0
func (c *Controller) GetMetricsRegistry() metrics.Registry
func (*Controller) GetNetwork ¶
func (c *Controller) GetNetwork() *network.Network
func (*Controller) GetOptions ¶ added in v0.18.0
func (c *Controller) GetOptions() *network.Options
func (*Controller) GetPeerSigners ¶ added in v0.23.49
func (c *Controller) GetPeerSigners() []*x509.Certificate
func (*Controller) GetRaftConfig ¶ added in v0.22.32
func (c *Controller) GetRaftConfig() *raft.Config
func (*Controller) GetVersionProvider ¶ added in v0.18.0
func (c *Controller) GetVersionProvider() versions.VersionProvider
func (*Controller) GetXWebInstance ¶ added in v0.18.1
func (c *Controller) GetXWebInstance() xweb.Instance
func (*Controller) HandleCustomAgentAsyncOp ¶ added in v0.18.0
func (self *Controller) HandleCustomAgentAsyncOp(conn net.Conn) error
func (*Controller) Identity ¶ added in v0.16.120
func (c *Controller) Identity() identity.Identity
func (*Controller) InitializeRaftFromBoltDb ¶ added in v0.22.4
func (c *Controller) InitializeRaftFromBoltDb(sourceDbPath string) error
func (*Controller) IsRaftEnabled ¶ added in v0.19.48
func (c *Controller) IsRaftEnabled() bool
func (*Controller) RegisterAgentBindHandler ¶ added in v0.18.0
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 ¶ added in v0.22.29
func (c *Controller) RenderJsonConfig() (string, error)
func (*Controller) Run ¶
func (c *Controller) Run() error
func (*Controller) Shutdown ¶
func (c *Controller) Shutdown()
func (*Controller) TryInitializeRaftFromBoltDb ¶ added in v0.22.4
func (c *Controller) TryInitializeRaftFromBoltDb() error
type CtrlOptions ¶ added in v0.17.26
type CtrlOptions struct { *channel.Options NewListener *transport.Address AdvertiseAddress *transport.Address RouterHeartbeatOptions *channel.HeartbeatOptions PeerHeartbeatOptions *channel.HeartbeatOptions }
CtrlOptions extends channel.Options to include support for additional, non-channel specific options (e.g. NewListener)
type OnConnectCtrlAddressesUpdateHandler ¶ added in v0.22.15
type OnConnectCtrlAddressesUpdateHandler struct {
// contains filtered or unexported fields
}
func NewOnConnectCtrlAddressesUpdateHandler ¶ added in v0.22.15
func NewOnConnectCtrlAddressesUpdateHandler(ctrlAddress string, raft *raft.Controller) *OnConnectCtrlAddressesUpdateHandler
func (OnConnectCtrlAddressesUpdateHandler) RouterConnected ¶ added in v0.22.15
func (o OnConnectCtrlAddressesUpdateHandler) RouterConnected(r *network.Router)
func (*OnConnectCtrlAddressesUpdateHandler) RouterDisconnected ¶ added in v0.22.15
func (o *OnConnectCtrlAddressesUpdateHandler) RouterDisconnected(r *network.Router)
type OnConnectSettingsHandler ¶ added in v0.17.26
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 ¶ added in v0.17.26
func (o OnConnectSettingsHandler) RouterConnected(r *network.Router)
func (*OnConnectSettingsHandler) RouterDisconnected ¶ added in v0.17.26
func (o *OnConnectSettingsHandler) RouterDisconnected(r *network.Router)
Directories
¶
Path | Synopsis |
---|---|
Package ioc provides a simple generics based registry which allows registering instance providers for a name and then instantiating instances, returning instances of the requested type.
|
Package ioc provides a simple generics based registry which allows registering instance providers for a name and then instantiating instances, returning instances of the requested type. |
Package rest_server Ziti Fabric
|
Package rest_server Ziti Fabric |
Package rest_util provides helper functions to generate a client for the Ziti Fabric REST APIs.
|
Package rest_util provides helper functions to generate a client for the Ziti Fabric REST APIs. |
Click to show internal directories.
Click to hide internal directories.