handler_edge_ctrl

package
v2.0.0-pre9 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2026 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewConnectEventsHandler 

func NewConnectEventsHandler(appEnv *env.AppEnv, ch ctrlchan.CtrlChannel) channel.TypedReceiveHandler

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 

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

func NewCreateCircuitV3Handler 

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

NewCreateCircuitV3Handler creates a handler for CreateCircuitV3 requests. These requests come from routers that have already authorized the dial locally via RDM, so no service session token is required. Instead, the request carries identity ID, service ID, and a pre-assigned circuit ID.

func NewCreateTerminatorV2Handler 

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

func NewCreateTunnelCircuitV2Handler 

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

func NewCreateTunnelTerminatorHandler 

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

func NewCreateTunnelTerminatorV2Handler 

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

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 NewSubscribeToDataModelHandler 

func NewSubscribeToDataModelHandler(appEnv *env.AppEnv, callback func(routerId string, respHello *edge_ctrl_pb.SubscribeToDataModelRequest)) *subscribeToDataModelHandler

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 

type CreateCircuitRequest interface {
	GetSessionToken() string
	GetApiSessionToken() 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

func (*CreateCircuitRequestContext) UpdateResponse 

func (self *CreateCircuitRequestContext) UpdateResponse(m *channel.Message)

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 CreateTunnelCircuitV2RequestContext 

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

type CreateTunnelTerminatorRequestContext 

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

type ExtendEnrollmentHandler 

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

func NewExtendEnrollmentHandler 

func NewExtendEnrollmentHandler(appEnv *env.AppEnv) *ExtendEnrollmentHandler

func (*ExtendEnrollmentHandler) ContentType 

func (h *ExtendEnrollmentHandler) ContentType() int32

func (*ExtendEnrollmentHandler) HandleReceive 

func (h *ExtendEnrollmentHandler) HandleReceive(msg *channel.Message, ch channel.Channel)

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

func (InvalidApiSessionError) GetRetryHint 

func (InvalidApiSessionError) GetRetryHint() edge.RetryHint

type InvalidEdgeRouterForSessionError 

type InvalidEdgeRouterForSessionError struct{}

func (InvalidEdgeRouterForSessionError) Error 

func (InvalidEdgeRouterForSessionError) Error() string

func (InvalidEdgeRouterForSessionError) ErrorCode 

func (self InvalidEdgeRouterForSessionError) ErrorCode() uint32

func (InvalidEdgeRouterForSessionError) GetRetryHint 

func (InvalidEdgeRouterForSessionError) GetRetryHint() edge.RetryHint

type InvalidServiceError 

type InvalidServiceError struct{}

func (InvalidServiceError) Error 

func (InvalidServiceError) Error() string

func (InvalidServiceError) ErrorCode 

func (self InvalidServiceError) ErrorCode() uint32

func (InvalidServiceError) GetRetryHint 

func (InvalidServiceError) GetRetryHint() edge.RetryHint

type InvalidSessionError 

type InvalidSessionError struct{}

func (InvalidSessionError) Error 

func (InvalidSessionError) Error() string

func (InvalidSessionError) ErrorCode 

func (self InvalidSessionError) ErrorCode() uint32

func (InvalidSessionError) GetRetryHint 

func (InvalidSessionError) GetRetryHint() edge.RetryHint

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

func (TunnelingNotEnabledError) GetRetryHint 

func (TunnelingNotEnabledError) GetRetryHint() edge.RetryHint

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

func (WrongSessionTypeError) GetRetryHint 

func (WrongSessionTypeError) GetRetryHint() edge.RetryHint

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.