producer

Documentation

Index

• type FileStoreProducer
  • func NewFileStoreProducer() *FileStoreProducer
  • func (p *FileStoreProducer) Cancel()
  • func (p *FileStoreProducer) Publish(message model.Message) error
• type MockProducer
  • func NewMockProducer() *MockProducer
  • func (p *MockProducer) Cancel()
  • func (p *MockProducer) Publish(message model.Message) error
• type MongoDBProducer
  • func NewMongoProducer() *MongoDBProducer
  • func (p *MongoDBProducer) Cancel()
  • func (p *MongoDBProducer) Publish(message model.Message) error
• type Producer
  • func NewProducer(config settings.Settings) Producer

Types

type FileStoreProducer

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

func NewFileStoreProducer

func NewFileStoreProducer() *FileStoreProducer

func (*FileStoreProducer) Cancel

func (p *FileStoreProducer) Cancel()

func (*FileStoreProducer) Publish

func (p *FileStoreProducer) Publish(message model.Message) error

type MockProducer

type MockProducer struct {
	Actions map[string]int
}

func NewMockProducer

func NewMockProducer() *MockProducer

func (*MockProducer) Cancel

func (p *MockProducer) Cancel()

func (*MockProducer) Publish

func (p *MockProducer) Publish(message model.Message) error

type MongoDBProducer

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

func NewMongoProducer

func NewMongoProducer() *MongoDBProducer

func (*MongoDBProducer) Cancel

func (p *MongoDBProducer) Cancel()

func (*MongoDBProducer) Publish

func (p *MongoDBProducer) Publish(message model.Message) error

type Producer

type Producer interface {
	Publish(message model.Message) error
	Cancel()
}

func NewProducer

func NewProducer(config settings.Settings) Producer