steps

Oct 16, 2022

Changes in this version

type SearchReindexAPIFeature

+ func (f *SearchReindexAPIFeature) PutNumberOfDocs(version, id, taskName, countStr string) error

May 4, 2022

Changes in this version

+ type FakeAPI struct

+ func NewFakeSearchAPI() *FakeAPI

+ func (f *FakeAPI) Close()

+ func (f *FakeAPI) Reset()

+ func (f *FakeAPI) Restart()

Apr 28, 2022

Changes in this version

+ func DoGetKafkaProducerChecker(ctx context.Context, state *healthcheck.CheckState) error

+ type SearchReindexAPIFeature struct

+ APIFeature *componentTest.APIFeature

+ AuthFeature *componentTest.AuthorizationFeature

+ Config *config.Config

+ ErrorFeature componentTest.ErrorFeature

+ HTTPServer *http.Server

+ KafkaMessageProducer kafka.IProducer

+ KafkaProducer service.KafkaProducer

+ MongoClient *mongo.JobStore

+ MongoFeature *componentTest.MongoFeature

+ SearchFeature *SearchFeature

+ ServiceRunning bool

+ func NewSearchReindexAPIFeature(mongoFeature *componentTest.MongoFeature, ...) (*SearchReindexAPIFeature, error)

+ func (f *SearchReindexAPIFeature) CallGetJobByID(id string) error

+ func (f *SearchReindexAPIFeature) Close() error

+ func (f *SearchReindexAPIFeature) DoGetAuthorisationHandlers(ctx context.Context, cfg *config.Config) api.AuthHandler

+ func (f *SearchReindexAPIFeature) DoGetHTTPServer(bindAddr string, router http.Handler) service.HTTPServer

+ func (f *SearchReindexAPIFeature) DoGetHealthcheckOk(cfg *config.Config, curTime, commit, version string) (service.HealthChecker, error)

+ func (f *SearchReindexAPIFeature) DoGetKafkaProducer(ctx context.Context, cfg *config.Config) (service.KafkaProducer, error)

+ func (f *SearchReindexAPIFeature) DoGetMongoDB(ctx context.Context, cfg *config.Config) (service.MongoDataStorer, error)

+ func (f *SearchReindexAPIFeature) GetTaskForJob(jobID, taskName string) error

+ func (f *SearchReindexAPIFeature) InitAPIFeature() *componentTest.APIFeature

+ func (f *SearchReindexAPIFeature) InitialiseService() (http.Handler, error)

+ func (f *SearchReindexAPIFeature) PostTaskForJob(jobID string, requestBody *godog.DocString) error

+ func (f *SearchReindexAPIFeature) PutNumberOfTasks(countStr string) error

+ func (f *SearchReindexAPIFeature) RegisterSteps(ctx *godog.ScenarioContext)

+ func (f *SearchReindexAPIFeature) Reset(mongoFail bool) error

Jan 25, 2022

Changes in this version

type JobsFeature

+ KafkaProducer service.KafkaProducer

+ MessageProducer kafka.IProducer

+ func (f *JobsFeature) DoGetKafkaProducer(ctx context.Context, cfg *config.Config) (service.KafkaProducer, error)

Dec 24, 2021

Changes in this version

+ type ErrorFeature struct

+ func (t *ErrorFeature) Errorf(format string, args ...interface{})

+ func (t *ErrorFeature) Helper()

+ func (t *ErrorFeature) Log(args ...interface{})

+ func (t *ErrorFeature) Logf(format string, args ...interface{})

+ func (t *ErrorFeature) Name() string

+ func (t *ErrorFeature) StepError() error

type JobsFeature

+ APIFeature *componentTest.APIFeature

+ SearchFeature *SearchFeature

+ type SearchFeature struct

+ FakeSearchAPI *httpfake.HTTPFake

+ func NewSearchFeature() *SearchFeature

+ func (f *SearchFeature) Close()

+ func (f *SearchFeature) RegisterSteps(ctx *godog.ScenarioContext)

+ func (f *SearchFeature) Reset()

Oct 7, 2021

Changes in this version

type JobsFeature

+ func (f *JobsFeature) GetTaskForJob(jobID string, taskName string) error

Sep 27, 2021

Changes in this version

type JobsFeature

+ AuthFeature *componentTest.AuthorizationFeature

+ func (f *JobsFeature) DoGetAuthorisationHandlers(ctx context.Context, cfg *config.Config) api.AuthHandler

+ func (f *JobsFeature) IAmAuthorised() error

+ func (f *JobsFeature) PostTaskForJob(jobID string, requestBody *godog.DocString) error

Jul 26, 2021

Changes in this version

type JobsFeature

+ func (f *JobsFeature) GetJobByID(id string) error

+ func (f *JobsFeature) PutNumberOfTasks(countStr string) error

Jun 30, 2021

Changes in this version

type JobsFeature

+ MongoClient *mongo.JobStore

+ MongoFeature *componentTest.MongoFeature

+ func (f *JobsFeature) DoGetMongoDB(ctx context.Context, cfg *config.Config) (service.MongoJobStorer, error)

Apr 19, 2021

Changes in this version

+ type JobsFeature struct

+ ApiFeature *componenttest.APIFeature

+ Config *config.Config

+ ErrorFeature componenttest.ErrorFeature

+ HTTPServer *http.Server

+ ServiceRunning bool

+ func NewJobsFeature() (*JobsFeature, error)

+ func (f *JobsFeature) Close() error

+ func (f *JobsFeature) DoGetHTTPServer(bindAddr string, router http.Handler) service.HTTPServer

+ func (f *JobsFeature) DoGetHealthcheckOk(cfg *config.Config, time string, commit string, version string) (service.HealthChecker, error)

+ func (f *JobsFeature) InitAPIFeature() *componenttest.APIFeature

+ func (f *JobsFeature) InitialiseService() (http.Handler, error)

+ func (f *JobsFeature) RegisterSteps(ctx *godog.ScenarioContext)

+ func (f *JobsFeature) Reset() *JobsFeature