config

Documentation

Index

• Constants
• Variables
• func ProvideConsumerProvider(logger logging.Logger, c *Config) (consumers.ConsumerProvider, error)
• func ProvidePublisherProvider(logger logging.Logger, c *Config) (publishers.PublisherProvider, error)
• type Config
• type MessageQueueAddress
• type Provider
• type RedisConfig

Constants

const (
	// ProviderRedis is used to refer to redis.
	ProviderRedis = "redis"
)

Variables

var (
	// Providers are what we provide to dependency injection.
	Providers = wire.NewSet(
		ProvideConsumerProvider,
		ProvidePublisherProvider,
	)
)

Functions

func ProvideConsumerProvider

func ProvideConsumerProvider(logger logging.Logger, c *Config) (consumers.ConsumerProvider, error)

ProvideConsumerProvider provides a PublisherProvider.

func ProvidePublisherProvider

func ProvidePublisherProvider(logger logging.Logger, c *Config) (publishers.PublisherProvider, error)

ProvidePublisherProvider provides a PublisherProvider.

Types

type Config

type Config struct {
	Provider    Provider    `json:"provider" mapstructure:"provider" toml:"provider,omitempty"`
	RedisConfig RedisConfig `json:"redis" mapstructure:"redis" toml:"redis,omitempty"`
	// contains filtered or unexported fields
}

Config is used to indicate how the messaging provider should be configured.

type MessageQueueAddress

type MessageQueueAddress string

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

type Provider

type Provider string

Provider is used to indicate what messaging provider we'll use.

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.