test

Documentation

Overview

Package test implements the Benthos service unit testing command.

Index

• func Generate(path, testSuffix string) error
• func Run(path, testSuffix string, lint bool) bool
• type Case
  • func NewCase() Case
  • func (c *Case) Execute(provider ProcProvider) (failures []CaseFailure, err error)
  • func (c *Case) UnmarshalYAML(value *yaml.Node) error
• type CaseFailure
  • func (c CaseFailure) String() string
• type Condition
• type ConditionsMap
  • func (c ConditionsMap) CheckAll(part types.Part) (errs []error)
  • func (c *ConditionsMap) UnmarshalYAML(value *yaml.Node) error
• type ContentEqualsCondition
  • func (c ContentEqualsCondition) Check(p types.Part) error
• type ContentMatchesCondition
  • func (c ContentMatchesCondition) Check(p types.Part) error
• type Definition
  • func ExampleDefinition() Definition
  • func (d Definition) Execute(filepath string) ([]CaseFailure, error)
• type InputPart
• type MetadataEqualsCondition
  • func (m MetadataEqualsCondition) Check(p types.Part) error
• type ProcProvider
• type ProcessorsProvider
  • func NewProcessorsProvider(targetPath string) *ProcessorsProvider
  • func (p *ProcessorsProvider) Provide(jsonPtr string, environment map[string]string) ([]types.Processor, error)

Functions

func Generate

func Generate(path, testSuffix string) error

Generate executes the generate-tests command for a specified path. The path can either be a config file, a directory, or the special pattern './...'.

func Run

func Run(path, testSuffix string, lint bool) bool

Run executes the test command for a specified path. The path can either be a config file, a config files test definition file, a directory, or the wildcard pattern './...'.

Types

type Case

type Case struct {
	Name             string            `yaml:"name"`
	Environment      map[string]string `yaml:"environment"`
	TargetProcessors string            `yaml:"target_processors"`
	InputBatch       []InputPart       `yaml:"input_batch"`
	OutputBatches    [][]ConditionsMap `yaml:"output_batches"`
	// contains filtered or unexported fields
}

Case contains a definition of a single Benthos config test case.

func NewCase

func NewCase() Case

NewCase returns a default test case.

func (*Case) Execute

func (c *Case) Execute(provider ProcProvider) (failures []CaseFailure, err error)

Execute attempts to execute a test case against a Benthos configuration.

func (*Case) UnmarshalYAML

func (c *Case) UnmarshalYAML(value *yaml.Node) error

UnmarshalYAML extracts a Case from a YAML node.

type CaseFailure

type CaseFailure struct {
	Name     string
	TestLine int
	Reason   string
}

CaseFailure encapsulates information about a failed test case.

func (CaseFailure) String

func (c CaseFailure) String() string

String returns a string representation of the case failure.

type Condition

type Condition interface {
	Check(part types.Part) error
}

Condition is a test case against a message part.

type ConditionsMap

type ConditionsMap map[string]Condition

ConditionsMap contains a map of conditions to condition string types.

func (ConditionsMap) CheckAll

func (c ConditionsMap) CheckAll(part types.Part) (errs []error)

CheckAll checks all conditions against a message part. Conditions are executed in alphabetical order.

func (*ConditionsMap) UnmarshalYAML

func (c *ConditionsMap) UnmarshalYAML(value *yaml.Node) error

UnmarshalYAML extracts a ConditionsMap from a YAML node.

type ContentEqualsCondition

type ContentEqualsCondition string

ContentEqualsCondition is a string condition that tests the string against the contents of a message.

func (ContentEqualsCondition) Check

func (c ContentEqualsCondition) Check(p types.Part) error

Check this condition against a message part.

type ContentMatchesCondition

type ContentMatchesCondition string

ContentMatchesCondition is a string condition that tests parses the string as a regular expression and tests that regular expression against the contents of a message.

func (ContentMatchesCondition) Check

func (c ContentMatchesCondition) Check(p types.Part) error

Check this condition against a message part.

type Definition

type Definition struct {
	Parallel bool   `yaml:"parallel"`
	Cases    []Case `yaml:"tests"`
}

Definition of a group of tests for a Benthos config file.

func ExampleDefinition

func ExampleDefinition() Definition

ExampleDefinition returns a Definition containing an example case.

func (Definition) Execute

func (d Definition) Execute(filepath string) ([]CaseFailure, error)

Execute attempts to run a test definition on a target config file. Returns an array of test failures or an error.

type InputPart

type InputPart struct {
	Content  string            `yaml:"content"`
	Metadata map[string]string `yaml:"metadata"`
}

InputPart defines an input part for a test case.

type MetadataEqualsCondition

type MetadataEqualsCondition map[string]string

MetadataEqualsCondition checks whether a metadata keys contents matches a value.

func (MetadataEqualsCondition) Check

func (m MetadataEqualsCondition) Check(p types.Part) error

Check this condition against a message part.

type ProcProvider

type ProcProvider interface {
	Provide(jsonPtr string, environment map[string]string) ([]types.Processor, error)
}

ProcProvider returns compiled processors extracted from a Benthos config using a JSON Pointer.

type ProcessorsProvider

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

ProcessorsProvider consumes a Benthos config and, given a JSON Pointer, extracts and constructs the target processors from the config file.

func NewProcessorsProvider

func NewProcessorsProvider(targetPath string) *ProcessorsProvider

NewProcessorsProvider returns a new processors provider aimed at a filepath.

func (*ProcessorsProvider) Provide

func (p *ProcessorsProvider) Provide(jsonPtr string, environment map[string]string) ([]types.Processor, error)

Provide attempts to extract an array of processors from a Benthos config. If the JSON Pointer targets a single processor config it will be constructed and returned as an array of one element.