Documentation
¶
Index ¶
- type DatasetComponent
- func (f *DatasetComponent) Close() error
- func (f *DatasetComponent) DoGetGraphDBOk(ctx context.Context) (store.GraphDB, service.Closer, error)
- func (f *DatasetComponent) DoGetHTTPServer(bindAddr string, router http.Handler) service.HTTPServer
- func (f *DatasetComponent) DoGetHealthcheckOk(cfg *config.Configuration, buildTime string, gitCommit string, version string) (service.HealthChecker, error)
- func (f *DatasetComponent) DoGetKafkaProducerOk(ctx context.Context, cfg *config.Configuration, topic string) (kafka.IProducer, error)
- func (f *DatasetComponent) DoGetMongoDB(ctx context.Context, cfg *config.Configuration) (store.MongoDB, error)
- func (f *DatasetComponent) InitialiseService() (http.Handler, error)
- func (f *DatasetComponent) RegisterSteps(ctx *godog.ScenarioContext)
- func (f *DatasetComponent) Reset() *DatasetComponent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DatasetComponent ¶ added in v1.29.0
type DatasetComponent struct {
ErrorFeature componenttest.ErrorFeature
MongoClient *mongo.Mongo
Config *config.Configuration
HTTPServer *http.Server
ServiceRunning bool
// contains filtered or unexported fields
}
func NewDatasetComponent ¶ added in v1.29.0
func NewDatasetComponent(mongoFeature *componenttest.MongoFeature, zebedeeURL string) (*DatasetComponent, error)
func (*DatasetComponent) Close ¶ added in v1.29.0
func (f *DatasetComponent) Close() error
func (*DatasetComponent) DoGetGraphDBOk ¶ added in v1.29.0
func (*DatasetComponent) DoGetHTTPServer ¶ added in v1.29.0
func (f *DatasetComponent) DoGetHTTPServer(bindAddr string, router http.Handler) service.HTTPServer
func (*DatasetComponent) DoGetHealthcheckOk ¶ added in v1.29.0
func (f *DatasetComponent) DoGetHealthcheckOk(cfg *config.Configuration, buildTime string, gitCommit string, version string) (service.HealthChecker, error)
func (*DatasetComponent) DoGetKafkaProducerOk ¶ added in v1.29.0
func (f *DatasetComponent) DoGetKafkaProducerOk(ctx context.Context, cfg *config.Configuration, topic string) (kafka.IProducer, error)
func (*DatasetComponent) DoGetMongoDB ¶ added in v1.29.0
func (f *DatasetComponent) DoGetMongoDB(ctx context.Context, cfg *config.Configuration) (store.MongoDB, error)
DoGetMongoDB returns a MongoDB
func (*DatasetComponent) InitialiseService ¶ added in v1.29.0
func (f *DatasetComponent) InitialiseService() (http.Handler, error)
func (*DatasetComponent) RegisterSteps ¶ added in v1.29.0
func (f *DatasetComponent) RegisterSteps(ctx *godog.ScenarioContext)
func (*DatasetComponent) Reset ¶ added in v1.29.0
func (f *DatasetComponent) Reset() *DatasetComponent
Click to show internal directories.
Click to hide internal directories.