ingestor

Documentation

Index

• func Run(ctx context.Context) error
• type MappingIngestor
  • func NewMappingIngestor() (*MappingIngestor, error)
  • func (gi *MappingIngestor) MappingFunc(ctx context.Context, mappingRecord *types.MappingRecord) error
  • func (gi *MappingIngestor) Run(ctx context.Context) error

Functions

func Run

func Run(ctx context.Context) error

Types

type MappingIngestor

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

func NewMappingIngestor

func NewMappingIngestor() (*MappingIngestor, error)

func (*MappingIngestor) MappingFunc

func (gi *MappingIngestor) MappingFunc(ctx context.Context, mappingRecord *types.MappingRecord) error

func (*MappingIngestor) Run

func (gi *MappingIngestor) Run(ctx context.Context) error