kvstore

package

v0.0.0-...-839ea1c Latest Latest Go to latest Published: Jul 16, 2024 License: GPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Client wrapper around Redis

func New() Client

New initializes a new client

func (c *Client) Publish(ctx context.Context, e event.Envelope)

Publish an event.Query

func (c *Client) SubMessages(ctx context.Context) <-chan envelope.Message

SubMessages subcribes to message events

func (c *Client) SubRooms(ctx context.Context) <-chan remote.Payload

SubRooms subcribes to events

type Payload struct {
	user.Token
	// contains filtered or unexported fields
}

Payload retrieved from redis

func (p Payload) Type() string

Type implements interface

func (p Payload) User() user.Token

User implements interface

Path	Synopsis
examples Package main contains examples for Redis	Package main contains examples for Redis