domain

type CloseStreamFunc func() error

type CollectorType string

type CollectorUnionDataType interface {
	LogLine | VolumeInfo | LabeledSample | SecretYaml | UnstructuredResource
}

type LabeledSample struct {
	MetricName string
	ID         string
	Value      float64
	Time       time.Time
}

type LogLine struct {
	Timestamp time.Time
	Value     string
}

type SecretYaml struct {
	ApiVersion string             `yaml:"apiVersion,omitempty"`
	Kind       string             `yaml:"kind,omitempty"`
	SecretType string             `yaml:"type,omitempty"`
	Data       map[string]string  `yaml:"data,omitempty"`
	Metadata   SecretYamlMetaData `yaml:"metadata,omitempty"`
}

type SecretYamlMetaData struct {
	Name              string            `yaml:"name,omitempty"`
	Namespace         string            `yaml:"namespace,omitempty"`
	UID               string            `yaml:"uid,omitempty"`
	CreationTimestamp string            `yaml:"creationTimestamp,omitempty"`
	Labels            map[string]string `yaml:"labels,omitempty"`
}

type Stream struct {
	Data chan StreamData
}

type StreamConstructor func() (io.Reader, CloseStreamFunc, error)

type StreamData struct {
	ID                string
	StreamConstructor StreamConstructor
}

type SupportArchiveID struct {
	Namespace string
	Name      string
}

type UnstructuredResource struct {
	Name string `yaml:"name,omitempty"`
	// Path represents e.g. gvk in kubernetes
	Path    string                 `json:"path,omitempty"`
	Content map[string]interface{} `yaml:"content,omitempty"`
}

type VolumeInfo struct {
	Name      string
	Timestamp time.Time        `yaml:"timestamp"`
	Items     []VolumeInfoItem `yaml:"items"`
}

type VolumeInfoItem struct {
	Name            string `yaml:"name"`
	Capacity        int64  `yaml:"capacity"`
	Used            int64  `yaml:"used"`
	PercentageUsage string `yaml:"percentageUsage"`
	Phase           string `yaml:"phase"`
}