processor

Jun 28, 2023

Changes in this version

+ type TableProcessor interface

+ AddRow func(ctx context.Context, obj types.Row) error

+ AddRowMiddleware func(mw ...middlewares.RowMiddleware)

+ Finalize func(ctx context.Context) error

+ GetTable func() *types.Table

+ OutputFormatter func() formatters.TableOutputFormatter

Jun 20, 2023

Changes in this version

+ type GlazeProcessorOption func(*GlazeProcessor)

+ func WithAppendObjectMiddleware(om ...middlewares.ObjectMiddleware) GlazeProcessorOption

+ func WithOutputFormatter(of formatters.OutputFormatter) GlazeProcessorOption

+ func WithPrependObjectMiddleware(om ...middlewares.ObjectMiddleware) GlazeProcessorOption

Apr 27, 2023

Changes in this version

+ type GlazeProcessor struct

+ func NewGlazeProcessor(of formatters.OutputFormatter, oms ...middlewares.ObjectMiddleware) *GlazeProcessor

+ func (gp *GlazeProcessor) OutputFormatter() formatters.OutputFormatter

+ func (gp *GlazeProcessor) ProcessInputObject(ctx context.Context, obj map[string]interface{}) error

+ type Processor interface

+ OutputFormatter func() formatters.OutputFormatter

+ ProcessInputObject func(ctx context.Context, obj map[string]interface{}) error

+ type SimpleGlazeProcessor struct

+ func NewSimpleGlazeProcessor(oms ...middlewares.ObjectMiddleware) *SimpleGlazeProcessor

+ func (gp *SimpleGlazeProcessor) GetTable() *types.Table