consumers

Documentation

Index

• type Consumer
• type ConsumerProvider
  • func ProvideRedisConsumerProvider(logger logging.Logger, queueAddress string) ConsumerProvider
• type MessageQueueAddress
• type RedisConfig
• type Topic

Types

type Consumer

type Consumer interface {
	Consume(stopChan chan bool, errors chan error)
}

Consumer produces events onto a queue.

type ConsumerProvider

type ConsumerProvider interface {
	ProviderConsumer(ctx context.Context, topic string, handlerFunc func(context.Context, []byte) error) (Consumer, error)
}

ConsumerProvider is a function that provides a Consumer for a given topic.

func ProvideRedisConsumerProvider

func ProvideRedisConsumerProvider(logger logging.Logger, queueAddress string) ConsumerProvider

ProvideRedisConsumerProvider returns a ConsumerProvider for a given address.

type MessageQueueAddress

type MessageQueueAddress string

MessageQueueAddress is a simple string alias for the location of our event queue server.

type RedisConfig

type RedisConfig struct {
	QueueAddress MessageQueueAddress `json:"message_queue_address" mapstructure:"message_queue_address" toml:"message_queue_address,omitempty"`
}

RedisConfig configures a Redis-backed consumer.

type Topic

type Topic string

Topic is a simple string alias for the location of our event queue server.