queue

Documentation

Index

• type KafkaWriter
• type Queue
  • func NewQueue(ctx context.Context, kafkaWriter KafkaWriter) *Queue
  • func (q *Queue) AddToQueue(topic string, value interface{}) error
  • func (q *Queue) Dispatch() error

Types

type KafkaWriter

type KafkaWriter interface {
	WriteMessages(ctx context.Context, msgs ...kafka.Message) error
}

type Queue

type Queue struct {
	KafkaWriter KafkaWriter
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(ctx context.Context, kafkaWriter KafkaWriter) *Queue

func (*Queue) AddToQueue

func (q *Queue) AddToQueue(topic string, value interface{}) error

func (*Queue) Dispatch

func (q *Queue) Dispatch() error