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 = 5 // 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 {
cmptest.ErrorFeature
DatasetAPI *httpfake.HTTPFake
FilterAPI *httpfake.HTTPFake
S3Downloader *s3manager.Downloader
// contains filtered or unexported fields
}
func NewComponent ¶
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)
Source Files
Click to show internal directories.
Click to hide internal directories.