stats

package
v0.0.0-...-c392379 Latest Latest
Warning

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

 Go to latest Published: Sep 24, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

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 (_m *MockPoseidonStatsClient) ReceiveNodeStats(_param0 context.Context, _param1 ...grpc.CallOption) (PoseidonStats_ReceiveNodeStatsClient, error)

func (*MockPoseidonStatsClient) ReceivePodStats 

func (_m *MockPoseidonStatsClient) ReceivePodStats(_param0 context.Context, _param1 ...grpc.CallOption) (PoseidonStats_ReceivePodStatsClient, error)

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 (_m *MockPoseidonStatsServer) ReceiveNodeStats(_param0 PoseidonStats_ReceiveNodeStatsServer) error

func (*MockPoseidonStatsServer) ReceivePodStats 

func (_m *MockPoseidonStatsServer) ReceivePodStats(_param0 PoseidonStats_ReceivePodStatsServer) error

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 (_m *MockPoseidonStats_ReceiveNodeStatsClient) CloseSend() error

func (*MockPoseidonStats_ReceiveNodeStatsClient) Context 

func (_m *MockPoseidonStats_ReceiveNodeStatsClient) Context() context.Context

func (*MockPoseidonStats_ReceiveNodeStatsClient) EXPECT 

func (_m *MockPoseidonStats_ReceiveNodeStatsClient) EXPECT() *_MockPoseidonStats_ReceiveNodeStatsClientRecorder

func (*MockPoseidonStats_ReceiveNodeStatsClient) Header 

func (_m *MockPoseidonStats_ReceiveNodeStatsClient) Header() (metadata.MD, error)

func (*MockPoseidonStats_ReceiveNodeStatsClient) Recv 

func (_m *MockPoseidonStats_ReceiveNodeStatsClient) Recv() (*NodeStatsResponse, error)

func (*MockPoseidonStats_ReceiveNodeStatsClient) RecvMsg 

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

func (*MockPoseidonStats_ReceiveNodeStatsClient) Send 

func (_m *MockPoseidonStats_ReceiveNodeStatsClient) Send(_param0 *NodeStats) error

func (*MockPoseidonStats_ReceiveNodeStatsClient) SendMsg 

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

func (*MockPoseidonStats_ReceiveNodeStatsClient) Trailer 

func (_m *MockPoseidonStats_ReceiveNodeStatsClient) Trailer() metadata.MD

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 (_m *MockPoseidonStats_ReceiveNodeStatsServer) Context() context.Context

func (*MockPoseidonStats_ReceiveNodeStatsServer) EXPECT 

func (_m *MockPoseidonStats_ReceiveNodeStatsServer) EXPECT() *_MockPoseidonStats_ReceiveNodeStatsServerRecorder

func (*MockPoseidonStats_ReceiveNodeStatsServer) Recv 

func (_m *MockPoseidonStats_ReceiveNodeStatsServer) Recv() (*NodeStats, error)

func (*MockPoseidonStats_ReceiveNodeStatsServer) RecvMsg 

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

func (*MockPoseidonStats_ReceiveNodeStatsServer) Send 

func (_m *MockPoseidonStats_ReceiveNodeStatsServer) Send(_param0 *NodeStatsResponse) error

func (*MockPoseidonStats_ReceiveNodeStatsServer) SendHeader 

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

func (*MockPoseidonStats_ReceiveNodeStatsServer) SendMsg 

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

func (*MockPoseidonStats_ReceiveNodeStatsServer) SetHeader 

func (_m *MockPoseidonStats_ReceiveNodeStatsServer) SetHeader(_param0 metadata.MD) error

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 (_m *MockPoseidonStats_ReceivePodStatsClient) CloseSend() error

func (*MockPoseidonStats_ReceivePodStatsClient) Context 

func (_m *MockPoseidonStats_ReceivePodStatsClient) Context() context.Context

func (*MockPoseidonStats_ReceivePodStatsClient) EXPECT 

func (_m *MockPoseidonStats_ReceivePodStatsClient) EXPECT() *_MockPoseidonStats_ReceivePodStatsClientRecorder

func (*MockPoseidonStats_ReceivePodStatsClient) Header 

func (_m *MockPoseidonStats_ReceivePodStatsClient) Header() (metadata.MD, error)

func (*MockPoseidonStats_ReceivePodStatsClient) Recv 

func (_m *MockPoseidonStats_ReceivePodStatsClient) Recv() (*PodStatsResponse, error)

func (*MockPoseidonStats_ReceivePodStatsClient) RecvMsg 

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

func (*MockPoseidonStats_ReceivePodStatsClient) Send 

func (_m *MockPoseidonStats_ReceivePodStatsClient) Send(_param0 *PodStats) error

func (*MockPoseidonStats_ReceivePodStatsClient) SendMsg 

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

func (*MockPoseidonStats_ReceivePodStatsClient) Trailer 

func (_m *MockPoseidonStats_ReceivePodStatsClient) Trailer() metadata.MD

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 (_m *MockPoseidonStats_ReceivePodStatsServer) Context() context.Context

func (*MockPoseidonStats_ReceivePodStatsServer) EXPECT 

func (_m *MockPoseidonStats_ReceivePodStatsServer) EXPECT() *_MockPoseidonStats_ReceivePodStatsServerRecorder

func (*MockPoseidonStats_ReceivePodStatsServer) Recv 

func (_m *MockPoseidonStats_ReceivePodStatsServer) Recv() (*PodStats, error)

func (*MockPoseidonStats_ReceivePodStatsServer) RecvMsg 

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

func (*MockPoseidonStats_ReceivePodStatsServer) Send 

func (_m *MockPoseidonStats_ReceivePodStatsServer) Send(_param0 *PodStatsResponse) error

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 (_m *MockPoseidonStats_ReceivePodStatsServer) SetHeader(_param0 metadata.MD) error

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 (m *NodeStatsResponse) GetType() NodeStatsResponseType

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 (m *PodStatsResponse) GetType() PodStatsResponseType

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.