redis

Documentation

Overview

Package redis contains cache implementations using Redis as the underlying database.

Index

• type EventStore
  • func NewEventStore(client *redis.Client, instance string) EventStore
  • func (es EventStore) Connect(clientID string) error
  • func (es EventStore) Disconnect(clientID string) error

Types

type EventStore

type EventStore struct {
	// contains filtered or unexported fields
}

EventStore is a struct used to store event streams in Redis

func NewEventStore

func NewEventStore(client *redis.Client, instance string) EventStore

NewEventStore returns wrapper around mProxy service that sends events to event store.

func (EventStore) Connect

func (es EventStore) Connect(clientID string) error

Connect issues event on MQTT CONNECT

func (EventStore) Disconnect

func (es EventStore) Disconnect(clientID string) error

Disconnect issues event on MQTT CONNECT