Documentation
¶
Index ¶
- type TopicComponent
- func (f *TopicComponent) Close() error
- func (f *TopicComponent) DoGetHTTPServer(bindAddr string, router http.Handler) service.HTTPServer
- func (f *TopicComponent) DoGetHealthcheckOk(_ *config.Config, _, _, _ string) (service.HealthChecker, error)
- func (f *TopicComponent) DoGetMongoDB(_ context.Context, _ config.MongoConfig) (store.MongoDB, error)
- func (f *TopicComponent) InitialiseService() (http.Handler, error)
- func (f *TopicComponent) RegisterSteps(ctx *godog.ScenarioContext)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TopicComponent ¶
type TopicComponent struct {
ErrorFeature componenttest.ErrorFeature
MongoClient *mongo.Mongo
Config *config.Config
HTTPServer *http.Server
ServiceRunning bool
// contains filtered or unexported fields
}
func NewTopicComponent ¶
func NewTopicComponent(mongoURL, zebedeeURL string) (*TopicComponent, error)
func (*TopicComponent) Close ¶
func (f *TopicComponent) Close() error
func (*TopicComponent) DoGetHTTPServer ¶
func (f *TopicComponent) DoGetHTTPServer(bindAddr string, router http.Handler) service.HTTPServer
func (*TopicComponent) DoGetHealthcheckOk ¶
func (f *TopicComponent) DoGetHealthcheckOk(_ *config.Config, _, _, _ string) (service.HealthChecker, error)
func (*TopicComponent) DoGetMongoDB ¶
func (f *TopicComponent) DoGetMongoDB(_ context.Context, _ config.MongoConfig) (store.MongoDB, error)
DoGetMongoDB returns a MongoDB
func (*TopicComponent) InitialiseService ¶
func (f *TopicComponent) InitialiseService() (http.Handler, error)
func (*TopicComponent) RegisterSteps ¶
func (f *TopicComponent) RegisterSteps(ctx *godog.ScenarioContext)
Source Files
Click to show internal directories.
Click to hide internal directories.