steps

Documentation

Index

• func WellKnownTestTime() time.Time
• type DatasetComponent
  • func NewDatasetComponent(mongoURI, zebedeeURL string) (*DatasetComponent, error)
  • func (c *DatasetComponent) Close() error
  • func (c *DatasetComponent) DoGetGraphDBOk(_ context.Context) (store.GraphDB, service.Closer, error)
  • func (c *DatasetComponent) DoGetHTTPServer(bindAddr string, router http.Handler) service.HTTPServer
  • func (c *DatasetComponent) DoGetHealthcheckOk(_ *config.Configuration, _, _, _ string) (service.HealthChecker, error)
  • func (c *DatasetComponent) DoGetKafkaProducer(ctx context.Context, cfg *config.Configuration, topic string) (kafka.IProducer, error)
  • func (c *DatasetComponent) DoGetMockedKafkaProducerOk(_ context.Context, _ *config.Configuration, _ string) (kafka.IProducer, error)
  • func (c *DatasetComponent) DoGetMongoDB(_ context.Context, _ config.MongoConfig) (store.MongoDB, error)
  • func (c *DatasetComponent) InitialiseService() (http.Handler, error)
  • func (c *DatasetComponent) RegisterSteps(ctx *godog.ScenarioContext)
  • func (c *DatasetComponent) Reset() error

Functions

func WellKnownTestTime

func WellKnownTestTime() time.Time

Types

type DatasetComponent

type DatasetComponent struct {
	ErrorFeature componenttest.ErrorFeature

	MongoClient    *mongo.Mongo
	Config         *config.Configuration
	HTTPServer     *http.Server
	ServiceRunning bool
	// contains filtered or unexported fields
}

func NewDatasetComponent

func NewDatasetComponent(mongoURI, zebedeeURL string) (*DatasetComponent, error)

func (*DatasetComponent) Close

func (c *DatasetComponent) Close() error

func (*DatasetComponent) DoGetGraphDBOk

func (c *DatasetComponent) DoGetGraphDBOk(_ context.Context) (store.GraphDB, service.Closer, error)

func (*DatasetComponent) DoGetHTTPServer

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

func (*DatasetComponent) DoGetHealthcheckOk

func (c *DatasetComponent) DoGetHealthcheckOk(_ *config.Configuration, _, _, _ string) (service.HealthChecker, error)

func (*DatasetComponent) DoGetKafkaProducer

func (c *DatasetComponent) DoGetKafkaProducer(ctx context.Context, cfg *config.Configuration, topic string) (kafka.IProducer, error)

func (*DatasetComponent) DoGetMockedKafkaProducerOk

func (c *DatasetComponent) DoGetMockedKafkaProducerOk(_ context.Context, _ *config.Configuration, _ string) (kafka.IProducer, error)

func (*DatasetComponent) DoGetMongoDB

func (c *DatasetComponent) DoGetMongoDB(_ context.Context, _ config.MongoConfig) (store.MongoDB, error)

func (*DatasetComponent) InitialiseService

func (c *DatasetComponent) InitialiseService() (http.Handler, error)

func (*DatasetComponent) RegisterSteps

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

func (*DatasetComponent) Reset

func (c *DatasetComponent) Reset() error