ingester

Documentation

Index

• type Ingester
  • func NewIngester(logger log.Logger, table Table) Ingester
• type Table
• type TableIngester
  • func (ing TableIngester) Ingest(ctx context.Context, record arrow.Record) error

Types

type Ingester

type Ingester interface {
	Ingest(ctx context.Context, record arrow.Record) error
}

func NewIngester

func NewIngester(
	logger log.Logger,
	table Table,
) Ingester

type Table

type Table interface {
	InsertRecord(context.Context, arrow.Record) (tx uint64, err error)
}

type TableIngester

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

func (TableIngester) Ingest

func (ing TableIngester) Ingest(ctx context.Context, record arrow.Record) error