stats

package
v0.0.0-...-2c9fce1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 19, 2021 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Overview

Package stats is a generated protocol buffer package.

It is generated from these files:

poseidonstats.proto

It has these top-level messages:

NodeStats
NodeStatsResponse
PodStats
PodStatsResponse

Index

Constants

This section is empty.

Variables

View Source
var NodeStatsResponseType_name = map[int32]string{
	0: "NODE_STATS_OK",
	1: "NODE_NOT_FOUND",
}
View Source
var NodeStatsResponseType_value = map[string]int32{
	"NODE_STATS_OK":  0,
	"NODE_NOT_FOUND": 1,
}
View Source
var PodStatsResponseType_name = map[int32]string{
	0: "POD_STATS_OK",
	1: "POD_NOT_FOUND",
}
View Source
var PodStatsResponseType_value = map[string]int32{
	"POD_STATS_OK":  0,
	"POD_NOT_FOUND": 1,
}

Functions

func RegisterPoseidonStatsServer

func RegisterPoseidonStatsServer(s *grpc.Server, srv PoseidonStatsServer)

func StartgRPCStatsServer

func StartgRPCStatsServer(statsServerAddress, firmamentAddress string)

StartgRPCStatsServer starts a gRPC server to serve poseidon status. Currently, it receives node and pod status.

Types

type MockPoseidonStatsClient

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

Mock of PoseidonStatsClient interface

func NewMockPoseidonStatsClient

func NewMockPoseidonStatsClient(ctrl *gomock.Controller) *MockPoseidonStatsClient

func (*MockPoseidonStatsClient) EXPECT

func (_m *MockPoseidonStatsClient) EXPECT() *_MockPoseidonStatsClientRecorder

func (*MockPoseidonStatsClient) ReceiveNodeStats

func (*MockPoseidonStatsClient) ReceivePodStats

type MockPoseidonStatsServer

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

Mock of PoseidonStatsServer interface

func NewMockPoseidonStatsServer

func NewMockPoseidonStatsServer(ctrl *gomock.Controller) *MockPoseidonStatsServer

func (*MockPoseidonStatsServer) EXPECT

func (_m *MockPoseidonStatsServer) EXPECT() *_MockPoseidonStatsServerRecorder

func (*MockPoseidonStatsServer) ReceiveNodeStats

func (*MockPoseidonStatsServer) ReceivePodStats

type MockPoseidonStats_ReceiveNodeStatsClient

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

Mock of PoseidonStats_ReceiveNodeStatsClient interface

func NewMockPoseidonStats_ReceiveNodeStatsClient

func NewMockPoseidonStats_ReceiveNodeStatsClient(ctrl *gomock.Controller) *MockPoseidonStats_ReceiveNodeStatsClient

func (*MockPoseidonStats_ReceiveNodeStatsClient) CloseSend

func (*MockPoseidonStats_ReceiveNodeStatsClient) Context

func (*MockPoseidonStats_ReceiveNodeStatsClient) EXPECT

func (_m *MockPoseidonStats_ReceiveNodeStatsClient) EXPECT() *_MockPoseidonStats_ReceiveNodeStatsClientRecorder

func (*MockPoseidonStats_ReceiveNodeStatsClient) Header

func (*MockPoseidonStats_ReceiveNodeStatsClient) Recv

func (*MockPoseidonStats_ReceiveNodeStatsClient) RecvMsg

func (_m *MockPoseidonStats_ReceiveNodeStatsClient) RecvMsg(_param0 interface{}) error

func (*MockPoseidonStats_ReceiveNodeStatsClient) Send

func (*MockPoseidonStats_ReceiveNodeStatsClient) SendMsg

func (_m *MockPoseidonStats_ReceiveNodeStatsClient) SendMsg(_param0 interface{}) error

func (*MockPoseidonStats_ReceiveNodeStatsClient) Trailer

type MockPoseidonStats_ReceiveNodeStatsServer

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

Mock of PoseidonStats_ReceiveNodeStatsServer interface

func NewMockPoseidonStats_ReceiveNodeStatsServer

func NewMockPoseidonStats_ReceiveNodeStatsServer(ctrl *gomock.Controller) *MockPoseidonStats_ReceiveNodeStatsServer

func (*MockPoseidonStats_ReceiveNodeStatsServer) Context

func (*MockPoseidonStats_ReceiveNodeStatsServer) EXPECT

