consumer

Documentation

Overview

Package esconsumer contains events esconsumer for events

Index

• type Subscriber
  • func NewEventStore(fleetService fleet.Service, commsService fleet.AgentCommsService, ...) Subscriber

Types

type Subscriber

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

func NewEventStore

func NewEventStore(fleetService fleet.Service, commsService fleet.AgentCommsService, client *redis.Client, esconsumer string, log *zap.Logger) Subscriber

NewEventStore returns new event store instance.