Documentation
¶
Index ¶
- type Component
- func (c *Component) CleanFile(file string)
- func (c *Component) DoGetConsumer(ctx context.Context, kafkaCfg *config.KafkaConfig) (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) RegisterSteps(ctx *godog.ScenarioContext)
- func (c *Component) Reset()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Component ¶
type Component struct {
componenttest.ErrorFeature
KafkaConsumer kafka.IConsumerGroup
EsClient *es710.Client
EsIndex *godog.Table
S3UploadedSitemap map[string]string
// contains filtered or unexported fields
}
func NewComponent ¶
func NewComponent() *Component
func (*Component) DoGetConsumer ¶
func (c *Component) DoGetConsumer(ctx context.Context, kafkaCfg *config.KafkaConfig) (kafkaConsumer kafka.IConsumerGroup, err error)
func (*Component) DoGetHTTPServer ¶
func (*Component) DoGetHealthCheck ¶
func (*Component) RegisterSteps ¶
func (c *Component) RegisterSteps(ctx *godog.ScenarioContext)
Source Files
Click to show internal directories.
Click to hide internal directories.