handler_mgmt

Documentation

Index

• func NewCircuit(circuit *network.Circuit) *mgmt_pb.Circuit
• type BindHandler
  • func NewBindHandler(network *network.Network, xmgmts []xmgmt.Xmgmt) *BindHandler
  • func (bindHandler *BindHandler) BindChannel(ch channel2.Channel) error
• type ConnectHandler
  • func NewConnectHandler(network *network.Network) *ConnectHandler
  • func (h *ConnectHandler) HandleConnection(hello *channel2.Hello, certificates []*x509.Certificate) error
• type MetricsStreamHandler
  • func (handler *MetricsStreamHandler) AcceptMetrics(msg *metrics_pb.MetricsMessage)
• type MgmtAccepter
  • func NewMgmtAccepter(listener channel2.UnderlayListener, options *channel2.Options) *MgmtAccepter
  • func (mgmtAccepter *MgmtAccepter) Run()
• type SessionsStreamHandler
  • func (handler *SessionsStreamHandler) CircuitUpdated(sessionId *identity.TokenId, circuit *network.Circuit)
  • func (handler *SessionsStreamHandler) SessionCreated(sessionId *identity.TokenId, clientId *identity.TokenId, serviceId string, ...)
  • func (handler *SessionsStreamHandler) SessionDeleted(sessionId *identity.TokenId, clientId *identity.TokenId)

Functions

func NewCircuit

func NewCircuit(circuit *network.Circuit) *mgmt_pb.Circuit

Types

type BindHandler

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

func NewBindHandler

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

func (*BindHandler) BindChannel

func (bindHandler *BindHandler) BindChannel(ch channel2.Channel) error

type ConnectHandler

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

func NewConnectHandler

func NewConnectHandler(network *network.Network) *ConnectHandler

func (*ConnectHandler) HandleConnection

func (h *ConnectHandler) HandleConnection(hello *channel2.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(listener channel2.UnderlayListener,
	options *channel2.Options) *MgmtAccepter

func (*MgmtAccepter) Run

func (mgmtAccepter *MgmtAccepter) Run()

type SessionsStreamHandler

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

func (*SessionsStreamHandler) CircuitUpdated

func (handler *SessionsStreamHandler) CircuitUpdated(sessionId *identity.TokenId, circuit *network.Circuit)

func (*SessionsStreamHandler) SessionCreated

func (handler *SessionsStreamHandler) SessionCreated(sessionId *identity.TokenId, clientId *identity.TokenId, serviceId string, circuit *network.Circuit)

func (*SessionsStreamHandler) SessionDeleted

func (handler *SessionsStreamHandler) SessionDeleted(sessionId *identity.TokenId, clientId *identity.TokenId)