faker

func (r *Reader) Ack(
	ctx context.Context, msgIDs [][]byte,
	ackHandler func(error),
	ackMsgHandler func([]byte, error),
)

func (r *Reader) Close()

func (r *Reader) EncodeMsgID(buf []byte, topic string, args ...any) []byte

func (r *Reader) Fetch(
	ctx context.Context, n uint32,
	fetchHandler func(n uint32, err error),
	msgHandler func(message []byte, topic string, args ...any),
)

func (r *Reader) HFetch(
	ctx context.Context, n uint32,
	fetchHandler func(n uint32, err error),
	msgHandler func(message []byte, topic string, hs [][]byte, args ...any),
)

func (r *Reader) HSubscribe(ctx context.Context, h func(message []byte, topic string, hs [][]byte, args ...any)) error

func (r *Reader) IsAutoCommit() bool

func (r *Reader) MsgIDStaticArgsLen() int

func (r *Reader) Nack(
	ctx context.Context, msgIDs [][]byte,
	nackHandler func(error),
	nackMsgHandler func([]byte, error),
)

func (r *Reader) Subscribe(ctx context.Context, h func(message []byte, topic string, args ...any)) error

func (w *Writer) BeginTx(_ context.Context) error

func (w *Writer) Close() error

func (w *Writer) CommitTx(_ context.Context) error

func (w *Writer) Endpoint() string

func (w *Writer) Flush(_ context.Context) error

func (w *Writer) HProduce(_ context.Context, msg []byte, headers [][]byte, callback func(err error))

func (w *Writer) Produce(_ context.Context, msg []byte, callback func(err error))

func (w *Writer) RollbackTx(_ context.Context) error