steps

Documentation

Index

• type TopicComponent
  • func NewTopicComponent(mongoFeature *componenttest.MongoFeature, zebedeeURL string) (*TopicComponent, error)
  • func (f *TopicComponent) Close() error
  • func (f *TopicComponent) DoGetHTTPServer(bindAddr string, router http.Handler) service.HTTPServer
  • func (f *TopicComponent) DoGetHealthcheckOk(cfg *config.Config, buildTime string, gitCommit string, version string) (service.HealthChecker, error)
  • func (f *TopicComponent) DoGetMongoDB(ctx context.Context, cfg *config.Config) (store.MongoDB, error)
  • func (f *TopicComponent) InitialiseService() (http.Handler, error)
  • func (f *TopicComponent) RegisterSteps(ctx *godog.ScenarioContext)
  • func (f *TopicComponent) Reset() *TopicComponent

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(mongoFeature *componenttest.MongoFeature, 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(cfg *config.Config, buildTime string, gitCommit string, version string) (service.HealthChecker, error)

func (*TopicComponent) DoGetMongoDB

func (f *TopicComponent) DoGetMongoDB(ctx context.Context, cfg *config.Config) (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)

func (*TopicComponent) Reset

func (f *TopicComponent) Reset() *TopicComponent