consumer

Documentation

Overview

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

Index

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

Types

type Subscriber

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

Subscriber represents event source for things and channels provisioning.

func NewEventStore

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

NewEventStore returns new event store instance.