Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaBenchmark ¶
type KafkaBenchmark struct {
// contains filtered or unexported fields
}
func NewKafkaBenchmark ¶
func NewKafkaBenchmark(urls []string, topic string, payloadSize uint) *KafkaBenchmark
func (*KafkaBenchmark) Errors ¶
func (k *KafkaBenchmark) Errors() uint
func (*KafkaBenchmark) Recv ¶
func (k *KafkaBenchmark) Recv() <-chan []byte
func (*KafkaBenchmark) Send ¶
func (k *KafkaBenchmark) Send() error
func (*KafkaBenchmark) SendDone ¶
func (k *KafkaBenchmark) SendDone() <-chan bool
type NATSBenchmark ¶
type NATSBenchmark struct {
// contains filtered or unexported fields
}
func NewNATSBenchmark ¶
func NewNATSBenchmark(url, subject string, payloadSize uint) *NATSBenchmark
func (*NATSBenchmark) Errors ¶
func (n *NATSBenchmark) Errors() uint
func (*NATSBenchmark) Recv ¶
func (n *NATSBenchmark) Recv() <-chan []byte
func (*NATSBenchmark) Send ¶
func (n *NATSBenchmark) Send() error
func (*NATSBenchmark) SendDone ¶
func (n *NATSBenchmark) SendDone() <-chan bool
Source Files
Click to show internal directories.
Click to hide internal directories.