Documentation ¶
Index ¶
- func NewCreateApiSessionHandler(appEnv *env.AppEnv, ch channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler
- func NewCreateCircuitForTunnelHandler(appEnv *env.AppEnv, ch channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler
- func NewCreateCircuitHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewCreateCircuitV2Handler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewCreateTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewCreateTerminatorV2Handler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewCreateTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler
- func NewExtendEnrollmentHandler(appEnv *env.AppEnv) *extendEnrollmentHandler
- func NewExtendEnrollmentVerifyHandler(appEnv *env.AppEnv) *extendEnrollmentVerifyHandler
- func NewHealthEventHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewHelloHandler(appEnv *env.AppEnv, ...) *helloHandler
- func NewListTunnelServicesHandler(appEnv *env.AppEnv, ch channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler
- func NewRemoveTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewRemoveTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewResyncHandler(appEnv *env.AppEnv, ...) *resyncHandler
- func NewSessionHeartbeatHandler(appEnv *env.AppEnv) *sessionHeartbeatHandler
- func NewTunnelHealthEventHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewUpdateTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewUpdateTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- func NewValidateSessionsHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler
- type CreateCircuitForServiceRequestContext
- type CreateCircuitRequest
- type CreateCircuitRequestContext
- type CreateTerminatorRequestContext
- type CreateTerminatorV2RequestContext
- 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 ¶
func NewCreateApiSessionHandler(appEnv *env.AppEnv, ch channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler
func NewCreateCircuitForTunnelHandler ¶
func NewCreateCircuitForTunnelHandler(appEnv *env.AppEnv, ch channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler
func NewCreateCircuitHandler ¶
func NewCreateCircuitV2Handler ¶ added in v0.32.2
func NewCreateTunnelTerminatorHandler ¶
func NewCreateTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler
func NewHealthEventHandler ¶
func NewHelloHandler ¶
func NewHelloHandler(appEnv *env.AppEnv, callback func(routerId string, msg *channel.Message, respHello *edge_ctrl_pb.ClientHello)) *helloHandler
func NewListTunnelServicesHandler ¶
func NewListTunnelServicesHandler(appEnv *env.AppEnv, ch channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler
func NewResyncHandler ¶
func NewResyncHandler(appEnv *env.AppEnv, callback func(routerId string, respHello *edge_ctrl_pb.RequestClientReSync)) *resyncHandler
Types ¶
type CreateCircuitForServiceRequestContext ¶
type CreateCircuitForServiceRequestContext struct {
// contains filtered or unexported fields
}
type CreateCircuitRequest ¶ added in v0.32.2
type CreateCircuitRequestContext ¶
type CreateCircuitRequestContext struct {
// contains filtered or unexported fields
}
func (*CreateCircuitRequestContext) GetHandler ¶
func (self *CreateCircuitRequestContext) GetHandler() requestHandler
func (*CreateCircuitRequestContext) GetMessage ¶
func (self *CreateCircuitRequestContext) GetMessage() *channel.Message
func (*CreateCircuitRequestContext) GetSessionToken ¶
func (self *CreateCircuitRequestContext) GetSessionToken() string
type CreateTerminatorRequestContext ¶
type CreateTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*CreateTerminatorRequestContext) GetHandler ¶
func (self *CreateTerminatorRequestContext) GetHandler() requestHandler
func (*CreateTerminatorRequestContext) GetMessage ¶
func (self *CreateTerminatorRequestContext) GetMessage() *channel.Message
func (*CreateTerminatorRequestContext) GetSessionToken ¶
func (self *CreateTerminatorRequestContext) GetSessionToken() string
type CreateTerminatorV2RequestContext ¶
type CreateTerminatorV2RequestContext struct {
// contains filtered or unexported fields
}
func (*CreateTerminatorV2RequestContext) GetHandler ¶
func (self *CreateTerminatorV2RequestContext) GetHandler() requestHandler
func (*CreateTerminatorV2RequestContext) GetMessage ¶
func (self *CreateTerminatorV2RequestContext) GetMessage() *channel.Message
func (*CreateTerminatorV2RequestContext) GetSessionToken ¶
func (self *CreateTerminatorV2RequestContext) GetSessionToken() string
type CreateTunnelTerminatorRequestContext ¶
type CreateTunnelTerminatorRequestContext struct {
// contains filtered or unexported fields
}
type HealthEventRequestContext ¶
type HealthEventRequestContext struct {
// contains filtered or unexported fields
}
func (*HealthEventRequestContext) GetHandler ¶
func (self *HealthEventRequestContext) GetHandler() requestHandler
func (*HealthEventRequestContext) GetMessage ¶
func (self *HealthEventRequestContext) GetMessage() *channel.Message
func (*HealthEventRequestContext) GetSessionToken ¶
func (self *HealthEventRequestContext) GetSessionToken() string
type InvalidApiSessionError ¶
type InvalidApiSessionError struct{}
func (InvalidApiSessionError) Error ¶
func (InvalidApiSessionError) Error() string
func (InvalidApiSessionError) ErrorCode ¶
func (self InvalidApiSessionError) ErrorCode() uint32
type InvalidEdgeRouterForSessionError ¶
type InvalidEdgeRouterForSessionError struct{}
func (InvalidEdgeRouterForSessionError) Error ¶
func (InvalidEdgeRouterForSessionError) Error() string
func (InvalidEdgeRouterForSessionError) ErrorCode ¶
func (self InvalidEdgeRouterForSessionError) ErrorCode() uint32
type InvalidServiceError ¶
type InvalidServiceError struct{}
func (InvalidServiceError) Error ¶
func (InvalidServiceError) Error() string
func (InvalidServiceError) ErrorCode ¶
func (self InvalidServiceError) ErrorCode() uint32
type InvalidSessionError ¶
type InvalidSessionError struct{}
func (InvalidSessionError) Error ¶
func (InvalidSessionError) Error() string
func (InvalidSessionError) ErrorCode ¶
func (self InvalidSessionError) ErrorCode() uint32
type RemoveTerminatorRequestContext ¶
type RemoveTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*RemoveTerminatorRequestContext) GetHandler ¶
func (self *RemoveTerminatorRequestContext) GetHandler() requestHandler
func (*RemoveTerminatorRequestContext) GetMessage ¶
func (self *RemoveTerminatorRequestContext) GetMessage() *channel.Message
func (*RemoveTerminatorRequestContext) GetSessionToken ¶
func (self *RemoveTerminatorRequestContext) GetSessionToken() string
type RemoveTunnelTerminatorRequestContext ¶
type RemoveTunnelTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*RemoveTunnelTerminatorRequestContext) GetHandler ¶
func (self *RemoveTunnelTerminatorRequestContext) GetHandler() requestHandler
func (*RemoveTunnelTerminatorRequestContext) GetMessage ¶
func (self *RemoveTunnelTerminatorRequestContext) GetMessage() *channel.Message
type TunnelHealthEventRequestContext ¶
type TunnelHealthEventRequestContext struct {
// contains filtered or unexported fields
}
func (*TunnelHealthEventRequestContext) GetHandler ¶
func (self *TunnelHealthEventRequestContext) GetHandler() requestHandler
func (*TunnelHealthEventRequestContext) GetMessage ¶
func (self *TunnelHealthEventRequestContext) GetMessage() *channel.Message
type TunnelState ¶
type TunnelState struct {
// contains filtered or unexported fields
}
func NewTunnelState ¶
func NewTunnelState() *TunnelState
type TunnelingNotEnabledError ¶
type TunnelingNotEnabledError struct{}
func (TunnelingNotEnabledError) Error ¶
func (TunnelingNotEnabledError) Error() string
func (TunnelingNotEnabledError) ErrorCode ¶
func (self TunnelingNotEnabledError) ErrorCode() uint32
type UpdateTerminatorRequest ¶
type UpdateTerminatorRequest interface { GetCost() uint32 GetUpdateCost() bool GetPrecedence() edge_ctrl_pb.TerminatorPrecedence GetUpdatePrecedence() bool }
type UpdateTerminatorRequestContext ¶
type UpdateTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*UpdateTerminatorRequestContext) GetHandler ¶
func (self *UpdateTerminatorRequestContext) GetHandler() requestHandler
func (*UpdateTerminatorRequestContext) GetMessage ¶
func (self *UpdateTerminatorRequestContext) GetMessage() *channel.Message
func (*UpdateTerminatorRequestContext) GetSessionToken ¶
func (self *UpdateTerminatorRequestContext) GetSessionToken() string
type UpdateTunnelTerminatorRequestContext ¶
type UpdateTunnelTerminatorRequestContext struct {
// contains filtered or unexported fields
}
func (*UpdateTunnelTerminatorRequestContext) GetHandler ¶
func (self *UpdateTunnelTerminatorRequestContext) GetHandler() requestHandler
func (*UpdateTunnelTerminatorRequestContext) GetMessage ¶
func (self *UpdateTunnelTerminatorRequestContext) GetMessage() *channel.Message
type WrongSessionTypeError ¶
type WrongSessionTypeError struct{}
func (WrongSessionTypeError) Error ¶
func (WrongSessionTypeError) Error() string
func (WrongSessionTypeError) ErrorCode ¶
func (self WrongSessionTypeError) ErrorCode() uint32
Source Files ¶
- common.go
- common_tunnel.go
- create_circuit.go
- create_terminator.go
- create_terminator_v2.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.