steps

Documentation

Index

• Constants
• Variables
• func GenerateKafkaConsumer(ctx context.Context) (*kafka.ConsumerGroup, error)
• type CantabularFeature
  • func NewCantabularFeature(t *testing.T, cfg *config.Config) *CantabularFeature
  • func (cf *CantabularFeature) RegisterSteps(ctx *godog.ScenarioContext)
  • func (cf *CantabularFeature) Reset()
• type Component
  • func NewComponent(t *testing.T) *Component
  • func (c *Component) Close()
  • func (c *Component) RegisterSteps(ctx *godog.ScenarioContext)
  • func (c *Component) Reset()
  • func (c *Component) Router() (http.Handler, error)
• type DatasetFeature
  • func NewDatasetFeature(t *testing.T, cfg *config.Config) *DatasetFeature
  • func (df *DatasetFeature) Close()
  • func (df *DatasetFeature) RegisterSteps(ctx *godog.ScenarioContext)
  • func (df *DatasetFeature) Reset()
• type MongoFeature
  • func NewMongoFeature(ef componenttest.ErrorFeature, g service.Generator, cfg *config.Config) *MongoFeature
  • func (mf *MongoFeature) Close()
  • func (mf *MongoFeature) MongoDatastoreFailsForUpdateFilterOutput()
  • func (mf *MongoFeature) MongoDatastoreIsFailing()
  • func (mf *MongoFeature) RegisterSteps(ctx *godog.ScenarioContext)
  • func (mf *MongoFeature) Reset()

Constants

const (
	ComponentTestGroup    = "test-consumer-group"
	DrainTopicTimeout     = 10 * time.Second // maximum time to wait for a topic to be drained
	DrainTopicMaxMessages = 1000             // maximum number of messages that will be drained from a topic
	WaitEventTimeout      = 10 * time.Second // maximum time that the component test consumer will wait for a
)

Variables

var (
	BuildTime = strconv.Itoa(time.Now().Nanosecond())
	GitCommit = "component test commit"
	Version   = "component test version"
)

Functions

func GenerateKafkaConsumer

func GenerateKafkaConsumer(ctx context.Context) (*kafka.ConsumerGroup, error)

GenerateKafkaConsumer produces a consumer for specific steps. Currently only for PUT filters/{id}/submit

Types

type CantabularFeature

type CantabularFeature struct {
	// contains filtered or unexported fields
}

func NewCantabularFeature

func NewCantabularFeature(t *testing.T, cfg *config.Config) *CantabularFeature

func (*CantabularFeature) RegisterSteps

func (cf *CantabularFeature) RegisterSteps(ctx *godog.ScenarioContext)

func (*CantabularFeature) Reset

func (cf *CantabularFeature) Reset()

type Component

type Component struct {
	componenttest.ErrorFeature
	AuthFeature       *componenttest.AuthorizationFeature
	APIFeature        *componenttest.APIFeature
	MongoFeature      *MongoFeature
	DatasetFeature    *DatasetFeature
	CantabularFeature *CantabularFeature
	// contains filtered or unexported fields
}

func NewComponent

func NewComponent(t *testing.T) *Component

func (*Component) Close

func (c *Component) Close()

func (*Component) RegisterSteps

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

func (*Component) Reset

func (c *Component) Reset()

Reset re-initialises the service under test and the api dependencies

func (*Component) Router

func (c *Component) Router() (http.Handler, error)

Router initialises the service, returning the service's (server) router for tests This delayed initialisation is needed to ensure that any changes to the router (or the service in general) as a result of test setup, are picked up

type DatasetFeature

type DatasetFeature struct {
	// contains filtered or unexported fields
}

func NewDatasetFeature

func NewDatasetFeature(t *testing.T, cfg *config.Config) *DatasetFeature

func (*DatasetFeature) Close

func (df *DatasetFeature) Close()

func (*DatasetFeature) RegisterSteps

func (df *DatasetFeature) RegisterSteps(ctx *godog.ScenarioContext)

func (*DatasetFeature) Reset

func (df *DatasetFeature) Reset()

type MongoFeature

type MongoFeature struct {
	componenttest.ErrorFeature
	*componenttest.MongoFeature
	// contains filtered or unexported fields
}

func NewMongoFeature

func NewMongoFeature(ef componenttest.ErrorFeature, g service.Generator, cfg *config.Config) *MongoFeature

func (*MongoFeature) Close

func (mf *MongoFeature) Close()

func (*MongoFeature) MongoDatastoreFailsForUpdateFilterOutput

func (mf *MongoFeature) MongoDatastoreFailsForUpdateFilterOutput()

func (*MongoFeature) MongoDatastoreIsFailing

func (mf *MongoFeature) MongoDatastoreIsFailing()

func (*MongoFeature) RegisterSteps

func (mf *MongoFeature) RegisterSteps(ctx *godog.ScenarioContext)

func (*MongoFeature) Reset

func (mf *MongoFeature) Reset()