Documentation
¶
Index ¶
- type ImporterFeature
- func (f *ImporterFeature) Close()
- func (f *ImporterFeature) DoGetConsumer(ctx context.Context, topic, group string, cfg *config.KafkaConfig) (kafkaConsumer kafka.IConsumerGroup, err error)
- func (f *ImporterFeature) DoGetGraphDB(ctx context.Context) (*graph.DB, error)
- func (f *ImporterFeature) DoGetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (healthcheck.HealthCheck, error)
- func (f *ImporterFeature) DoGetImportErrorReporter(observationsImportedErrProducer reporter.KafkaProducer, serviceName string) (errorReporter reporter.ImportErrorReporter, err error)
- func (f *ImporterFeature) DoGetProducer(ctx context.Context, topic string, cfg *config.KafkaConfig) (kafkaProducer kafka.IProducer, err error)
- func (f *ImporterFeature) RegisterSteps(ctx *godog.ScenarioContext)
- func (f *ImporterFeature) Reset()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ImporterFeature ¶
type ImporterFeature struct {
ErrorFeature componenttest.ErrorFeature
KafkaConsumer kafka.IConsumerGroup
KafkaProducer kafka.IProducer
FakeDatasetAPI *httpfake.HTTPFake
ObservationDB *mock.ObservationMock
// contains filtered or unexported fields
}
func NewObservationImporterFeature ¶
func NewObservationImporterFeature() *ImporterFeature
func (*ImporterFeature) Close ¶
func (f *ImporterFeature) Close()
func (*ImporterFeature) DoGetConsumer ¶
func (f *ImporterFeature) DoGetConsumer(ctx context.Context, topic, group string, cfg *config.KafkaConfig) (kafkaConsumer kafka.IConsumerGroup, err error)
func (*ImporterFeature) DoGetGraphDB ¶
func (*ImporterFeature) DoGetHealthCheck ¶
func (f *ImporterFeature) DoGetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (healthcheck.HealthCheck, error)
func (*ImporterFeature) DoGetImportErrorReporter ¶
func (f *ImporterFeature) DoGetImportErrorReporter(observationsImportedErrProducer reporter.KafkaProducer, serviceName string) (errorReporter reporter.ImportErrorReporter, err error)
func (*ImporterFeature) DoGetProducer ¶
func (f *ImporterFeature) DoGetProducer(ctx context.Context, topic string, cfg *config.KafkaConfig) (kafkaProducer kafka.IProducer, err error)
func (*ImporterFeature) RegisterSteps ¶
func (f *ImporterFeature) RegisterSteps(ctx *godog.ScenarioContext)
func (*ImporterFeature) Reset ¶
func (f *ImporterFeature) Reset()
Source Files
Click to show internal directories.
Click to hide internal directories.