stats

Documentation

Index

• Constants
• type Stats
  • func NewStats() *Stats
  • func (s *Stats) Dec(statsType StatsType)
  • func (s *Stats) Inc(statsType StatsType)
  • func (s *Stats) Json() ([]byte, error)
• type StatsType

Constants

const (
	EnvCFInstanceIndex = "CF_INSTANCE_INDEX"
)

Types

type Stats

type Stats struct {
	Consume       uint64  `json:"consume"`
	ConsumePerSec float64 `json:"consume_per_sec"`
	ConsumeFail   uint64  `json:"consume_fail"`

	Publish       uint64  `json:"publish"`
	PublishPerSec float64 `json:"publish_per_sec"`

	// This is same as the number of dropped message
	PublishFail uint64 `json:"publish_fail"`

	SlowConsumerAlert uint64 `json:"slow_consumer_alert"`

	// SubInputBuffer is used to count number of current
	// buffer on subInput.
	SubInputBuffer int64 `json:"subinupt_buffer"`

	// Delay is Consume - Pulish
	// This indicate how slow publish to kafka
	Delay uint64 `json:"delay"`

	// InstanceID is ID for nozzle instance.
	// This is used to identify stats from different instances.
	// By default, it's defaultInstanceID
	InstanceID int `json:"instance_id"`
}

Stats stores various stats infomation

func NewStats

func NewStats() *Stats

func (*Stats) Dec

func (s *Stats) Dec(statsType StatsType)

func (*Stats) Inc

func (s *Stats) Inc(statsType StatsType)

func (*Stats) Json

func (s *Stats) Json() ([]byte, error)

type StatsType

type StatsType int

const (
	Consume StatsType = iota
	ConsumeFail
	Publish
	PublishFail
	SlowConsumerAlert
	SubInputBuffer
)