producer

Documentation

Overview

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

Index

• Constants
• Variables
• func NewEventStoreMiddleware(svc policies.Service, client *redis.Client, logger *zap.Logger) policies.Service

Constants

const (
	DatasetPrefix = "dataset."
	DatasetCreate = DatasetPrefix + "create"
	DatasetRemove = DatasetPrefix + "remove"
	DatasetUpdate = DatasetPrefix + "update"
	PolicyPrefix  = "policy."
	PolicyCreate  = PolicyPrefix + "create"
	PolicyUpdate  = PolicyPrefix + "update"
	PolicyRemove  = PolicyPrefix + "remove"
)

Variables

var (
	ErrValidatePolicy = errors.New("failed to validate policy")
)

Functions

func NewEventStoreMiddleware

func NewEventStoreMiddleware(svc policies.Service, client *redis.Client, logger *zap.Logger) policies.Service

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