steps

package
v0.22.2 Latest Latest
Warning

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

Go to latest
Published: Nov 10, 2022 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Component

type Component struct {
	ErrorFeature componenttest.ErrorFeature

	KafkaConsumer kafka.IConsumerGroup
	KafkaProducer kafka.IProducer
	// contains filtered or unexported fields
}

func NewComponent

func NewComponent() *Component

func (*Component) DoGetConsumer

func (c *Component) DoGetConsumer(ctx context.Context, cfg *config.Config) (kafkaConsumer kafka.IConsumerGroup, err error)

func (*Component) DoGetDatasetClient added in v0.7.0

func (c *Component) DoGetDatasetClient(cfg *config.Config) clients.DatasetClient

func (*Component) DoGetHTTPServer

func (c *Component) DoGetHTTPServer(bindAddr string, router http.Handler) service.HTTPServer

func (*Component) DoGetHealthCheck

func (c *Component) DoGetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (service.HealthChecker, error)

func (*Component) DoGetProducer added in v0.6.0

func (c *Component) DoGetProducer(ctx context.Context, cfg *config.Config) (kafkaConsumer kafka.IProducer, err error)

func (*Component) DoGetZebedeeClient added in v0.6.0

func (c *Component) DoGetZebedeeClient(cfg *config.Config) clients.ZebedeeClient

func (*Component) RegisterSteps

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

Jump to

Keyboard shortcuts

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