func (_m *MockPoseidonStats_ReceiveNodeStatsServer) EXPECT() *_MockPoseidonStats_ReceiveNodeStatsServerRecorder

func (*MockPoseidonStats_ReceiveNodeStatsServer) Recv

func (*MockPoseidonStats_ReceiveNodeStatsServer) RecvMsg

func (_m *MockPoseidonStats_ReceiveNodeStatsServer) RecvMsg(_param0 interface{}) error

func (*MockPoseidonStats_ReceiveNodeStatsServer) Send

func (*MockPoseidonStats_ReceiveNodeStatsServer) SendHeader

func (*MockPoseidonStats_ReceiveNodeStatsServer) SendMsg

func (_m *MockPoseidonStats_ReceiveNodeStatsServer) SendMsg(_param0 interface{}) error

func (*MockPoseidonStats_ReceiveNodeStatsServer) SetHeader

func (*MockPoseidonStats_ReceiveNodeStatsServer) SetTrailer

func (_m *MockPoseidonStats_ReceiveNodeStatsServer) SetTrailer(_param0 metadata.MD)

type MockPoseidonStats_ReceivePodStatsClient

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

Mock of PoseidonStats_ReceivePodStatsClient interface

func NewMockPoseidonStats_ReceivePodStatsClient

func NewMockPoseidonStats_ReceivePodStatsClient(ctrl *gomock.Controller) *MockPoseidonStats_ReceivePodStatsClient

func (*MockPoseidonStats_ReceivePodStatsClient) CloseSend

func (*MockPoseidonStats_ReceivePodStatsClient) Context

func (*MockPoseidonStats_ReceivePodStatsClient) EXPECT

func (_m *MockPoseidonStats_ReceivePodStatsClient) EXPECT() *_MockPoseidonStats_ReceivePodStatsClientRecorder

func (*MockPoseidonStats_ReceivePodStatsClient) Header

func (*MockPoseidonStats_ReceivePodStatsClient) Recv

func (*MockPoseidonStats_ReceivePodStatsClient) RecvMsg

func (_m *MockPoseidonStats_ReceivePodStatsClient) RecvMsg(_param0 interface{}) error

func (*MockPoseidonStats_ReceivePodStatsClient) Send

func (*MockPoseidonStats_ReceivePodStatsClient) SendMsg

func (_m *MockPoseidonStats_ReceivePodStatsClient) SendMsg(_param0 interface{}) error

func (*MockPoseidonStats_ReceivePodStatsClient) Trailer

type MockPoseidonStats_ReceivePodStatsServer

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

Mock of PoseidonStats_ReceivePodStatsServer interface

func NewMockPoseidonStats_ReceivePodStatsServer

func NewMockPoseidonStats_ReceivePodStatsServer(ctrl *gomock.Controller) *MockPoseidonStats_ReceivePodStatsServer

func (*MockPoseidonStats_ReceivePodStatsServer) Context

func (*MockPoseidonStats_ReceivePodStatsServer) EXPECT

func (_m *MockPoseidonStats_ReceivePodStatsServer) EXPECT() *_MockPoseidonStats_ReceivePodStatsServerRecorder

func (*MockPoseidonStats_ReceivePodStatsServer) Recv

func (*MockPoseidonStats_ReceivePodStatsServer) RecvMsg

func (_m *MockPoseidonStats_ReceivePodStatsServer) RecvMsg(_param0 interface{}) error

func (*MockPoseidonStats_ReceivePodStatsServer) Send

func (*MockPoseidonStats_ReceivePodStatsServer) SendHeader

func (_m *MockPoseidonStats_ReceivePodStatsServer) SendHeader(_param0 metadata.MD) error

func (*MockPoseidonStats_ReceivePodStatsServer) SendMsg

func (_m *MockPoseidonStats_ReceivePodStatsServer) SendMsg(_param0 interface{}) error

func (*MockPoseidonStats_ReceivePodStatsServer) SetHeader

func (*MockPoseidonStats_ReceivePodStatsServer) SetTrailer

func (_m *MockPoseidonStats_ReceivePodStatsServer) SetTrailer(_param0 metadata.MD)

type NodeStats

