server

Documentation

Index

• type Handle
• type NatsClient
  • func (n *NatsClient) Subscribe(handle Handle) error
• type Server
  • func NewServer(c conf.EventConf, nodeID int64) (Server, error)
• type ServerHandle

Types

type Handle

type Handle func(ctx context.Context) ServerHandle

type NatsClient

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

func (*NatsClient) Subscribe

func (n *NatsClient) Subscribe(handle Handle) error

type Server

type Server interface {
	Subscribe(handle Handle) error
}

func NewServer

func NewServer(c conf.EventConf, nodeID int64) (Server, error)

type ServerHandle

type ServerHandle interface {
	ActionCheck(req *deviceMsg.PublishMsg) error
}