producer

Documentation

Overview

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

Index

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

Constants

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

Functions

func NewEventStoreMiddleware

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

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