handler_edge_ctrl

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2024 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

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 NewCreateCircuitHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

func NewCreateCircuitV2Handler added in v0.32.2

func NewCreateCircuitV2Handler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

func NewCreateTerminatorHandler

func NewCreateTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

func NewCreateTerminatorV2Handler

func NewCreateTerminatorV2Handler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

func NewCreateTunnelTerminatorHandler

func NewCreateTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler

func NewExtendEnrollmentHandler

func NewExtendEnrollmentHandler(appEnv *env.AppEnv) *extendEnrollmentHandler

func NewExtendEnrollmentVerifyHandler

func NewExtendEnrollmentVerifyHandler(appEnv *env.AppEnv) *extendEnrollmentVerifyHandler

func NewHealthEventHandler

func NewHealthEventHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

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 NewRemoveTerminatorHandler

func NewRemoveTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

func NewRemoveTunnelTerminatorHandler

func NewRemoveTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

func NewResyncHandler

func NewResyncHandler(appEnv *env.AppEnv, callback func(routerId string, respHello *edge_ctrl_pb.RequestClientReSync)) *resyncHandler

func NewSessionHeartbeatHandler

func NewSessionHeartbeatHandler(appEnv *env.AppEnv) *sessionHeartbeatHandler

func NewTunnelHealthEventHandler

func NewTunnelHealthEventHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

func NewUpdateTerminatorHandler

func NewUpdateTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

func NewUpdateTunnelTerminatorHandler

func NewUpdateTunnelTerminatorHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

func NewValidateSessionsHandler

func NewValidateSessionsHandler(appEnv *env.AppEnv, ch channel.Channel) channel.TypedReceiveHandler

Types

type CreateCircuitForServiceRequestContext

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

type CreateCircuitRequest added in v0.32.2

type CreateCircuitRequest interface {
	GetSessionToken() string
	GetApiSessionToken() string
	GetFingerprints() []string
	GetTerminatorInstanceId() string
	GetPeerData() map[uint32][]byte
}

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) ErrorCode

func (self InvalidApiSessionError) ErrorCode() uint32

type InvalidEdgeRouterForSessionError

type InvalidEdgeRouterForSessionError struct{}

func (InvalidEdgeRouterForSessionError) Error

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) 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

Jump to

Keyboard shortcuts

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