handler_mgmt

package
v0.17.29 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 28, 2022 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBindHandler

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

func NewPath added in v0.16.92

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 added in v0.16.92

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

func (*CircuitsStreamHandler) CircuitCreated added in v0.16.92

func (handler *CircuitsStreamHandler) CircuitCreated(circuitId string, clientId string, serviceId string, path *network.Path)

func (*CircuitsStreamHandler) CircuitDeleted added in v0.16.92

func (handler *CircuitsStreamHandler) CircuitDeleted(circuitId string, clientId string)

func (*CircuitsStreamHandler) PathUpdated added in v0.16.92

func (handler *CircuitsStreamHandler) PathUpdated(circuitId string, path *network.Path)

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(listener channel.UnderlayListener,
	options *channel.Options) *MgmtAccepter

func (*MgmtAccepter) Run

func (mgmtAccepter *MgmtAccepter) Run()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL