subInner

Documentation

Index

• Constants
• type Handle
• type InnerSubHandle
• type NatsClient
  • func (n *NatsClient) SubToDevMsg(handle Handle) error
• type SubInner
  • func NewSubInner(c conf.EventConf, nodeID int64) (SubInner, error)

Constants

const (
	ThingsDDDeliverGroup = "things_dg_group"
)

Types

type Handle

type Handle func(ctx context.Context) InnerSubHandle

type InnerSubHandle

type InnerSubHandle interface {
	PublishToDev(info *devices.InnerPublish) error
}

type NatsClient

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

func (*NatsClient) SubToDevMsg

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

type SubInner

type SubInner interface {
	SubToDevMsg(handle Handle) error
}

func NewSubInner

func NewSubInner(c conf.EventConf, nodeID int64) (SubInner, error)