handler_edge_ctrl

package
v0.24.83 Latest Latest
Warning

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

Go to latest
Published: Dec 19, 2022 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCreateApiSessionHandler added in v0.19.43

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

func NewCreateCircuitForTunnelHandler added in v0.19.43

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

func NewCreateCircuitHandler added in v0.19.0

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

func NewCreateTerminatorHandler added in v0.19.0

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

func NewCreateTunnelTerminatorHandler added in v0.19.43

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

func NewExtendEnrollmentHandler added in v0.21.20

func NewExtendEnrollmentHandler(appEnv *env.AppEnv) *extendEnrollmentHandler

func NewExtendEnrollmentVerifyHandler added in v0.21.20

func NewExtendEnrollmentVerifyHandler(appEnv *env.AppEnv) *extendEnrollmentVerifyHandler

func NewHealthEventHandler added in v0.19.54

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

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 channel.Channel, tunnelState *TunnelState) channel.TypedReceiveHandler

func NewRemoveTerminatorHandler added in v0.19.0

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

func NewRemoveTunnelTerminatorHandler added in v0.19.43

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

func NewResyncHandler added in v0.17.72

func NewResyncHandler(appEnv *env.AppEnv, callback func(r *network.Router, respHello *edge_ctrl_pb.RequestClientReSync)) *resyncHandler

func NewSessionHeartbeatHandler

func NewSessionHeartbeatHandler(appEnv *env.AppEnv) *sessionHeartbeatHandler

func NewTunnelHealthEventHandler added in v0.19.54

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

func NewUpdateTerminatorHandler added in v0.19.0

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

func NewUpdateTunnelTerminatorHandler added in v0.19.43

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

func NewValidateSessionsHandler added in v0.19.0

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

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 (self *CreateCircuitRequestContext) GetMessage() *channel.Message

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 (self *CreateTerminatorRequestContext) GetMessage() *channel.Message

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 (self *HealthEventRequestContext) GetMessage() *channel.Message

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) 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) 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 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 (self *RemoveTerminatorRequestContext) GetMessage() *channel.Message

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

func (self *RemoveTunnelTerminatorRequestContext) GetMessage() *channel.Message

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

func (self *TunnelHealthEventRequestContext) GetMessage() *channel.Message

type TunnelState added in v0.19.43

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

func NewTunnelState added in v0.21.41

func NewTunnelState() *TunnelState

type TunnelingNotEnabledError added in v0.19.86

type TunnelingNotEnabledError struct{}

func (TunnelingNotEnabledError) Error added in v0.19.86

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 (self *UpdateTerminatorRequestContext) GetMessage() *channel.Message

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

func (self *UpdateTunnelTerminatorRequestContext) GetMessage() *channel.Message

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

Jump to

Keyboard shortcuts

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