util

Documentation

Index

• type Context
  • func NewContext(config *config.Config) *Context
  • func (context *Context) AppendConsumerRDiff(timestamp int64)
  • func (context *Context) AppendProducerSDiff(timestamp int64)
  • func (context *Context) CalcConsuemrAvg()
  • func (context *Context) CalcConsuemrExcludeFirstAvg()
  • func (context *Context) CalcProducerAvg()
  • func (context *Context) CalcProducerExcludeFirstAvg()
  • func (context *Context) MaxTimeConsumer(value int)
  • func (context *Context) MaxTimeProducer(value int)
  • func (context *Context) MinTimeConsumer(value int)
  • func (context *Context) MinTimeProducer(value int)
  • func (context *Context) ShowResult()
• type MsgKey
  • func NewUUID() *MsgKey
  • func (msgKey *MsgKey) KeyToString() string

Types

type Context

type Context struct {
	BootstrapServer string
	Topic           string
	MsgCount        int
	MsgByteSize     int
	Consumer        struct {
		ReciveTimeDiff  []int64
		AvgExcludeFirst int
		Average         int
		SuccessCount    int
		FailCount       int
		EtcCount        int
		MaxTime         int
		MinTime         int
	}
	Producer struct {
		SendTimeDiff    []int64
		AvgExcludeFirst int
		Average         int
		SuccessCount    int
		FailCount       int
		EtcCount        int
		MaxTime         int
		MinTime         int
	}
}

func NewContext

func NewContext(config *config.Config) *Context

func (*Context) AppendConsumerRDiff

func (context *Context) AppendConsumerRDiff(timestamp int64)

func (*Context) AppendProducerSDiff

func (context *Context) AppendProducerSDiff(timestamp int64)

func (*Context) CalcConsuemrAvg

func (context *Context) CalcConsuemrAvg()

func (*Context) CalcConsuemrExcludeFirstAvg

func (context *Context) CalcConsuemrExcludeFirstAvg()

func (*Context) CalcProducerAvg

func (context *Context) CalcProducerAvg()

func (*Context) CalcProducerExcludeFirstAvg

func (context *Context) CalcProducerExcludeFirstAvg()

func (*Context) MaxTimeConsumer

func (context *Context) MaxTimeConsumer(value int)

func (*Context) MaxTimeProducer

func (context *Context) MaxTimeProducer(value int)

func (*Context) MinTimeConsumer

func (context *Context) MinTimeConsumer(value int)

func (*Context) MinTimeProducer

func (context *Context) MinTimeProducer(value int)

func (*Context) ShowResult

func (context *Context) ShowResult()

type MsgKey

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

func NewUUID

func NewUUID() *MsgKey

func (*MsgKey) KeyToString

func (msgKey *MsgKey) KeyToString() string