requester

Documentation

Index

• type AMQPRequesterFactory
  • func (r *AMQPRequesterFactory) GetRequester(num uint64) bench.Requester
• type CassandraRequesterFactory
  • func (c *CassandraRequesterFactory) GetRequester(uint64) bench.Requester
• type KafkaRequesterFactory
  • func (k *KafkaRequesterFactory) GetRequester(num uint64) bench.Requester
• type NATSRequesterFactory
  • func (n *NATSRequesterFactory) GetRequester(num uint64) bench.Requester
• type NATSStreamingRequesterFactory
  • func (n *NATSStreamingRequesterFactory) GetRequester(num uint64) bench.Requester
• type NOOPRequesterFactory
  • func (n *NOOPRequesterFactory) GetRequester(num uint64) bench.Requester
• type NSQRequesterFactory
  • func (n *NSQRequesterFactory) GetRequester(num uint64) bench.Requester
• type PulsarRequester
  • func (n *PulsarRequester) Request() error
  • func (n *PulsarRequester) Setup() error
  • func (n *PulsarRequester) Teardown() error
• type PulsarRequesterFactory
  • func (n *PulsarRequesterFactory) GetRequester(num uint64) bench.Requester
• type RedisPubSubRequesterFactory
  • func (r *RedisPubSubRequesterFactory) GetRequester(num uint64) bench.Requester
• type RedisRequesterFactory
  • func (r *RedisRequesterFactory) GetRequester(uint64) bench.Requester
• type WebRequesterFactory
  • func (w *WebRequesterFactory) GetRequester(uint64) bench.Requester

Types

type AMQPRequesterFactory

type AMQPRequesterFactory struct {
	URL         string
	PayloadSize int
	Queue       string
	Exchange    string
}

AMQPRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to an AMQP exchange and waits to consume them.

func (*AMQPRequesterFactory) GetRequester

func (r *AMQPRequesterFactory) GetRequester(num uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.

type CassandraRequesterFactory

type CassandraRequesterFactory struct {
	URLs        []string
	Keyspace    string
	Consistency gocql.Consistency
	Statement   string
	Values      []interface{}
}

CassandraRequesterFactory implements RequesterFactory by creating a Requester which issues queries to Cassandra. Works with Cassandra 2.x.x.

func (*CassandraRequesterFactory) GetRequester

func (c *CassandraRequesterFactory) GetRequester(uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.

type KafkaRequesterFactory

type KafkaRequesterFactory struct {
	URLs        []string
	PayloadSize int
	Topic       string
}

KafkaRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to Kafka and waits to consume them.

func (*KafkaRequesterFactory) GetRequester

func (k *KafkaRequesterFactory) GetRequester(num uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.

type NATSRequesterFactory

type NATSRequesterFactory struct {
	URL         string
	PayloadSize int
	Subject     string
}

NATSRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to NATS and waits to receive them.

func (*NATSRequesterFactory) GetRequester

func (n *NATSRequesterFactory) GetRequester(num uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.

type NATSStreamingRequesterFactory

type NATSStreamingRequesterFactory struct {
	PayloadSize int
	Subject     string
	ClientID    string
	ClusterID   string
	URL         string
}

NATSStreamingRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to NATS Streaming and waits to receive them.

func (*NATSStreamingRequesterFactory) GetRequester

func (n *NATSStreamingRequesterFactory) GetRequester(num uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.

type NOOPRequesterFactory

type NOOPRequesterFactory struct {
}

func (*NOOPRequesterFactory) GetRequester

func (n *NOOPRequesterFactory) GetRequester(num uint64) bench.Requester

type NSQRequesterFactory

type NSQRequesterFactory struct {
	URL         string
	PayloadSize int
	Topic       string
}

NSQRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to NSQ and waits to receive them.

func (*NSQRequesterFactory) GetRequester

func (n *NSQRequesterFactory) GetRequester(num uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.

type PulsarRequester

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

PulsarRequester implements Requester by publishing a message to Pulsar and waiting to receive it.

func (*PulsarRequester) Request

func (n *PulsarRequester) Request() error

Request performs a synchronous request to the system under test.

func (*PulsarRequester) Setup

func (n *PulsarRequester) Setup() error

Setup prepares the Requester for benchmarking.

func (*PulsarRequester) Teardown

func (n *PulsarRequester) Teardown() error

Teardown is called upon benchmark completion.

type PulsarRequesterFactory

type PulsarRequesterFactory struct {
	URL         string
	PayloadSize int
	Topic       string
}

PulsarRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to Pulsar and waits to receive them.

func (*PulsarRequesterFactory) GetRequester

func (n *PulsarRequesterFactory) GetRequester(num uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.

type RedisPubSubRequesterFactory

type RedisPubSubRequesterFactory struct {
	URL         string
	PayloadSize int
	Channel     string
}

RedisPubSubRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to Redis and waits to receive them.

func (*RedisPubSubRequesterFactory) GetRequester

func (r *RedisPubSubRequesterFactory) GetRequester(num uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.

type RedisRequesterFactory

type RedisRequesterFactory struct {
	URL     string
	Command string
	Args    []interface{}
}

RedisRequesterFactory implements RequesterFactory by creating a Requester which sends the configured command and arguments to Redis and waits for the reply.

func (*RedisRequesterFactory) GetRequester

func (r *RedisRequesterFactory) GetRequester(uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.

type WebRequesterFactory

type WebRequesterFactory struct {
	URL string
}

WebRequesterFactory implements RequesterFactory by creating a Requester which makes GET requests to the provided URL.

func (*WebRequesterFactory) GetRequester

func (w *WebRequesterFactory) GetRequester(uint64) bench.Requester

GetRequester returns a new Requester, called for each Benchmark connection.