handler_edge_ctrl

Documentation

Index

• func NewCreateCircuitHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
• func NewCreateTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
• func NewHelloHandler(appEnv *env.AppEnv, ...) *helloHandler
• func NewRemoveTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
• func NewResyncHandler(appEnv *env.AppEnv, ...) *resyncHandler
• func NewSessionHeartbeatHandler(appEnv *env.AppEnv) *sessionHeartbeatHandler
• func NewUpdateTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
• func NewValidateSessionsHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler
• type CreateCircuitRequestContext
  • func (self *CreateCircuitRequestContext) GetHandler() requestHandler
  • func (self *CreateCircuitRequestContext) GetMessage() *channel2.Message
  • func (self *CreateCircuitRequestContext) GetSessionFields(ctx requestContext) logrus.Fields
  • func (self *CreateCircuitRequestContext) GetSessionToken() string
• type CreateTerminatorRequestContext
  • func (self *CreateTerminatorRequestContext) GetHandler() requestHandler
  • func (self *CreateTerminatorRequestContext) GetMessage() *channel2.Message
  • func (self *CreateTerminatorRequestContext) GetSessionFields(ctx requestContext) logrus.Fields
  • func (self *CreateTerminatorRequestContext) GetSessionToken() string
• type RemoveTerminatorRequestContext
  • func (self *RemoveTerminatorRequestContext) GetHandler() requestHandler
  • func (self *RemoveTerminatorRequestContext) GetMessage() *channel2.Message
  • func (self *RemoveTerminatorRequestContext) GetSessionFields(ctx requestContext) logrus.Fields
  • func (self *RemoveTerminatorRequestContext) GetSessionToken() string
• type UpdateTerminatorRequestContext
  • func (self *UpdateTerminatorRequestContext) GetHandler() requestHandler
  • func (self *UpdateTerminatorRequestContext) GetMessage() *channel2.Message
  • func (self *UpdateTerminatorRequestContext) GetSessionFields(ctx requestContext) logrus.Fields
  • func (self *UpdateTerminatorRequestContext) GetSessionToken() string

Functions

func NewCreateCircuitHandler

func NewCreateCircuitHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler

func NewCreateTerminatorHandler

func NewCreateTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler

func NewHelloHandler

func NewHelloHandler(appEnv *env.AppEnv, callback func(r *network.Router, respHello *edge_ctrl_pb.ClientHello)) *helloHandler

func NewRemoveTerminatorHandler

func NewRemoveTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler

func NewResyncHandler

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 NewUpdateTerminatorHandler

func NewUpdateTerminatorHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler

func NewValidateSessionsHandler

func NewValidateSessionsHandler(appEnv *env.AppEnv, ch channel2.Channel) channel2.ReceiveHandler

Types

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() *channel2.Message

func (*CreateCircuitRequestContext) GetSessionFields

func (self *CreateCircuitRequestContext) GetSessionFields(ctx requestContext) logrus.Fields

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() *channel2.Message

func (*CreateTerminatorRequestContext) GetSessionFields

func (self *CreateTerminatorRequestContext) GetSessionFields(ctx requestContext) logrus.Fields

func (*CreateTerminatorRequestContext) GetSessionToken

func (self *CreateTerminatorRequestContext) GetSessionToken() string

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() *channel2.Message

func (*RemoveTerminatorRequestContext) GetSessionFields

func (self *RemoveTerminatorRequestContext) GetSessionFields(ctx requestContext) logrus.Fields

func (*RemoveTerminatorRequestContext) GetSessionToken

func (self *RemoveTerminatorRequestContext) GetSessionToken() string

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() *channel2.Message

func (*UpdateTerminatorRequestContext) GetSessionFields

func (self *UpdateTerminatorRequestContext) GetSessionFields(ctx requestContext) logrus.Fields

func (*UpdateTerminatorRequestContext) GetSessionToken

func (self *UpdateTerminatorRequestContext) GetSessionToken() string