darwin

Documentation

Index

• type Ingester
  • func NewIngester(ctx context.Context, log *slog.Logger, reader *kafka.Reader, ...) (*Ingester, error)
  • func (i *Ingester) Close() error
  • func (i *Ingester) Fetch(ctx context.Context) (kafka.Message, error)
  • func (i *Ingester) ProcessAndCommit(msg kafka.Message) error

Types

type Ingester

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

Ingester implements the interface railreader.Ingester[kafka.Message].

func NewIngester

func NewIngester(ctx context.Context, log *slog.Logger, reader *kafka.Reader, dbpool *pgxpool.Pool, fs fs.ReadDirFS) (*Ingester, error)

func (*Ingester) Close

func (i *Ingester) Close() error

func (*Ingester) Fetch

func (i *Ingester) Fetch(ctx context.Context) (kafka.Message, error)

Fetch blocks until a message is available, or the provided context is cancelled.

func (*Ingester) ProcessAndCommit

func (i *Ingester) ProcessAndCommit(msg kafka.Message) error