type NodeStats struct {
	Hostname  string `protobuf:"bytes,1,opt,name=hostname" json:"hostname,omitempty"`
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp" json:"timestamp,omitempty"`
	// CPU stats (in millicores).
	CpuAllocatable int64 `protobuf:"varint,3,opt,name=cpu_allocatable,json=cpuAllocatable" json:"cpu_allocatable,omitempty"`
	CpuCapacity    int64 `protobuf:"varint,4,opt,name=cpu_capacity,json=cpuCapacity" json:"cpu_capacity,omitempty"`
	// CPU stats (fraction of total).
	CpuReservation float64 `protobuf:"fixed64,5,opt,name=cpu_reservation,json=cpuReservation" json:"cpu_reservation,omitempty"`
	CpuUtilization float64 `protobuf:"fixed64,6,opt,name=cpu_utilization,json=cpuUtilization" json:"cpu_utilization,omitempty"`
	// Memory stats (in KB).
	MemAllocatable int64 `protobuf:"varint,7,opt,name=mem_allocatable,json=memAllocatable" json:"mem_allocatable,omitempty"`
	MemCapacity    int64 `protobuf:"varint,8,opt,name=mem_capacity,json=memCapacity" json:"mem_capacity,omitempty"`
	// Memory stats (fraction of total).
	MemReservation float64 `protobuf:"fixed64,9,opt,name=mem_reservation,json=memReservation" json:"mem_reservation,omitempty"`
	MemUtilization float64 `protobuf:"fixed64,10,opt,name=mem_utilization,json=memUtilization" json:"mem_utilization,omitempty"`
}

func (*NodeStats) Descriptor

func (*NodeStats) Descriptor() ([]byte, []int)

func (*NodeStats) GetCpuAllocatable

func (m *NodeStats) GetCpuAllocatable() int64

func (*NodeStats) GetCpuCapacity

func (m *NodeStats) GetCpuCapacity() int64

func (*NodeStats) GetCpuReservation

func (m *NodeStats) GetCpuReservation() float64

func (*NodeStats) GetCpuUtilization

func (m *NodeStats) GetCpuUtilization() float64

func (*NodeStats) GetHostname

func (m *NodeStats) GetHostname() string

func (*NodeStats) GetMemAllocatable

func (m *NodeStats) GetMemAllocatable() int64

func (*NodeStats) GetMemCapacity

func (m *NodeStats) GetMemCapacity() int64

func (*NodeStats) GetMemReservation

func (m *NodeStats) GetMemReservation() float64

func (*NodeStats) GetMemUtilization

func (m *NodeStats) GetMemUtilization() float64

func (*NodeStats) GetTimestamp

func (m *NodeStats) GetTimestamp() uint64

func (*NodeStats) ProtoMessage

func (*NodeStats) ProtoMessage()

func (*NodeStats) Reset

func (m *NodeStats) Reset()

func (*NodeStats) String

func (m *NodeStats) String() string

type NodeStatsResponse

type NodeStatsResponse struct {
	Type     NodeStatsResponseType `protobuf:"varint,1,opt,name=type,enum=stats.NodeStatsResponseType" json:"type,omitempty"`
	Hostname string                `protobuf:"bytes,2,opt,name=hostname" json:"hostname,omitempty"`
}

func (*NodeStatsResponse) Descriptor

func (*NodeStatsResponse) Descriptor() ([]byte, []int)

func (*NodeStatsResponse) GetHostname

func (m *NodeStatsResponse) GetHostname() string

func (*NodeStatsResponse) GetType

func (*NodeStatsResponse) ProtoMessage

func (*NodeStatsResponse) ProtoMessage()

func (*NodeStatsResponse) Reset

func (m *NodeStatsResponse) Reset()

func (*NodeStatsResponse) String

func (m *NodeStatsResponse) String() string

type NodeStatsResponseType

type NodeStatsResponseType int32
const (
	NodeStatsResponseType_NODE_STATS_OK  NodeStatsResponseType = 0
	NodeStatsResponseType_NODE_NOT_FOUND NodeStatsResponseType = 1
)

func (NodeStatsResponseType) EnumDescriptor

func (NodeStatsResponseType) EnumDescriptor() ([]byte, []int)

func (NodeStatsResponseType) String

func (x NodeStatsResponseType) String() string

type PodStats

