handler_edge_ctrl

Documentation

Index

• func NewApiSessionAddedHandler(sm fabric.StateManager, binding channel.Binding) *apiSessionAddedHandler
• func NewApiSessionRemovedHandler(sm fabric.StateManager) *apiSessionRemovedHandler
• func NewApiSessionUpdatedHandler(sm fabric.StateManager) *apiSessionUpdatedHandler
• func NewExtendEnrollmentCertsHandler(id *identity.TokenId, notifyCertUpdate func()) *extendEnrollmentCertsHandler
• func NewHelloHandler(listeners []*edge_ctrl_pb.Listener) *helloHandler
• func NewSessionRemovedHandler(sm fabric.StateManager) *sessionRemovedHandler
• type ServiceListHandler
  • func NewServiceListHandler(handler func(ch channel.Channel, lastUpdateToken []byte, list []*edge.Service)) *ServiceListHandler
  • func (self *ServiceListHandler) ContentType() int32
  • func (self *ServiceListHandler) HandleReceive(msg *channel.Message, ch channel.Channel)

Functions

func NewApiSessionAddedHandler

func NewApiSessionAddedHandler(sm fabric.StateManager, binding channel.Binding) *apiSessionAddedHandler

func NewApiSessionRemovedHandler

func NewApiSessionRemovedHandler(sm fabric.StateManager) *apiSessionRemovedHandler

func NewApiSessionUpdatedHandler

func NewApiSessionUpdatedHandler(sm fabric.StateManager) *apiSessionUpdatedHandler

func NewExtendEnrollmentCertsHandler

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

func NewHelloHandler

func NewHelloHandler(listeners []*edge_ctrl_pb.Listener) *helloHandler

func NewSessionRemovedHandler

func NewSessionRemovedHandler(sm fabric.StateManager) *sessionRemovedHandler

Types

type ServiceListHandler

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

func NewServiceListHandler

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

func (*ServiceListHandler) ContentType

func (self *ServiceListHandler) ContentType() int32

func (*ServiceListHandler) HandleReceive

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