collector

type CheckpointMetrics struct {
	JobName  string
	Count    int64
	Duration int
	Size     int64
}

type ExceptionMetrics struct {
	JobName string
	Count   int
}

type Job struct{}

type JobMetrics struct {
	JobStatusMetrics      []JobStatusMetrics
	ReadWriteTotalMertics ReadWriteTotalMertics
	CheckpointMetrics     []CheckpointMetrics
	ExceptionMetrics      []ExceptionMetrics
}

type JobStatusMetrics struct {
	JobName    string
	Created    int
	Running    int
	Failing    int
	Failed     int
	Cancelling int
	Canceled   int
	Finished   int
	Restarting int
	Suspended  int
	Unknown    int
}

type Overview struct {
	TaskManagers   int
	SlotsTotal     int
	SlotsAvailable int
	JobsRunning    int
	JobsFinished   int
	JobsCancelled  int
	JobsFailed     int
	FlinkVersion   string
}

type ReadWriteMertics struct {
	JobName      string
	ReadBytes    int64
	WriteBytes   int64
	ReadRecords  int64
	WriteRecords int64
}

type ReadWriteTotalMertics struct {
	ReadBytesTotal    int64
	WriteBytesTotal   int64
	ReadRecordsTotal  int64
	WriteRecordsTotal int64
	Details           []ReadWriteMertics
}