Documentation
¶
Index ¶
- type ConnectHandler
- type CtrlAccepter
- func (self *CtrlAccepter) AcceptUnderlay(underlay channel.Underlay) error
- func (self *CtrlAccepter) Bind(binding channel.Binding) error
- func (self *CtrlAccepter) HandleGroupedUnderlay(underlay channel.Underlay, closeCallback func()) (channel.MultiChannel, error)
- func (self *CtrlAccepter) NewMultiListener() channel.UnderlayAcceptor
- type CtrlDialer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectHandler ¶
type ConnectHandler struct {
// contains filtered or unexported fields
}
func NewConnectHandler ¶
func NewConnectHandler(identity identity.Identity, network *network.Network) *ConnectHandler
func (*ConnectHandler) HandleConnection ¶
func (self *ConnectHandler) HandleConnection(hello *channel.Hello, certificates []*x509.Certificate) error
type CtrlAccepter ¶
type CtrlAccepter struct {
// contains filtered or unexported fields
}
func NewCtrlAccepter ¶
func NewCtrlAccepter(network *network.Network, xctrls []xctrl.Xctrl, options *channel.Options, heartbeatOptions *channel.HeartbeatOptions, traceHandler *channel.TraceHandler) *CtrlAccepter
func (*CtrlAccepter) AcceptUnderlay ¶
func (self *CtrlAccepter) AcceptUnderlay(underlay channel.Underlay) error
AcceptUnderlay handles incoming ungrouped connections from routers that don't support multi-underlay control channels (backward compatibility).
func (*CtrlAccepter) HandleGroupedUnderlay ¶
func (self *CtrlAccepter) HandleGroupedUnderlay(underlay channel.Underlay, closeCallback func()) (channel.MultiChannel, error)
HandleGroupedUnderlay handles incoming grouped connections from routers that support multi-underlay control channels. It creates a MultiChannel with ListenerCtrlChannel.
func (*CtrlAccepter) NewMultiListener ¶
func (self *CtrlAccepter) NewMultiListener() channel.UnderlayAcceptor
NewMultiListener returns an acceptor that handles both grouped (multi-underlay) and ungrouped (single underlay) connections from routers.
type CtrlDialer ¶
type CtrlDialer struct {
// contains filtered or unexported fields
}
func NewCtrlDialer ¶
func NewCtrlDialer( config *config.CtrlDialerConfig, network *network.Network, ctrlAccepter *CtrlAccepter, ctrlId *identity.TokenId, headers map[int32][]byte, closeNotify <-chan struct{}, ) *CtrlDialer
func (*CtrlDialer) RouterConnected ¶
func (self *CtrlDialer) RouterConnected(_ *model.Router)
func (*CtrlDialer) RouterDisconnected ¶
func (self *CtrlDialer) RouterDisconnected(r *model.Router)
func (*CtrlDialer) RouterUpdated ¶
func (self *CtrlDialer) RouterUpdated(id string)
func (*CtrlDialer) Run ¶
func (self *CtrlDialer) Run()
Source Files
¶
- accept.go
- alert.go
- base.go
- bind.go
- circuit_confirmation.go
- circuit_request.go
- close.go
- connect.go
- create_terminator.go
- decommission.go
- dequiesce_router.go
- dialer.go
- fault.go
- inspect.go
- link_state.go
- metrics.go
- ping.go
- quiesce_router.go
- remove_terminator.go
- remove_terminators.go
- route_result.go
- router_link.go
- send_cluster_members.go
- trace.go
- update_router_interfaces.go
- update_terminator.go
- verify_router.go
Click to show internal directories.
Click to hide internal directories.