consumer

Documentation

Overview

Package esconsumer contains events esconsumer for events

Index

• type SinkStatusListener
  • func NewSinkStatusListener(l *zap.Logger, streamClient *redis.Client, sinkService sinks.SinkService) SinkStatusListener
• type Subscriber
  • func NewEventStore(sinkService sinks.SinkService, client *redis.Client, esconsumer string, ...) Subscriber

Types

type SinkStatusListener

type SinkStatusListener interface {
	SubscribeToMaestroSinkStatus(ctx context.Context) error
	ReceiveMessage(ctx context.Context, message redis.XMessage) error
}

func NewSinkStatusListener

func NewSinkStatusListener(l *zap.Logger, streamClient *redis.Client, sinkService sinks.SinkService) SinkStatusListener

type Subscriber

type Subscriber interface {
	Subscribe(context context.Context) error
}

func NewEventStore

func NewEventStore(sinkService sinks.SinkService, client *redis.Client, esconsumer string, logger *zap.Logger) Subscriber