benchmark

Documentation

Index

• type KafkaBenchmark
  • func NewKafkaBenchmark(urls []string, topic string, payloadSize uint) *KafkaBenchmark
  • func (k *KafkaBenchmark) Errors() uint
  • func (k *KafkaBenchmark) Recv() <-chan []byte
  • func (k *KafkaBenchmark) Send() error
  • func (k *KafkaBenchmark) SendDone() <-chan bool
  • func (k *KafkaBenchmark) Setup(consumer bool, numMsgs uint) error
• type NATSBenchmark
  • func NewNATSBenchmark(url, subject string, payloadSize uint) *NATSBenchmark
  • func (n *NATSBenchmark) Errors() uint
  • func (n *NATSBenchmark) Recv() <-chan []byte
  • func (n *NATSBenchmark) Send() error
  • func (n *NATSBenchmark) SendDone() <-chan bool
  • func (n *NATSBenchmark) Setup(consumer bool, numMsgs uint) error

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

func (*KafkaBenchmark) Setup

func (k *KafkaBenchmark) Setup(consumer bool, numMsgs uint) error

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

func (*NATSBenchmark) Setup

func (n *NATSBenchmark) Setup(consumer bool, numMsgs uint) error