consumer

Documentation

Overview

Package consumer contains events consumer for events published by Things service.

Index

• type EventStore
  • func NewEventStore(svc bootstrap.Service, client *redis.Client, consumer string, ...) EventStore

Types

type EventStore

type EventStore interface {
	// Subscribes to given subject and receives events.
	Subscribe(string) error
}

EventStore represents event source for things and channels provisioning.

func NewEventStore

func NewEventStore(svc bootstrap.Service, client *redis.Client, consumer string, log logger.Logger) EventStore

NewEventStore returns new event store instance.