Documentation
¶
Index ¶
Constants ¶
View Source
const (
// ProviderRedis is used to refer to redis.
ProviderRedis = "redis"
)
Variables ¶
View Source
var ( // Providers are what we provide to dependency injection. Providers = wire.NewSet( ProvideConsumerProvider, ProvidePublisherProvider, ) )
Functions ¶
func ProvideConsumerProvider ¶
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.
Source Files
Click to show internal directories.
Click to hide internal directories.