handler_edge_ctrl

package
v0.32.2 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2024 License: Apache-2.0 Imports: 37 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, 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
	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) 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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.