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 NewExtendEnrollmentHandler(appEnv *env.AppEnv) *extendEnrollmentHandler
- func NewExtendEnrollmentVerifyHandler(appEnv *env.AppEnv) *extendEnrollmentVerifyHandler
- func NewHealthEventHandler(appEnv *env.AppEnv, ch channel2.Channel) 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 NewTunnelHealthEventHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
- 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 HealthEventRequestContext
- type InvalidApiSessionError
- type InvalidEdgeRouterForSessionError
- type InvalidServiceError
- type InvalidSessionError
- type RemoveTerminatorRequestContext
- type RemoveTunnelTerminatorRequestContext
- type TunnelHealthEventRequestContext
- type TunnelState
- type TunnelingNotEnabledError
- type UpdateTerminatorRequest
- type UpdateTerminatorRequestContext
- type UpdateTunnelTerminatorRequestContext
- type WrongSessionTypeError
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 NewExtendEnrollmentHandler ¶ added in v0.21.20
func NewExtendEnrollmentVerifyHandler ¶ added in v0.21.20
func NewHealthEventHandler ¶ added in v0.19.54
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 NewTunnelHealthEventHandler ¶ added in v0.19.54
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) CleanupOnError ¶ added in v0.20.24
func (self *CreateCircuitRequestContext) CleanupOnError()
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) CleanupOnError ¶ added in v0.20.24
func (self *CreateTerminatorRequestContext) CleanupOnError()
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 HealthEventRequestContext ¶ added in v0.19.54
type HealthEventRequestContext struct {
// contains filtered or unexported fields
}
func (*HealthEventRequestContext) CleanupOnError ¶ added in v0.20.24
func (self *HealthEventRequestContext) CleanupOnError()
func (*HealthEventRequestContext) GetHandler ¶ added in v0.19.54
func (self *HealthEventRequestContext) GetHandler() requestHandler
func (*HealthEventRequestContext) GetMessage ¶ added in v0.19.54
func (*HealthEventRequestContext) GetSessionToken ¶ added in v0.19.54
func (self *HealthEventRequestContext) GetSessionToken() string
type InvalidApiSessionError ¶ added in v0.19.86
type InvalidApiSessionError struct{}
func (InvalidApiSessionError) Error ¶ added in v0.19.86
func (InvalidApiSessionError) Error() string
func (InvalidApiSessionError) ErrorCode ¶ added in v0.19.86
func (self InvalidApiSessionError) ErrorCode() uint32
type InvalidEdgeRouterForSessionError ¶ added in v0.19.86
type InvalidEdgeRouterForSessionError struct{}
func (InvalidEdgeRouterForSessionError) Error ¶ added in v0.19.86
func (InvalidEdgeRouterForSessionError) Error() string
func (InvalidEdgeRouterForSessionError) ErrorCode ¶ added in v0.19.86
func (self InvalidEdgeRouterForSessionError) ErrorCode() uint32
type InvalidServiceError ¶ added in v0.19.86
type InvalidServiceError struct{}
func (InvalidServiceError) Error ¶ added in v0.19.86
func (InvalidServiceError) Error() string
func (InvalidServiceError) ErrorCode ¶ added in v0.19.86
func (self InvalidServiceError) ErrorCode() uint32
type InvalidSessionError ¶ added in v0.19.86
type InvalidSessionError struct{}
func (InvalidSessionError) Error ¶ added in v0.19.86
func (InvalidSessionError) Error() string
func (InvalidSessionError) ErrorCode ¶ added in v0.19.86
func (self InvalidSessionError) ErrorCode() uint32
type RemoveTerminatorRequestContext ¶ added in v0.19.0
type RemoveTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*RemoveTerminatorRequestContext) CleanupOnError ¶ added in v0.20.24
func (self *RemoveTerminatorRequestContext) CleanupOnError()
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) CleanupOnError ¶ added in v0.20.24
func (self *RemoveTunnelTerminatorRequestContext) CleanupOnError()
func (*RemoveTunnelTerminatorRequestContext) GetHandler ¶ added in v0.19.43
func (self *RemoveTunnelTerminatorRequestContext) GetHandler() requestHandler
func (*RemoveTunnelTerminatorRequestContext) GetMessage ¶ added in v0.19.43
type TunnelHealthEventRequestContext ¶ added in v0.19.54
type TunnelHealthEventRequestContext struct {
// contains filtered or unexported fields
}
func (*TunnelHealthEventRequestContext) CleanupOnError ¶ added in v0.20.24
func (self *TunnelHealthEventRequestContext) CleanupOnError()
func (*TunnelHealthEventRequestContext) GetHandler ¶ added in v0.19.54
func (self *TunnelHealthEventRequestContext) GetHandler() requestHandler
func (*TunnelHealthEventRequestContext) GetMessage ¶ added in v0.19.54
type TunnelState ¶ added in v0.19.43
type TunnelState struct {
// contains filtered or unexported fields
}
type TunnelingNotEnabledError ¶ added in v0.19.86
type TunnelingNotEnabledError struct{}
func (TunnelingNotEnabledError) Error ¶ added in v0.19.86
func (TunnelingNotEnabledError) Error() string
func (TunnelingNotEnabledError) ErrorCode ¶ added in v0.19.86
func (self TunnelingNotEnabledError) ErrorCode() uint32
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) CleanupOnError ¶ added in v0.20.24
func (self *UpdateTerminatorRequestContext) CleanupOnError()
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) CleanupOnError ¶ added in v0.20.24
func (self *UpdateTunnelTerminatorRequestContext) CleanupOnError()
func (*UpdateTunnelTerminatorRequestContext) GetHandler ¶ added in v0.19.43
func (self *UpdateTunnelTerminatorRequestContext) GetHandler() requestHandler
func (*UpdateTunnelTerminatorRequestContext) GetMessage ¶ added in v0.19.43
type WrongSessionTypeError ¶ added in v0.19.86
type WrongSessionTypeError struct{}
func (WrongSessionTypeError) Error ¶ added in v0.19.86
func (WrongSessionTypeError) Error() string
func (WrongSessionTypeError) ErrorCode ¶ added in v0.19.86
func (self WrongSessionTypeError) ErrorCode() uint32
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
- errors.go
- extend_enrollment.go
- extend_enrollment_verify.go
- health_event.go
- heartbeat.go
- hello.go
- list_tunnel_services.go
- remove_terminator.go
- remove_tunnel_terminator.go
- resync.go
- tunnel_health_event.go
- update_terminator.go
- update_tunnel_terminator.go
- validate_sessions.go
Click to show internal directories.
Click to hide internal directories.