subscribe

Documentation

Index

• Constants
• type Handle
• type NatsClient
  • func (n *NatsClient) Subscribe(handle Handle) error
• type ServerEvent
• type SubApp
  • func NewSubServer(c conf.EventConf, nodeID int64) (SubApp, error)

Constants

const (
	ThingsDeliverGroup = "things_timed_job_group"
)

Types

type Handle

type Handle func(ctx context.Context) ServerEvent

type NatsClient

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

func (*NatsClient) Subscribe

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

type ServerEvent

type ServerEvent interface {
	DataClean() error
}

type SubApp

type SubApp interface {
	Subscribe(handle Handle) error
}

func NewSubServer

func NewSubServer(c conf.EventConf, nodeID int64) (SubApp, error)