steps

package
v1.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 15, 2023 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ComponentTestGroup    = "component-test" // kafka group name for the component test consumer
	DrainTopicTimeout     = 5 * time.Second  // maximum time to wait for a topic to be drained
	DrainTopicMaxMessages = 1000             // maximum number of messages that will be drained from a topic
	MinioCheckRetries     = 3                // maximum number of retires to validate that a file is present in minio
	WaitEventTimeout      = 15 * time.Second // maximum time that the component test consumer will wait for a kafka event
)

Variables

View Source
var (
	BuildTime = "1625046891"
	GitCommit = "7434fe334d9f51b7239f978094ea29d10ac33b16"
	Version   = ""
)

Functions

This section is empty.

Types

type Component

type Component struct {
	componenttest.ErrorFeature
	DatasetAPI       *httpfake.HTTPFake
	FilterAPI        *httpfake.HTTPFake
	CantabularSrv    *httpfake.HTTPFake
	CantabularAPIExt *httpfake.HTTPFake
	S3Downloader     *s3manager.Downloader
	// contains filtered or unexported fields
}

func NewComponent

func NewComponent(t *testing.T) *Component

func (*Component) Close

func (c *Component) Close()

Close kills the application under test, and then it shuts down the testing consumer and producer.

func (*Component) RegisterSteps

func (c *Component) RegisterSteps(ctx *godog.ScenarioContext)

RegisterSteps maps the human-readable regular expressions to their corresponding funcs

func (*Component) Reset

func (c *Component) Reset() error

Reset re-initialises the service under test and the api mocks. Note that the service under test should not be started yet to prevent race conditions if it tries to call un-initialised dependencies (steps)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL