producer

Documentation

Overview

Package producer contains the domain events needed to support event sourcing of Sink service actions.

Index

• Constants
• func NewSinkStreamProducerMiddleware(svc sinks.SinkService, client *redis.Client) sinks.SinkService

Constants

const (
	SinkPrefix = "sinks."
	SinkCreate = SinkPrefix + "create"
	SinkDelete = SinkPrefix + "remove"
	SinkUpdate = SinkPrefix + "update"
)

Functions

func NewSinkStreamProducerMiddleware

func NewSinkStreamProducerMiddleware(svc sinks.SinkService, client *redis.Client) sinks.SinkService

NewSinkStreamProducerMiddleware returns wrapper around sinks service that sends events to event store.