processor

Documentation

Index

• type GlazeProcessor
  • 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
• type SimpleGlazeProcessor
  • func NewSimpleGlazeProcessor(oms ...middlewares.ObjectMiddleware) *SimpleGlazeProcessor
  • func (gp *SimpleGlazeProcessor) GetTable() *types.Table

Types

type GlazeProcessor

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

func NewGlazeProcessor

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

func (*GlazeProcessor) OutputFormatter

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

func (*GlazeProcessor) ProcessInputObject

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

ProcessInputObject takes an input object and processes it through the object middleware chain.

The final output is added to the output formatter as a single row.

type Processor

type Processor interface {
	ProcessInputObject(ctx context.Context, obj map[string]interface{}) error
	OutputFormatter() formatters.OutputFormatter
}

type SimpleGlazeProcessor

type SimpleGlazeProcessor struct {
	*GlazeProcessor
	// contains filtered or unexported fields
}

SimpleGlazeProcessor only collects the output and returns it as a types.Table

func NewSimpleGlazeProcessor

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

func (*SimpleGlazeProcessor) GetTable

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