Documentation ¶
Index ¶
- func NewCreateApiSessionHandler(appEnv *env.AppEnv, ch channel2.Channel, tunnelState *TunnelState) channel2.ReceiveHandler
- func NewCreateCircuitForTunnelHandler(appEnv *env.AppEnv, ch channel2.Channel, tunnelState *TunnelState) channel2.ReceiveHandler
- func NewCreateCircuitHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
- func NewCreateTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
- func NewCreateTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel, tunnelState *TunnelState) channel2.ReceiveHandler
- func NewHelloHandler(appEnv *env.AppEnv, ...) *helloHandler
- func NewListTunnelServicesHandler(appEnv *env.AppEnv, ch channel2.Channel, tunnelState *TunnelState) channel2.ReceiveHandler
- func NewRemoveTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
- func NewRemoveTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
- func NewResyncHandler(appEnv *env.AppEnv, ...) *resyncHandler
- func NewSessionHeartbeatHandler(appEnv *env.AppEnv) *sessionHeartbeatHandler
- func NewUpdateTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
- func NewUpdateTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
- func NewValidateSessionsHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
- type CreateCircuitForServiceRequestContext
- type CreateCircuitRequestContext
- type CreateTerminatorRequestContext
- type CreateTunnelTerminatorRequestContext
- type RemoveTerminatorRequestContext
- type RemoveTunnelTerminatorRequestContext
- type TunnelState
- type UpdateTerminatorRequest
- type UpdateTerminatorRequestContext
- type UpdateTunnelTerminatorRequestContext
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCreateApiSessionHandler ¶ added in v0.19.43
func NewCreateApiSessionHandler(appEnv *env.AppEnv, ch channel2.Channel, tunnelState *TunnelState) channel2.ReceiveHandler
func NewCreateCircuitForTunnelHandler ¶ added in v0.19.43
func NewCreateCircuitForTunnelHandler(appEnv *env.AppEnv, ch channel2.Channel, tunnelState *TunnelState) channel2.ReceiveHandler
func NewCreateCircuitHandler ¶ added in v0.19.0
func NewCreateTerminatorHandler ¶ added in v0.19.0
func NewCreateTunnelTerminatorHandler ¶ added in v0.19.43
func NewCreateTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel, tunnelState *TunnelState) channel2.ReceiveHandler
func NewHelloHandler ¶ added in v0.15.20
func NewHelloHandler(appEnv *env.AppEnv, callback func(r *network.Router, respHello *edge_ctrl_pb.ClientHello)) *helloHandler
func NewListTunnelServicesHandler ¶ added in v0.19.43
func NewListTunnelServicesHandler(appEnv *env.AppEnv, ch channel2.Channel, tunnelState *TunnelState) channel2.ReceiveHandler
func NewRemoveTerminatorHandler ¶ added in v0.19.0
func NewRemoveTunnelTerminatorHandler ¶ added in v0.19.43
func NewResyncHandler ¶ added in v0.17.72
func NewResyncHandler(appEnv *env.AppEnv, callback func(r *network.Router, respHello *edge_ctrl_pb.RequestClientReSync)) *resyncHandler
func NewUpdateTerminatorHandler ¶ added in v0.19.0
func NewUpdateTunnelTerminatorHandler ¶ added in v0.19.43
func NewValidateSessionsHandler ¶ added in v0.19.0
Types ¶
type CreateCircuitForServiceRequestContext ¶ added in v0.19.43
type CreateCircuitForServiceRequestContext struct {
// contains filtered or unexported fields
}
type CreateCircuitRequestContext ¶ added in v0.19.0
type CreateCircuitRequestContext struct {
// contains filtered or unexported fields
}
func (*CreateCircuitRequestContext) GetHandler ¶ added in v0.19.0
func (self *CreateCircuitRequestContext) GetHandler() requestHandler
func (*CreateCircuitRequestContext) GetMessage ¶ added in v0.19.0
func (*CreateCircuitRequestContext) GetSessionToken ¶ added in v0.19.0
func (self *CreateCircuitRequestContext) GetSessionToken() string
type CreateTerminatorRequestContext ¶ added in v0.19.0
type CreateTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*CreateTerminatorRequestContext) GetHandler ¶ added in v0.19.0
func (self *CreateTerminatorRequestContext) GetHandler() requestHandler
func (*CreateTerminatorRequestContext) GetMessage ¶ added in v0.19.0
func (*CreateTerminatorRequestContext) GetSessionToken ¶ added in v0.19.0
func (self *CreateTerminatorRequestContext) GetSessionToken() string
type CreateTunnelTerminatorRequestContext ¶ added in v0.19.43
type CreateTunnelTerminatorRequestContext struct {
// contains filtered or unexported fields
}
type RemoveTerminatorRequestContext ¶ added in v0.19.0
type RemoveTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*RemoveTerminatorRequestContext) GetHandler ¶ added in v0.19.0
func (self *RemoveTerminatorRequestContext) GetHandler() requestHandler
func (*RemoveTerminatorRequestContext) GetMessage ¶ added in v0.19.0
func (*RemoveTerminatorRequestContext) GetSessionToken ¶ added in v0.19.0
func (self *RemoveTerminatorRequestContext) GetSessionToken() string
type RemoveTunnelTerminatorRequestContext ¶ added in v0.19.43
type RemoveTunnelTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*RemoveTunnelTerminatorRequestContext) GetHandler ¶ added in v0.19.43
func (self *RemoveTunnelTerminatorRequestContext) GetHandler() requestHandler
func (*RemoveTunnelTerminatorRequestContext) GetMessage ¶ added in v0.19.43
type TunnelState ¶ added in v0.19.43
type TunnelState struct {
// contains filtered or unexported fields
}
type UpdateTerminatorRequest ¶ added in v0.19.43
type UpdateTerminatorRequest interface { GetCost() uint32 GetUpdateCost() bool GetPrecedence() edge_ctrl_pb.TerminatorPrecedence GetUpdatePrecedence() bool }
type UpdateTerminatorRequestContext ¶ added in v0.19.0
type UpdateTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*UpdateTerminatorRequestContext) GetHandler ¶ added in v0.19.0
func (self *UpdateTerminatorRequestContext) GetHandler() requestHandler
func (*UpdateTerminatorRequestContext) GetMessage ¶ added in v0.19.0
func (*UpdateTerminatorRequestContext) GetSessionToken ¶ added in v0.19.0
func (self *UpdateTerminatorRequestContext) GetSessionToken() string
type UpdateTunnelTerminatorRequestContext ¶ added in v0.19.43
type UpdateTunnelTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*UpdateTunnelTerminatorRequestContext) GetHandler ¶ added in v0.19.43
func (self *UpdateTunnelTerminatorRequestContext) GetHandler() requestHandler
func (*UpdateTunnelTerminatorRequestContext) GetMessage ¶ added in v0.19.43
Source Files ¶
- common.go
- common_tunnel.go
- create_circuit.go
- create_terminator.go
- create_tunnel_api_session.go
- create_tunnel_circuit.go
- create_tunnel_terminator.go
- heartbeat.go
- hello.go
- list_tunnel_services.go
- remove_terminator.go
- remove_tunnel_terminator.go
- resync.go
- update_terminator.go
- update_tunnel_terminator.go
- validate_sessions.go
Click to show internal directories.
Click to hide internal directories.