testcomponents

type Community ¶ added in v1.3.0

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

Community is a test community component.

func (e *Community) Run(ctx context.Context) error

func (e *Community) Update(args component.Arguments) error

type Count ¶

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

func NewCount(o component.Options, cfg CountConfig) (*Count, error)

func (t *Count) Run(ctx context.Context) error

func (t *Count) Update(args component.Arguments) error

type CountConfig ¶

type CountConfig struct {
	Frequency time.Duration `alloy:"frequency,attr"`
	Max       int           `alloy:"max,attr"`
}

type CountExports ¶

type CountExports struct {
	Count int `alloy:"count,attr,optional"`
}

type Experimental ¶

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

Experimental is a test component that is marked as experimental. Used to verify stability level checking.

func (e *Experimental) Run(ctx context.Context) error

func (e *Experimental) Update(args component.Arguments) error

type Fake ¶

type Fake struct {
	RunFunc    func(ctx context.Context) error
	UpdateFunc func(args component.Arguments) error
}

Fake is a fake component instance which invokes fields when its methods are called. Fake does not register itself as a component and must be provided in a custom registry.

The zero value is ready for use.

func (f *Fake) Run(ctx context.Context) error

func (f *Fake) Update(args component.Arguments) error

type Passthrough ¶

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

Passthrough implements the testcomponents.passthrough component, where it always emits its input as an output.

func NewPassthrough(o component.Options, cfg PassthroughConfig) (*Passthrough, error)

func (t *Passthrough) DebugInfo() interface{}

func (t *Passthrough) Run(ctx context.Context) error

func (t *Passthrough) Update(args component.Arguments) error

type PassthroughConfig ¶

type PassthroughConfig struct {
	Input string        `alloy:"input,attr"`
	Lag   time.Duration `alloy:"lag,attr,optional"`
}

PassthroughConfig configures the testcomponents.passthrough component.

type PassthroughExports ¶

type PassthroughExports struct {
	Output string `alloy:"output,attr,optional"`
}

PassthroughExports describes exported fields for the testcomponents.passthrough component.

type Summation ¶

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

func NewSummation(o component.Options, cfg SummationConfig) (*Summation, error)

func (t *Summation) Run(ctx context.Context) error

func (t *Summation) Update(args component.Arguments) error

type SummationConfig ¶

type SummationConfig struct {
	Input int `alloy:"input,attr"`
}

type SummationExports ¶

type SummationExports struct {
	Sum       int `alloy:"sum,attr"`
	LastAdded int `alloy:"last_added,attr"`
}

type Tick ¶

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

Tick implements the testcomponents.tick component, where the wallclock time will be emitted on a given frequency.

func NewTick(o component.Options, cfg TickConfig) (*Tick, error)

func (t *Tick) Run(ctx context.Context) error

func (t *Tick) Update(args component.Arguments) error

type TickConfig ¶

type TickConfig struct {
	Frequency time.Duration `alloy:"frequency,attr"`
}

TickConfig configures the testcomponents.tick component.

type TickExports ¶

type TickExports struct {
	Time time.Time `alloy:"tick_time,attr,optional"`
}

TickExports describes exported fields for the testcomponents.tick component.