redis

Documentation

Index

• type Client
  • func NewClient(network string, addr string, size int) (*Client, error)
  • func (c *Client) SaveBusVehicleDataMessage(vehicleID string, message []byte) (int, error)

Types

type Client

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

Client represents layer between writer and Redis

func NewClient

func NewClient(network string, addr string, size int) (*Client, error)

NewClient creates new Client

func (*Client) SaveBusVehicleDataMessage

func (c *Client) SaveBusVehicleDataMessage(vehicleID string, message []byte) (int, error)

SaveBusVehicleDataMessage saves individual BusVehicleData message and sends it to PubSub subscribers. Returns the number of clients that received the message (and error)