publishers

Documentation

Index

• type MessageQueueAddress
• type Publisher
• type PublisherProvider
  • func ProvideRedisPublisherProvider(logger logging.Logger, address string) PublisherProvider
• type Topic

Types

type MessageQueueAddress

type MessageQueueAddress string

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

type Publisher

type Publisher interface {
	Publish(ctx context.Context, data interface{}) error
}

Publisher produces events onto a queue.

type PublisherProvider

type PublisherProvider interface {
	ProviderPublisher(topic string) (Publisher, error)
}

PublisherProvider is a function that provides a Publisher for a given topic.

func ProvideRedisPublisherProvider

func ProvideRedisPublisherProvider(logger logging.Logger, address string) PublisherProvider

ProvideRedisPublisherProvider returns a PublisherProvider for a given address.

type Topic

type Topic string

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