consumer

Documentation

Overview

Package esconsumer contains events esconsumer for events

Adapted for Orb project, modifications licensed under MPL v. 2.0:

This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at https://mozilla.org/MPL/2.0/.

Index

• type Subscriber
  • func NewEventStore(sinkService sinks.SinkService, client *redis.Client, esconsumer string, ...) Subscriber

Types

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