steps

Mar 29, 2023

Changes in this version

+ const WaitEventTimeout

+ var BuildTime = "1625046891"

+ var GitCommit = "7434fe334d9f51b7239f978094ea29d10ac33b16"

+ var Version = ""

type Component

+ DatasetAPI *httpfake.HTTPFake

+ Zebedee *httpfake.HTTPFake

+ func (c *Component) GetKafkaConsumer(ctx context.Context, cfg *config.Kafka) (kafka.IConsumerGroup, error)

+ func (c *Component) GetKafkaProducer(ctx context.Context, cfg *config.Kafka) (kafka.IProducer, error)

Jan 18, 2022

Changes in this version

type Component

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

Jan 6, 2022

Changes in this version

type Component

+ ErrorFeature componenttest.ErrorFeature

+ KafkaProducer kafka.IProducer

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

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

May 24, 2021

Changes in this version

+ type Component struct

+ KafkaConsumer kafka.IConsumerGroup

+ func NewComponent() *Component

+ func (c *Component) Close()

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

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

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

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

+ func (c *Component) Reset()