type PodStats struct {
	Name      string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
	Hostname  string `protobuf:"bytes,3,opt,name=hostname" json:"hostname,omitempty"`
	// CPU stats in millicores.
	CpuLimit   int64 `protobuf:"varint,4,opt,name=cpu_limit,json=cpuLimit" json:"cpu_limit,omitempty"`
	CpuRequest int64 `protobuf:"varint,5,opt,name=cpu_request,json=cpuRequest" json:"cpu_request,omitempty"`
	CpuUsage   int64 `protobuf:"varint,6,opt,name=cpu_usage,json=cpuUsage" json:"cpu_usage,omitempty"`
	// Memory stats in Kb.
	MemLimit            int64   `protobuf:"varint,7,opt,name=mem_limit,json=memLimit" json:"mem_limit,omitempty"`
	MemRequest          int64   `protobuf:"varint,8,opt,name=mem_request,json=memRequest" json:"mem_request,omitempty"`
	MemUsage            int64   `protobuf:"varint,9,opt,name=mem_usage,json=memUsage" json:"mem_usage,omitempty"`
	MemRss              int64   `protobuf:"varint,10,opt,name=mem_rss,json=memRss" json:"mem_rss,omitempty"`
	MemCache            int64   `protobuf:"varint,11,opt,name=mem_cache,json=memCache" json:"mem_cache,omitempty"`
	MemWorkingSet       int64   `protobuf:"varint,12,opt,name=mem_working_set,json=memWorkingSet" json:"mem_working_set,omitempty"`
	MemPageFaults       int64   `protobuf:"varint,13,opt,name=mem_page_faults,json=memPageFaults" json:"mem_page_faults,omitempty"`
	MemPageFaultsRate   float64 `protobuf:"fixed64,14,opt,name=mem_page_faults_rate,json=memPageFaultsRate" json:"mem_page_faults_rate,omitempty"`
	MajorPageFaults     int64   `protobuf:"varint,15,opt,name=major_page_faults,json=majorPageFaults" json:"major_page_faults,omitempty"`
	MajorPageFaultsRate float64 `protobuf:"fixed64,16,opt,name=major_page_faults_rate,json=majorPageFaultsRate" json:"major_page_faults_rate,omitempty"`
	// Network stats in Kb.
	NetRx           int64   `protobuf:"varint,17,opt,name=net_rx,json=netRx" json:"net_rx,omitempty"`
	NetRxErrors     int64   `protobuf:"varint,18,opt,name=net_rx_errors,json=netRxErrors" json:"net_rx_errors,omitempty"`
	NetRxErrorsRate float64 `protobuf:"fixed64,19,opt,name=net_rx_errors_rate,json=netRxErrorsRate" json:"net_rx_errors_rate,omitempty"`
	NetRxRate       float64 `protobuf:"fixed64,20,opt,name=net_rx_rate,json=netRxRate" json:"net_rx_rate,omitempty"`
	NetTx           int64   `protobuf:"varint,21,opt,name=net_tx,json=netTx" json:"net_tx,omitempty"`
	NetTxErrors     int64   `protobuf:"varint,22,opt,name=net_tx_errors,json=netTxErrors" json:"net_tx_errors,omitempty"`
	NetTxErrorsRate float64 `protobuf:"fixed64,23,opt,name=net_tx_errors_rate,json=netTxErrorsRate" json:"net_tx_errors_rate,omitempty"`
	NetTxRate       float64 `protobuf:"fixed64,24,opt,name=net_tx_rate,json=netTxRate" json:"net_tx_rate,omitempty"`
}

func (*PodStats) Descriptor

func (*PodStats) Descriptor() ([]byte, []int)

func (*PodStats) GetCpuLimit

func (m *PodStats) GetCpuLimit() int64

func (*PodStats) GetCpuRequest

func (m *PodStats) GetCpuRequest() int64

func (*PodStats) GetCpuUsage

func (m *PodStats) GetCpuUsage() int64

func (*PodStats) GetHostname

func (m *PodStats) GetHostname() string

func (*PodStats) GetMajorPageFaults

func (m *PodStats) GetMajorPageFaults() int64

func (*PodStats) GetMajorPageFaultsRate

func (m *PodStats) GetMajorPageFaultsRate() float64

func (*PodStats) GetMemCache

func (m *PodStats) GetMemCache() int64

func (*PodStats) GetMemLimit

func (m *PodStats) GetMemLimit() int64

func (*PodStats) GetMemPageFaults

func (m *PodStats) GetMemPageFaults() int64

func (*PodStats) GetMemPageFaultsRate

func (m *PodStats) GetMemPageFaultsRate() float64

func (*PodStats) GetMemRequest

func (m *PodStats) GetMemRequest() int64

func (*PodStats) GetMemRss

func (m *PodStats) GetMemRss() int64

