consumer

Documentation

Overview

Package esconsumer contains events esconsumer for events

Index

• type Subscriber
  • func NewEventStore(policiesService policies.Service, client *redis.Client, esconsumer string, ...) Subscriber

Types

type Subscriber

type Subscriber interface {
	SubscribeToFleet(context context.Context) error
	SubscribeToSink(context context.Context) error
}

func NewEventStore

func NewEventStore(policiesService policies.Service, client *redis.Client, esconsumer string, log *zap.Logger) Subscriber

NewEventStore returns new event store instance.