json

Documentation

Index

• Constants
• type JSONLogGenerator
  • func New(logger *zap.Logger, workers int, rate time.Duration, logType string, ...) (*JSONLogGenerator, error)
  • func (g *JSONLogGenerator) Name() string
  • func (g *JSONLogGenerator) SetCountTracker(t *count.Tracker)
  • func (g *JSONLogGenerator) Start(_ context.Context) error
  • func (g *JSONLogGenerator) Stop(ctx context.Context) error
  • func (g *JSONLogGenerator) SupportedTelemetry() []telemetry.Type

Constants

const (

	// LogTypeDefault is the default log type
	LogTypeDefault = logtypes.LogTypeDefault
	// LogTypePII is the PII log type
	LogTypePII = logtypes.LogTypePII
)

Types

type JSONLogGenerator

type JSONLogGenerator struct {
	embed.ProducerMarker
	// contains filtered or unexported fields
}

JSONLogGenerator generates JSON log data with configurable workers

func New

func New(logger *zap.Logger, workers int, rate time.Duration, logType string, consumer embed.LogConsumer) (*JSONLogGenerator, error)

New creates a new JSON log generator. The consumer receives each generated record as a size-1 batch via ConsumeLogs.

func (*JSONLogGenerator) Name

func (g *JSONLogGenerator) Name() string

Name returns the module identifier.

func (*JSONLogGenerator) SetCountTracker

func (g *JSONLogGenerator) SetCountTracker(t *count.Tracker)

SetCountTracker sets the finite generation count tracker.

func (*JSONLogGenerator) Start

func (g *JSONLogGenerator) Start(_ context.Context) error

Start launches the worker goroutines that push generated records to the configured consumer.

func (*JSONLogGenerator) Stop

func (g *JSONLogGenerator) Stop(ctx context.Context) error

Stop stops the JSON log generator. This function expects to be called exactly once.

func (*JSONLogGenerator) SupportedTelemetry

func (g *JSONLogGenerator) SupportedTelemetry() []telemetry.Type

SupportedTelemetry returns the telemetry types this generator produces.