func (*PodStats) GetMemUsage

func (m *PodStats) GetMemUsage() int64

func (*PodStats) GetMemWorkingSet

func (m *PodStats) GetMemWorkingSet() int64

func (*PodStats) GetName

func (m *PodStats) GetName() string

func (*PodStats) GetNamespace

func (m *PodStats) GetNamespace() string

func (*PodStats) GetNetRx

func (m *PodStats) GetNetRx() int64

func (*PodStats) GetNetRxErrors

func (m *PodStats) GetNetRxErrors() int64

func (*PodStats) GetNetRxErrorsRate

func (m *PodStats) GetNetRxErrorsRate() float64

func (*PodStats) GetNetRxRate

func (m *PodStats) GetNetRxRate() float64

func (*PodStats) GetNetTx

func (m *PodStats) GetNetTx() int64

func (*PodStats) GetNetTxErrors

func (m *PodStats) GetNetTxErrors() int64

func (*PodStats) GetNetTxErrorsRate

func (m *PodStats) GetNetTxErrorsRate() float64

func (*PodStats) GetNetTxRate

func (m *PodStats) GetNetTxRate() float64

func (*PodStats) ProtoMessage

func (*PodStats) ProtoMessage()

func (*PodStats) Reset

func (m *PodStats) Reset()

func (*PodStats) String

func (m *PodStats) String() string

type PodStatsResponse

type PodStatsResponse struct {
	Type      PodStatsResponseType `protobuf:"varint,1,opt,name=type,enum=stats.PodStatsResponseType" json:"type,omitempty"`
	Name      string               `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Namespace string               `protobuf:"bytes,3,opt,name=namespace" json:"namespace,omitempty"`
}

func (*PodStatsResponse) Descriptor

func (*PodStatsResponse) Descriptor() ([]byte, []int)

func (*PodStatsResponse) GetName

func (m *PodStatsResponse) GetName() string

func (*PodStatsResponse) GetNamespace

func (m *PodStatsResponse) GetNamespace() string

func (*PodStatsResponse) GetType

func (*PodStatsResponse) ProtoMessage

func (*PodStatsResponse) ProtoMessage()

func (*PodStatsResponse) Reset

func (m *PodStatsResponse) Reset()

func (*PodStatsResponse) String

func (m *PodStatsResponse) String() string

type PodStatsResponseType

type PodStatsResponseType int32
const (
	PodStatsResponseType_POD_STATS_OK  PodStatsResponseType = 0
	PodStatsResponseType_POD_NOT_FOUND PodStatsResponseType = 1
)

func (PodStatsResponseType) EnumDescriptor

func (PodStatsResponseType) EnumDescriptor() ([]byte, []int)

func (PodStatsResponseType) String

func (x PodStatsResponseType) String() string

type PoseidonStatsClient

type PoseidonStatsClient interface {
	ReceiveNodeStats(ctx context.Context, opts ...grpc.CallOption) (PoseidonStats_ReceiveNodeStatsClient, error)
	ReceivePodStats(ctx context.Context, opts ...grpc.CallOption) (PoseidonStats_ReceivePodStatsClient, error)
}

func NewPoseidonStatsClient

func NewPoseidonStatsClient(cc *grpc.ClientConn) PoseidonStatsClient

type PoseidonStatsServer

type PoseidonStatsServer interface {
	ReceiveNodeStats(PoseidonStats_ReceiveNodeStatsServer) error
	ReceivePodStats(PoseidonStats_ReceivePodStatsServer) error
}

type PoseidonStats_ReceiveNodeStatsClient

type PoseidonStats_ReceiveNodeStatsClient interface {
	Send(*NodeStats) error
	Recv() (*NodeStatsResponse, error)
	grpc.ClientStream
}

type PoseidonStats_ReceiveNodeStatsServer

type PoseidonStats_ReceiveNodeStatsServer interface {
	Send(*NodeStatsResponse) error
	Recv() (*NodeStats, error)
	grpc.ServerStream
}

type PoseidonStats_ReceivePodStatsClient

type PoseidonStats_ReceivePodStatsClient interface {
	Send(*PodStats) error
	Recv() (*PodStatsResponse, error)
	grpc.ClientStream
}

type PoseidonStats_ReceivePodStatsServer

type PoseidonStats_ReceivePodStatsServer interface {
	Send(*PodStatsResponse) error
	Recv() (*PodStats, error)
	grpc.ServerStream
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL