request

Documentation

Index

• type GRPCRequest
  • func (request GRPCRequest) Count() uint
  • func (request GRPCRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)
• type HTTPRequest
  • func (request HTTPRequest) Count() uint
  • func (request HTTPRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)
• type KafkaConsumeRequest
  • func (request KafkaConsumeRequest) Count() uint
  • func (request KafkaConsumeRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)
  • func (request KafkaConsumeRequest) SetConsumer(consumer *kafka.Consumer)
• type KafkaProduceRequest
  • func (request KafkaProduceRequest) Count() uint
  • func (request KafkaProduceRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)
• type Request
• type Requests
  • func CreateRequestsFromStringSlice(reqs []string, logger log.Logger) (Requests, error)
  • func (r *Requests) AddRequest(request HTTPRequest, logger log.Logger) error
• type TCPRequest
  • func (request TCPRequest) Count() uint
  • func (request TCPRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)

Types

type GRPCRequest

type GRPCRequest struct {
	Host    string `json:"host"`
	Service string `json:"service"`
	Method  string `json:"method"`
	// contains filtered or unexported fields
}

func (GRPCRequest) Count

func (request GRPCRequest) Count() uint

func (GRPCRequest) Do

func (request GRPCRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)

type HTTPRequest

type HTTPRequest struct {
	URL string `json:"URL"`
	// contains filtered or unexported fields
}

func (HTTPRequest) Count

func (request HTTPRequest) Count() uint

func (HTTPRequest) Do

func (request HTTPRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)

type KafkaConsumeRequest

type KafkaConsumeRequest struct {
	BootstrapServer string `json:"host"`
	Topic           string `json:"topic"`
	ConsumerGroup   string `json:"consumerGroup"`
	// contains filtered or unexported fields
}

func (KafkaConsumeRequest) Count

func (request KafkaConsumeRequest) Count() uint

func (KafkaConsumeRequest) Do

func (request KafkaConsumeRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)

func (KafkaConsumeRequest) SetConsumer

func (request KafkaConsumeRequest) SetConsumer(consumer *kafka.Consumer)

type KafkaProduceRequest

type KafkaProduceRequest struct {
	BootstrapServer string `json:"host"`
	Topic           string `json:"topic"`
	Message         string `json:"message"`
	// contains filtered or unexported fields
}

func (KafkaProduceRequest) Count

func (request KafkaProduceRequest) Count() uint

func (KafkaProduceRequest) Do

func (request KafkaProduceRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)

type Request

type Request interface {
	Do(incomingRequestHeaders http.Header, logger log.Logger)
	Count() uint
}

type Requests

type Requests []Request

func CreateRequestsFromStringSlice

func CreateRequestsFromStringSlice(reqs []string, logger log.Logger) (Requests, error)

func (*Requests) AddRequest

func (r *Requests) AddRequest(request HTTPRequest, logger log.Logger) error

type TCPRequest

type TCPRequest struct {
	Host        string `json:"host"`
	Port        int    `json:"port"`
	PayloadSize uint   `json:"payloadSize"`
}

func (TCPRequest) Count

func (request TCPRequest) Count() uint

func (TCPRequest) Do

func (request TCPRequest) Do(incomingRequestHeaders http.Header, logger log.Logger)