metrics

type CollectOptions struct {
	FlushInterval     time.Duration
	SampleCount       int
	BlockCount        int
	OutputFilePrefix  string
	CaptureStructured bool

	// The WriterConstructor returns a writable object (typically
	// a file) to stream metrics too. This can be a (simple)
	// wrapper around os.Create in the common case.
	WriterConstructor func(string) (io.WriteCloser, error)
}

type CounterType int8

type GoRuntimeInfo struct {
	Message string `bson:"msg" json:"msg" yaml:"msg"`
	Payload struct {
		HeapObjects uint64        `bson:"memory.objects.heap" json:"memory.objects.heap" yaml:"memory.objects.heap"`
		Alloc       uint64        `bson:"memory.summary.alloc" json:"memory.summary.alloc" yaml:"memory.summary.alloc"`
		HeapSystem  uint64        `bson:"memory.summary.system" json:"memory.summary.system" yaml:"memory.summary.system"`
		HeapIdle    uint64        `bson:"memory.heap.idle" json:"memory.heap.idle" yaml:"memory.heap.idle"`
		HeapInUse   uint64        `bson:"memory.heap.used" json:"memory.heap.used" yaml:"memory.heap.used"`
		Mallocs     int64         `bson:"memory.counters.mallocs" json:"memory.counters.mallocs" yaml:"memory.counters.mallocs"`
		Frees       int64         `bson:"memory.counters.frees" json:"memory.counters.frees" yaml:"memory.counters.frees"`
		GC          int64         `bson:"gc.rate" json:"gc.rate" yaml:"gc.rate"`
		GCPause     time.Duration `bson:"gc.pause.duration.last" json:"gc.pause.last" yaml:"gc.pause.last"`
		GCLatency   time.Duration `bson:"gc.pause.duration.latency" json:"gc.pause.duration.latency" yaml:"gc.pause.duration.latency"`
		Goroutines  int64         `bson:"goroutines.total" json:"goroutines.total" yaml:"goroutines.total"`
		CgoCalls    int64         `bson:"cgo.calls" json:"cgo.calls" yaml:"cgo.calls"`
	}
	message.Base `json:"meta,omitempty" bson:"meta,omitempty" yaml:"meta,omitempty"`
	// contains filtered or unexported fields
}

type ProcessInfo struct {
	Message string `json:"msg" bson:"msg"`
	Payload struct {
		Pid            int32                    `json:"pid" bson:"pid"`
		Parent         int32                    `json:"parentPid" bson:"parentPid"`
		Threads        int                      `json:"numThreads" bson:"numThreads"`
		Command        string                   `json:"command" bson:"command"`
		CPU            StatCPUTimes             `json:"cpu" bson:"cpu"`
		IoStat         process.IOCountersStat   `json:"io" bson:"io"`
		NetStat        []net.IOCountersStat     `json:"net" bson:"net"`
		Memory         process.MemoryInfoStat   `json:"mem" bson:"mem"`
		MemoryPlatform process.MemoryInfoExStat `json:"memExtra" bson:"memExtra"`
		Errors         []string                 `json:"errors" bson:"errors"`
	}

	message.Base `json:"metadata,omitempty" bson:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type SchemaComposer interface {
	message.Composer
	// Schema describes the format of the Raw() method for a
	// message. This is provided as an alternative to simply using
	// fmt.Sprintf("%T", msg), and makes it possible to maintain
	// schema versions.
	Schema() string
}

type StatCPUTimes struct {
	User      int64 `json:"user" bson:"user"`
	System    int64 `json:"system" bson:"system"`
	Idle      int64 `json:"idle" bson:"idle"`
	Nice      int64 `json:"nice" bson:"nice"`
	Iowait    int64 `json:"iowait" bson:"iowait"`
	Irq       int64 `json:"irq" bson:"irq"`
	Softirq   int64 `json:"softirq" bson:"softirq"`
	Steal     int64 `json:"steal" bson:"steal"`
	Guest     int64 `json:"guest" bson:"guest"`
	GuestNice int64 `json:"guestNice" bson:"guestNice"`
}

type SystemInfo struct {
	Message string `json:"msg" bson:"msg"`
	Payload struct {
		CPU        StatCPUTimes          `json:"cpu" bson:"cpu"`
		CPUPercent float64               `json:"cpu_percent" bson:"cpu_percent"`
		NumCPU     int                   `json:"num_cpus" bson:"num_cpus"`
		VMStat     mem.VirtualMemoryStat `json:"vmstat" bson:"vmstat"`
		NetStat    net.IOCountersStat    `json:"netstat" bson:"netstat"`
		Partitions []disk.PartitionStat  `json:"partitions" bson:"partitions"`
		Usage      []disk.UsageStat      `json:"usage" bson:"usage"`
		IOStat     []disk.IOCountersStat `json:"iostat" bson:"iostat"`
		Errors     []string              `json:"errors" bson:"errors"`
	}
	message.Base `json:"metadata,omitempty" bson:"metadata,omitempty�"`
	// contains filtered or unexported fields
}