handler_edge_ctrl

Documentation

Index

• func NewApiSessionAddedHandler(sm state.Manager, binding channel.Binding) *apiSessionAddedHandler
• func NewApiSessionRemovedHandler(sm state.Manager) *apiSessionRemovedHandler
• func NewApiSessionUpdatedHandler(sm state.Manager) *apiSessionUpdatedHandler
• func NewDataStateEventHandler(state state.Manager) channel.TypedReceiveHandler
• func NewExtendEnrollmentCertsHandler(id *identity.TokenId, notifyCertUpdate func()) *extendEnrollmentCertsHandler
• func NewHelloHandler(stateManager state.Manager, listeners []*edge_ctrl_pb.Listener) *helloHandler
• func NewSessionRemovedHandler(sm state.Manager) *sessionRemovedHandler
• type DataStateHandler
  • func NewDataStateHandler(state state.Manager) *DataStateHandler
  • func (*DataStateHandler) ContentType() int32
  • func (dsh *DataStateHandler) HandleReceive(msg *channel.Message, ch channel.Channel)
• type ServiceListHandler
  • func NewServiceListHandler(...) *ServiceListHandler
  • func (self *ServiceListHandler) ContentType() int32
  • func (self *ServiceListHandler) HandleReceive(msg *channel.Message, ch channel.Channel)

Functions

func NewApiSessionAddedHandler

func NewApiSessionAddedHandler(sm state.Manager, binding channel.Binding) *apiSessionAddedHandler

func NewApiSessionRemovedHandler

func NewApiSessionRemovedHandler(sm state.Manager) *apiSessionRemovedHandler

func NewApiSessionUpdatedHandler

func NewApiSessionUpdatedHandler(sm state.Manager) *apiSessionUpdatedHandler

func NewDataStateEventHandler

func NewDataStateEventHandler(state state.Manager) channel.TypedReceiveHandler

func NewExtendEnrollmentCertsHandler

func NewExtendEnrollmentCertsHandler(id *identity.TokenId, notifyCertUpdate func()) *extendEnrollmentCertsHandler

func NewHelloHandler

func NewHelloHandler(stateManager state.Manager, listeners []*edge_ctrl_pb.Listener) *helloHandler

func NewSessionRemovedHandler

func NewSessionRemovedHandler(sm state.Manager) *sessionRemovedHandler

Types

type DataStateHandler

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

func NewDataStateHandler

func NewDataStateHandler(state state.Manager) *DataStateHandler

func (*DataStateHandler) ContentType

func (*DataStateHandler) ContentType() int32

func (*DataStateHandler) HandleReceive

func (dsh *DataStateHandler) HandleReceive(msg *channel.Message, ch channel.Channel)

type ServiceListHandler

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

func NewServiceListHandler

func NewServiceListHandler(handler func(ch channel.Channel, lastUpdateToken []byte, list []*rest_model.ServiceDetail)) *ServiceListHandler

func (*ServiceListHandler) ContentType

func (self *ServiceListHandler) ContentType() int32

func (*ServiceListHandler) HandleReceive

func (self *ServiceListHandler) HandleReceive(msg *channel.Message, ch channel.Channel)