pipeline

type BlockDeviceMetric struct {
	Name            string    `avro:"name"`
	NodeName        string    `avro:"node_name"`
	NodeTemplate    *string   `avro:"node_template"`
	ReadIOPS        int64     `avro:"read_iops"`
	WriteIOPS       int64     `avro:"write_iops"`
	ReadThroughput  int64     `avro:"read_throughput"`
	WriteThroughput int64     `avro:"write_throughput"`
	Size            *int64    `avro:"size"`
	PhysicalDevices []string  `avro:"physical_devices"`
	Timestamp       time.Time `avro:"ts"`
	// contains filtered or unexported fields
}

type BlockDeviceMetricsWriter interface {
	Write(metrics ...BlockDeviceMetric) error
}

type Config struct {
	DataBatch   config.DataBatchConfig   `validate:"required"`
	Netflow     config.NetflowConfig     `validate:"required"`
	Events      config.EventsConfig      `validate:"required"`
	Stats       config.StatsConfig       `validate:"required"`
	ProcessTree config.ProcessTreeConfig `validate:"required"`
}

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

type DiskClient struct{}

type DiskInterface interface {
	IOCounters() (map[string]disk.IOCountersStat, error)
	Partitions(all bool) ([]disk.PartitionStat, error)
	GetDiskStats(path string) (*disk.UsageStat, error)
}

type FilesystemMetric struct {
	Devices      []string  `avro:"devices"`
	NodeName     string    `avro:"node_name"`
	NodeTemplate *string   `avro:"node_template"`
	MountPoint   string    `avro:"mount_point"`
	TotalSize    *int64    `avro:"total_size"`
	UsedSpace    *int64    `avro:"used_space"`
	Timestamp    time.Time `avro:"ts"`
}

type FilesystemMetricsWriter interface {
	Write(metrics ...FilesystemMetric) error
}

type StorageInfoProvider interface {
	BuildFilesystemMetrics(timestamp time.Time) ([]FilesystemMetric, error)
	BuildBlockDeviceMetrics(timestamp time.Time) ([]BlockDeviceMetric, error)
}

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