steps

Documentation

Index

• type Component
  • func NewComponent() *Component
  • 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, gitCommit, version string) (service.HealthChecker, error)
  • func (c *Component) DoGetProducer(ctx context.Context, cfg *config.Config) (kafkaConsumer kafka.IProducer, err error)
  • func (c *Component) DoGetZebedeeClient(cfg *config.Config) clients.ZebedeeClient
  • func (c *Component) RegisterSteps(ctx *godog.ScenarioContext)

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) 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

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

func (*Component) DoGetZebedeeClient

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

func (*Component) RegisterSteps

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