scenarioType

Documentation

Index

• type GraphQLTypeProvider
  • func NewGraphQLTypeProvider(w http.ResponseWriter, req *http.Request) *GraphQLTypeProvider
  • func (g *GraphQLTypeProvider) Retrieve(scenarioNumber int)
  • func (g *GraphQLTypeProvider) Unmarshal(rawScenarios []map[string]interface{}) error
• type HTTPTypeProvider
  • func NewHTTPTypeProvider(w http.ResponseWriter) *HTTPTypeProvider
  • func (hp *HTTPTypeProvider) Retrieve(scenarioNumber int)
  • func (hp *HTTPTypeProvider) Unmarshal(rawScenarios []map[string]interface{}) error
  • func (hp HTTPTypeProvider) Validate() error
• type KafkaProvider
  • func NewKafkaProvider(w http.ResponseWriter, lgr *logrus.Entry) *KafkaProvider
  • func (k *KafkaProvider) Retrieve(scenarioNumber int)
  • func (k *KafkaProvider) Unmarshal(rawScenarios []map[string]interface{}) error
  • func (k KafkaProvider) Validate() error
• type TypeProvider
  • func Factory(scenarioType string, w http.ResponseWriter, req *http.Request, ...) (TypeProvider, error)

Types

type GraphQLTypeProvider

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

GraphQLTypeProvider

func NewGraphQLTypeProvider

func NewGraphQLTypeProvider(w http.ResponseWriter, req *http.Request) *GraphQLTypeProvider

NewGraphQLTypeProvider

func (*GraphQLTypeProvider) Retrieve

func (g *GraphQLTypeProvider) Retrieve(scenarioNumber int)

func (*GraphQLTypeProvider) Unmarshal

func (g *GraphQLTypeProvider) Unmarshal(rawScenarios []map[string]interface{}) error

type HTTPTypeProvider

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

HTTPTypeProvider

func NewHTTPTypeProvider

func NewHTTPTypeProvider(w http.ResponseWriter) *HTTPTypeProvider

NewHTTPTypeProvider

func (*HTTPTypeProvider) Retrieve

func (hp *HTTPTypeProvider) Retrieve(scenarioNumber int)

Retrieve

func (*HTTPTypeProvider) Unmarshal

func (hp *HTTPTypeProvider) Unmarshal(rawScenarios []map[string]interface{}) error

func (HTTPTypeProvider) Validate

func (hp HTTPTypeProvider) Validate() error

Validate

type KafkaProvider

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

func NewKafkaProvider

func NewKafkaProvider(w http.ResponseWriter, lgr *logrus.Entry) *KafkaProvider

func (*KafkaProvider) Retrieve

func (k *KafkaProvider) Retrieve(scenarioNumber int)

Retrieve is a main function to run a scenario

func (*KafkaProvider) Unmarshal

func (k *KafkaProvider) Unmarshal(rawScenarios []map[string]interface{}) error

func (KafkaProvider) Validate

func (k KafkaProvider) Validate() error

type TypeProvider

type TypeProvider interface {
	// Unmarshal
	Unmarshal([]map[string]interface{}) error
	Retrieve(scenarioNumber int)
	validation.Validatable
}

TypeProvider

func Factory

func Factory(
	scenarioType string,
	w http.ResponseWriter,
	req *http.Request,
	lgr *logrus.Entry,
) (TypeProvider, error)