redisClient

Documentation

Index

• type Client
  • func NewClient(cfg config.RedisCfg, log *slog.Logger) *Client
  • func (c *Client) ClearChannel(ctx context.Context, channel *topic.Channel) error
  • func (c *Client) Close() error
  • func (c *Client) Consume(ctx context.Context, channel *topic.Channel, consumer *topic.Consumer) ([]*topic.Event, error)
  • func (c *Client) CreateConsumerGroup(ctx context.Context, channel *topic.Channel, consumer *topic.Consumer) error
  • func (c *Client) Produce(ctx context.Context, channel *topic.Channel, event *topic.Event) error

Types

type Client

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

func NewClient

func NewClient(cfg config.RedisCfg, log *slog.Logger) *Client

func (*Client) ClearChannel

func (c *Client) ClearChannel(ctx context.Context, channel *topic.Channel) error

func (*Client) Close

func (c *Client) Close() error

func (*Client) Consume

func (c *Client) Consume(ctx context.Context, channel *topic.Channel, consumer *topic.Consumer) ([]*topic.Event, error)

func (*Client) CreateConsumerGroup

func (c *Client) CreateConsumerGroup(ctx context.Context, channel *topic.Channel, consumer *topic.Consumer) error

func (*Client) Produce

func (c *Client) Produce(ctx context.Context, channel *topic.Channel, event *topic.Event) error