reader

Documentation

Index

• type Config
• type Reader
  • func NewReader(cnf *Config, log *zap.SugaredLogger) (*Reader, error)
  • func (r *Reader) Ack(m ami.Message)
  • func (r *Reader) AmiError(err error)
  • func (r *Reader) IsAccessible() bool
  • func (r *Reader) Start() chan ami.Message
  • func (r *Reader) Stop()

Types

type Config

type Config struct {
	Consumer          string
	PendingBufferSize int64
	PipeBufferSize    int64
	PrefetchCount     int64
	QueueName         string
	Redis             redisConfig
	ShardsCount       int8
}

type Reader

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

Reader hold object

func NewReader

func NewReader(cnf *Config, log *zap.SugaredLogger) (*Reader, error)

func (*Reader) Ack

func (r *Reader) Ack(m ami.Message)

Ack message

func (*Reader) AmiError

func (r *Reader) AmiError(err error)

func (*Reader) IsAccessible

func (r *Reader) IsAccessible() bool

IsAccessible checks Redis status

func (*Reader) Start

func (r *Reader) Start() chan ami.Message

func (*Reader) Stop

func (r *Reader) Stop()