publisher

Documentation

Index

• type Event
• type Publisher
  • func NewPublisher(r *redisp.RedisDB, client *emq.Mqtt, natsCl *natsp.Nats, m *mongo.DB, size int, ...) *Publisher
  • func (pb *Publisher) Cancel()
  • func (pb *Publisher) GetEvents()
  • func (pb *Publisher) Work()

Types

type Event

type Event struct {
	ID      string   `json:"id"`
	Topic   string   `json:"topic"`
	Payload string   `json:"payload"`
	Type    []string `json:"type"`
}

type Publisher

type Publisher struct {
	Redis      *redisp.RedisDB
	Mongo      *mongo.DB
	Events     []Event
	Mqtt       *emq.Mqtt
	Nats       *natsp.Nats
	Wp         *workerpool.WorkerPool
	WorkerSize int
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(r *redisp.RedisDB, client *emq.Mqtt, natsCl *natsp.Nats,
	m *mongo.DB, size int, logger *zap.Logger,
) *Publisher

func (*Publisher) Cancel

func (pb *Publisher) Cancel()

func (*Publisher) GetEvents

func (pb *Publisher) GetEvents()

func (*Publisher) Work

func (pb *Publisher) Work()