redis

Documentation

Index

• Constants
• type Client
  • func NewClient(config db.Configuration, logger logger.LoggingClient) (*Client, errors.EdgeX)
  • func (c *Client) AddEvent(e model.Event) (model.Event, errors.EdgeX)
  • func (c *Client) CloseSession()
  • func (c *Client) EventById(id string) (event model.Event, edgeXerr errors.EdgeX)

Constants

const (
	MULTI = "MULTI"
	SET   = "SET"
	ZADD  = "ZADD"
	GET   = "GET"
	EXEC  = "EXEC"
)

Redis commmands used in this project Reference: https://redis.io/commands

const EventsCollection = "v2:event"

const ReadingsCollection = "v2:reading"

Types

type Client

type Client struct {
	*redisClient.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(config db.Configuration, logger logger.LoggingClient) (*Client, errors.EdgeX)

func (*Client) AddEvent

func (c *Client) AddEvent(e model.Event) (model.Event, errors.EdgeX)

Add a new event

func (*Client) CloseSession

func (c *Client) CloseSession()

CloseSession closes the connections to Redis

func (*Client) EventById

func (c *Client) EventById(id string) (event model.Event, edgeXerr errors.EdgeX)

Get an event by id