producer

Documentation

Index

• Constants
• func NewEventStoreMiddleware(repo config.ConfigRepo, client *redis.Client) config.ConfigRepo
• type SinkerUpdateEvent
  • func (cse SinkerUpdateEvent) Encode() map[string]interface{}

Constants

const (
	SinkerPrefix = "sinker."
	SinkerUpdate = SinkerPrefix + "update"
)

Functions

func NewEventStoreMiddleware

func NewEventStoreMiddleware(repo config.ConfigRepo, client *redis.Client) config.ConfigRepo

Types

type SinkerUpdateEvent

type SinkerUpdateEvent struct {
	SinkID    string
	Owner     string
	State     string
	Msg       string
	Timestamp time.Time
}

func (SinkerUpdateEvent) Encode

func (cse SinkerUpdateEvent) Encode() map[string]interface{}