consumer

Documentation

Index

• type Builder
• type CloseFunc
• type DemoConsumer
  • func (p *DemoConsumer) Consume(ctx context.Context, stdout, stderr io.Reader) CloseFunc
• type ExecutionSummary
• type Interface
• type WriterOp

Types

type Builder

type Builder interface {
	Build(*zap.SugaredLogger, WriterOp) (Interface, error)
}

Builder builds a consumer

type CloseFunc

type CloseFunc func(ExecutionSummary)

CloseFunc

type DemoConsumer

type DemoConsumer struct {
	WriterOp
	Logger *zap.SugaredLogger
}

DemoConsumer stub consumer implementation. todo(ck) delete - this is a stub implementation for PoC purposes only.

func (*DemoConsumer) Consume

func (p *DemoConsumer) Consume(ctx context.Context, stdout, stderr io.Reader) CloseFunc

Consume reads stdout line by line and produces entries

type ExecutionSummary

type ExecutionSummary struct {
	Command     string
	ExitCode    int
	RunDuration time.Duration
}

ExecutionSummary describes a command execution

type Interface

type Interface interface {
	Consume(ctx context.Context, stdin, stderr io.Reader) CloseFunc
}

Interface consumes command output and emits telemetry data

type WriterOp

type WriterOp interface {
	NewEntry(value interface{}) (*entry.Entry, error)
	Write(ctx context.Context, e *entry.Entry)
}

WriterOp is the consumer's interface to the stanza pipeline