requester

package
v0.0.0-...-11bbf28 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 21, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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
	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 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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL