handler_mgmt

Documentation

Index

• func NewBindHandler(network *network.Network, xmgmts []xmgmt.Xmgmt) channel.BindHandler
• func NewPath(path *network.Path) *mgmt_pb.Path
• type BindHandler
  • func (bindHandler *BindHandler) BindChannel(binding channel.Binding) error
• type CircuitsStreamHandler
  • func (handler *CircuitsStreamHandler) AcceptCircuitEvent(netEvent *network.CircuitEvent)
• type ConnectHandler
  • func NewConnectHandler(identity identity.Identity, network *network.Network) *ConnectHandler
  • func (self *ConnectHandler) HandleConnection(hello *channel.Hello, certificates []*x509.Certificate) error
• type MetricsStreamHandler
  • func (handler *MetricsStreamHandler) AcceptMetrics(msg *metrics_pb.MetricsMessage)
• type MgmtAccepter
  • func NewMgmtAccepter(network *network.Network, xmgmts []xmgmt.Xmgmt, ...) *MgmtAccepter
  • func (self *MgmtAccepter) Run()

Functions

func NewBindHandler

func NewBindHandler(network *network.Network, xmgmts []xmgmt.Xmgmt) channel.BindHandler

func NewPath

func NewPath(path *network.Path) *mgmt_pb.Path

Types

type BindHandler

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

func (*BindHandler) BindChannel

func (bindHandler *BindHandler) BindChannel(binding channel.Binding) error

type CircuitsStreamHandler

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

func (*CircuitsStreamHandler) AcceptCircuitEvent

func (handler *CircuitsStreamHandler) AcceptCircuitEvent(netEvent *network.CircuitEvent)

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 MetricsStreamHandler

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

func (*MetricsStreamHandler) AcceptMetrics

func (handler *MetricsStreamHandler) AcceptMetrics(msg *metrics_pb.MetricsMessage)

type MgmtAccepter

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

func NewMgmtAccepter

func NewMgmtAccepter(network *network.Network,
	xmgmts []xmgmt.Xmgmt,
	listener channel.UnderlayListener,
	options *channel.Options) *MgmtAccepter

func (*MgmtAccepter) Run

func (self *MgmtAccepter) Run()