accounts

type Accountant interface {
	Account([]Container) ([]Sample, error)
}

type AccountantFactory func(Command) (Accountant, error)

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

type Command struct {
	Postgres        flag.PostgresConfig
	K8sNamespace    string
	K8sPod          string
	WebK8sNamespace string
	WebK8sPod       string
}

type Container struct {
	Handle string
	Stats  Stats
}

type DBAccountant struct {
	Opener PostgresOpener
}

type FileTracker interface {
	Write(string) (string, error)
	Clear()
}

type GardenConnection struct {
	Dialer GardenDialer
}

type GardenDialer interface {
	Dial() (net.Conn, error)
}

type GardenWorker struct {
	Dialer GardenDialer
}

type K8sClient interface {
	GetPod(string) (*corev1.Pod, error)
	GetSecret(string, string) (string, error)
}

type K8sGardenDialer struct {
	RESTConfig *rest.Config
	Namespace  string
	PodName    string
}

type K8sWebPod struct {
	Pod    *corev1.Pod
	Client K8sClient
}

type LANGardenDialer struct{}

type Labels struct {
	Type      db.ContainerType
	Workloads []Workload
}

type PostgresOpener interface {
	Open() (*sql.DB, error)
}

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

type Sample struct {
	Container Container
	Labels    Labels
}

type StaticPostgresOpener struct {
	flag.PostgresConfig
}

type Stats struct {
	Memory uint64
	Age    time.Duration
}

type StatsOption func()

type StreamAddr struct {
}

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

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

type WebNode interface {
	PostgresParamNames() ([]string, error)
	ValueFromEnvVar(string) (string, error)
	FileContentsFromEnvVar(string) (string, error)
}

type WebNodeInferredPostgresOpener struct {
	WebNode     WebNode
	FileTracker FileTracker
}

type Worker interface {
	Containers(...StatsOption) ([]Container, error)
}

type WorkerFactory func(Command) (Worker, error)

type Workload interface {
	ToString() string
}