consumer

Documentation

Index

• type Subscriber
  • func NewEventStore(sinkerService sinker.Service, configRepo config.ConfigRepo, ...) Subscriber

Types

type Subscriber

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

func NewEventStore

func NewEventStore(sinkerService sinker.Service, configRepo config.ConfigRepo, client *redis.Client, esconsumer string, log *zap.Logger) Subscriber

NewEventStore returns new event store instance.