redis

Documentation

Index

• func NewRouteMapRepository(client *redis.Client, prefix string) lora.RouteMapRepository
• type Subscriber
  • func NewEventStore(svc lora.Service, client *redis.Client, consumer string, log logger.Logger) Subscriber

Functions

func NewRouteMapRepository

func NewRouteMapRepository(client *redis.Client, prefix string) lora.RouteMapRepository

NewRouteMapRepository returns redis thing cache implementation.

Types

type Subscriber

type Subscriber interface {
	// Subscribes to geven subject and receives events.
	Subscribe(context.Context, string) error
}

Subscriber represents event source for things and channels provisioning.

func NewEventStore

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

NewEventStore returns new event store instance.