shepherd_common

type AppMetrics struct {
	// Cpu is a percentage
	Cpu   float64
	CpuTS *types.Timestamp
	// Mem is bytes used
	Mem   uint64
	MemTS *types.Timestamp
	// Disk is bytes used
	Disk   uint64
	DiskTS *types.Timestamp
}

type AppStats interface {
	// Returns current resource usage for a app instance
	GetAppStats(ctx context.Context) *AppMetrics
}

type CloudletMetrics struct {
	CollectTime *types.Timestamp
	// Total number of CPUs
	VCpuMax uint64
	// Current number of CPUs used
	VCpuUsed uint64
	// Total amount of RAM(in MB)
	MemMax uint64
	// Currently used RAM(in MB)
	MemUsed uint64
	// Total amount of Storage(in GB)
	DiskUsed uint64
	// Currently used Storage(in GB)
	DiskMax uint64
	// Total number of Floating IPs available
	FloatingIpsMax uint64
	// Currently used number of Floating IPs
	FloatingIpsUsed uint64
	// Total KBytes received
	NetRecv uint64
	// Total KBytes sent
	NetSent uint64
	// Total available IP addresses
	Ipv4Max uint64
	// Currently used IP addrs
	Ipv4Used uint64
}

type ClusterMetrics struct {
	Cpu          float64
	CpuTS        *types.Timestamp
	Mem          float64
	MemTS        *types.Timestamp
	Disk         float64
	DiskTS       *types.Timestamp
	TcpConns     uint64
	TcpConnsTS   *types.Timestamp
	TcpRetrans   uint64
	TcpRetransTS *types.Timestamp
	UdpSent      uint64
	UdpSentTS    *types.Timestamp
	UdpRecv      uint64
	UdpRecvTS    *types.Timestamp
	UdpRecvErr   uint64
	UdpRecvErrTS *types.Timestamp
	AutoScaleCpu float64
	AutoScaleMem float64
}

type ClusterNetMetrics struct {
	NetTS   *types.Timestamp
	NetSent uint64
	NetRecv uint64
}

type ClusterStats interface {
	// Returns current resource usage for a cluster instance
	GetClusterStats(ctx context.Context, ops ...StatsOp) *ClusterMetrics
	GetAppStats(ctx context.Context) map[MetricAppInstKey]*AppMetrics
	GetAlerts(ctx context.Context) []edgeproto.Alert
	// Track a new AppInst in the cluster. Must be idempotent
	TrackAppInst(ctx context.Context, appInst *edgeproto.AppInst)
	// Untrack an AppInst from the cluster. Must be idempotent
	UntrackAppInst(ctx context.Context, appInst *edgeproto.AppInst)
}

type MetricAppInstKey struct {
	ClusterKey  edgeproto.ClusterKey
	CloudletKey edgeproto.CloudletKey
	Pod         string
	AppInstName string
	AppInstOrg  string
}

type ProxyMetrics struct {
	ActiveConn    uint64
	Accepts       uint64
	HandledConn   uint64
	Requests      uint64
	Reading       uint64
	Writing       uint64
	Waiting       uint64
	Nginx         bool
	EnvoyTcpStats map[int32]TcpConnectionsMetric
	EnvoyUdpStats map[int32]UdpConnectionsMetric
	Ts            *types.Timestamp
}

type StatsOp func(opts *StatsOptions)

type StatsOptions struct {
	GetAutoScaleStats bool
}

type TcpConnectionsMetric struct {
	ActiveConn  uint64
	Accepts     uint64
	HandledConn uint64
	// histogram of sessions times (in ms)
	SessionTime map[string]float64
	BytesSent   uint64
	BytesRecvd  uint64
}

type UdpConnectionsMetric struct {
	RecvBytes     uint64
	SentBytes     uint64
	RecvDatagrams uint64
	SentDatagrams uint64
	RecvErrs      uint64
	SentErrs      uint64
	Overflow      uint64
	Missed        uint64
}