instmetrics

type CRIMetricsScraper struct {
	RuntimeClient *RemoteRuntimeServiceClient
}

type ContainerMetricsRequest struct {

	// Filter needed to find target "application container"
	PodName string `protobuf:"bytes,1,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	// contains filtered or unexported fields
}

type ContainerMetricsResponse struct {
	CpuPerc   float32 `protobuf:"fixed32,1,opt,name=cpu_perc,json=cpuPerc,proto3" json:"cpu_perc,omitempty"`
	MemBytes  uint64  `protobuf:"varint,2,opt,name=mem_bytes,json=memBytes,proto3" json:"mem_bytes,omitempty"`
	DiskBytes uint64  `protobuf:"varint,3,opt,name=disk_bytes,json=diskBytes,proto3" json:"disk_bytes,omitempty"`
	// contains filtered or unexported fields
}

type ContainerStats struct {
	// Timestamp in nanoseconds at which the information were collected
	CPUTimestamp int64
	// Cumulative CPU usage (sum across all cores) since object creation.
	UsageCoreNanoSeconds uint64
	// Total memory in use.
	MemoryUsageInBytes uint64
	// UsedBytes represents the bytes used for images on the filesystem.
	// This may differ from the total bytes used on the filesystem and may not
	// equal CapacityBytes - AvailableBytes.
	DiskUsageInBytes uint64
	// contains filtered or unexported fields
}

type ContainerStatsResponse struct {
	MemoryStats struct {
		Usage uint64 `json:"usage"`
	} `json:"memory_stats"`

	CPUStats struct {
		Timestamp int64  `json:"system_cpu_usage"`
		Cores     uint64 `json:"online_cpus"`

		Usage struct {
			Total uint64 `json:"total_usage"`
		} `json:"cpu_usage"`
	} `json:"cpu_stats"`
}

type CustomMetrics struct {
	CPUPerc   float32 `json:"cpu"`
	MemBytes  uint64  `json:"mem"`
	DiskBytes uint64  `json:"disk"`
}

type DockerMetricsScraper struct {
	// Client is the API client that performs all operations against a docker server.
	DockerClient       *client.Client
	ContStatsListMutex *sync.RWMutex
}

type InstanceMetricsClient interface {
	// ContainerMetrics returns metrics of the "application container" related to the required PodName.
	// If the container does not exist, the call returns an error.
	ContainerMetrics(ctx context.Context, in *ContainerMetricsRequest, opts ...grpc.CallOption) (*ContainerMetricsResponse, error)
}

type InstanceMetricsServer interface {
	// ContainerMetrics returns metrics of the "application container" related to the required PodName.
	// If the container does not exist, the call returns an error.
	ContainerMetrics(context.Context, *ContainerMetricsRequest) (*ContainerMetricsResponse, error)
	// contains filtered or unexported methods
}

type MetricsScraper struct {
	Log           logr.Logger
	UpdatePeriod  time.Duration
	RuntimeClient *RemoteRuntimeServiceClient
	// contains filtered or unexported fields
}

type ReadinessProbeHandler struct {
	RuntimeClient *RemoteRuntimeServiceClient
	Log           logr.Logger
	Ready         bool
}

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

type Server struct {
	// MetricsScraperPeriod indicates the update interval for CustomMetrics update.
	MetricsScraperPeriod time.Duration
	Port                 int
	Log                  logr.Logger
	RuntimeClient        *RemoteRuntimeServiceClient
	StatsScraper         *StatsScraper

	UnimplementedInstanceMetricsServer
	// contains filtered or unexported fields
}

type StatsScraper interface {
	// contains filtered or unexported methods
}

type UnimplementedInstanceMetricsServer struct {
}

type UnsafeInstanceMetricsServer interface {
	// contains filtered or unexported methods
}