read

Documentation

Index

• type Read
  • func NewRead(batcher b.MqBatcher[b.MessageArguments], conf conf.Connection, ...) (*Read, error)
  • func (r *Read) Close() error
  • func (r *Read) Read(ctx context.Context, lwdp fetcher.LwdpFetcher) error

Types

type Read

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

func NewRead

func NewRead(batcher b.MqBatcher[b.MessageArguments], conf conf.Connection, schemas conf.SchemasConf, book string, group string, alias string) (*Read, error)

func (*Read) Close

func (r *Read) Close() error

func (*Read) Read

func (r *Read) Read(ctx context.Context, lwdp fetcher.LwdpFetcher) error