Documentation ¶
Index ¶
- func NewPath(path *network.Path) *mgmt_pb.Path
- type BindHandler
- type CircuitsStreamHandler
- func (handler *CircuitsStreamHandler) CircuitCreated(circuitId string, clientId string, serviceId string, path *network.Path)
- func (handler *CircuitsStreamHandler) CircuitDeleted(circuitId string, clientId string)
- func (handler *CircuitsStreamHandler) PathUpdated(circuitId string, path *network.Path)
- type ConnectHandler
- type MetricsStreamHandler
- type MgmtAccepter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 CircuitsStreamHandler ¶ added in v0.16.92
type CircuitsStreamHandler struct {
// contains filtered or unexported fields
}
func (*CircuitsStreamHandler) CircuitCreated ¶ added in v0.16.92
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 *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()
Source Files ¶
- accept.go
- bind.go
- close.go
- connect.go
- create_router.go
- create_service.go
- create_terminator.go
- get_service.go
- get_terminator.go
- inspect.go
- list_circuits.go
- list_links.go
- list_routers.go
- list_services.go
- list_terminators.go
- remove_circuit.go
- remove_router.go
- remove_service.go
- remove_terminator.go
- set_link_cost.go
- set_link_down.go
- set_terminator_cost.go
- snapshot_db.go
- stream_circuits.go
- stream_metrics.go
- stream_toggle_pipe_traces.go
- stream_traces.go
Click to show internal directories.
Click to hide internal directories.