redis

Documentation

Index

• Constants
• func DecodeSinksEvent(event map[string]interface{}, operation string) (redis.SinksUpdateEvent, error)
• type StateUpdateEvent

Constants

const (
	SinkPrefix   = "sinks."
	SinkCreate   = SinkPrefix + "create"
	SinkDelete   = SinkPrefix + "remove"
	SinkUpdate   = SinkPrefix + "update"
	StreamSinks  = "orb.sinks"
	GroupMaestro = "orb.maestro"
	Exists       = "BUSYGROUP Consumer Group name already exists"
)

Functions

func DecodeSinksEvent

func DecodeSinksEvent(event map[string]interface{}, operation string) (redis.SinksUpdateEvent, error)

Types

type StateUpdateEvent

type StateUpdateEvent struct {
	OwnerID   string
	SinkID    string
	State     string
	Msg       string
	Timestamp time.Time
}