steps

Documentation

Index

• type TopicComponent
  • func NewTopicComponent(mongoURL, zebedeeURL string) (*TopicComponent, error)
  • 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)

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)