redis_connector

Documentation

Overview

Package redis_connector implements a connector with redis

Index

• type Connector
  • func NewConnector(client *rdb.Client) *Connector
  • func (q *Connector) Close() error
  • func (q *Connector) NewConsumer(topic, group string, batchSize int, fn type2.HandleMessage) error
  • func (q *Connector) Produce(ctx context.Context, msg *types.Message) error

Types

type Connector

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

Connector is a redis connector

func NewConnector

func NewConnector(client *rdb.Client) *Connector

NewConnector create a new redis connector

func (*Connector) Close

func (q *Connector) Close() error

Close close the queue

func (*Connector) NewConsumer

func (q *Connector) NewConsumer(topic, group string, batchSize int, fn type2.HandleMessage) error

NewConsumer consume Messages from the queue in real time

func (*Connector) Produce

func (q *Connector) Produce(ctx context.Context, msg *types.Message) error

Produce produce a Message to the queue in realtime