publish

Documentation

Index

• type Publisher
  • func New(logger *zap.Logger, opts option.Options) *Publisher
  • func (p *Publisher) Publish(clients []mqtt.Client)

Types

type Publisher

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

func New

func New(logger *zap.Logger, opts option.Options) *Publisher

func (*Publisher) Publish

func (p *Publisher) Publish(clients []mqtt.Client)

Publish start publishing on goroutines.