Documentation
¶
Index ¶
- type AMQPRequesterFactory
- type CassandraRequesterFactory
- type JetStreamRequesterFactory
- type KafkaRequesterFactory
- type LiftbridgeRequesterFactory
- type NATSRequesterFactory
- type NATSStreamingRequesterFactory
- type NOOPRequesterFactory
- type NSQRequesterFactory
- type RMQStreamRequesterFactory
- type RedisPubSubRequesterFactory
- type RedisRequesterFactory
- type WebRequesterFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPRequesterFactory ¶
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 JetStreamRequesterFactory ¶
type JetStreamRequesterFactory struct {
URL string
PayloadSize int
Stream string
AsyncPublish bool
MaxPublishAckPending int // wont' be used if async false
}
NATSRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to NATS and waits to receive them.
func (*JetStreamRequesterFactory) GetRequester ¶
func (j *JetStreamRequesterFactory) GetRequester(num uint64) bench.Requester
GetRequester returns a new Requester, called for each Benchmark connection.
type KafkaRequesterFactory ¶
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 LiftbridgeRequesterFactory ¶
type LiftbridgeRequesterFactory struct {
URLs []string
PayloadSize int
Stream string
AsyncPublish bool
}
AMQPRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to an AMQP exchange and waits to consume them.
func (*LiftbridgeRequesterFactory) GetRequester ¶
func (l *LiftbridgeRequesterFactory) GetRequester(num uint64) bench.Requester
GetRequester returns a new Requester, called for each Benchmark connection.
type NATSRequesterFactory ¶
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 ¶
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 RMQStreamRequesterFactory ¶
AMQPRequesterFactory implements RequesterFactory by creating a Requester which publishes messages to an AMQP exchange and waits to consume them.
func (*RMQStreamRequesterFactory) GetRequester ¶
func (r *RMQStreamRequesterFactory) GetRequester(num uint64) bench.Requester
GetRequester returns a new Requester, called for each Benchmark connection.
type RedisPubSubRequesterFactory ¶
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 ¶
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.
Source Files