Documentation ¶
Index ¶
- Variables
- func RegisterContainerStatsServiceServer(s grpc.ServiceRegistrar, srv ContainerStatsServiceServer)
- type Container
- func (*Container) Descriptor() ([]byte, []int)deprecated
- func (x *Container) GetId() string
- func (x *Container) GetImage() string
- func (x *Container) GetName() string
- func (*Container) ProtoMessage()
- func (x *Container) ProtoReflect() protoreflect.Message
- func (x *Container) Reset()
- func (x *Container) String() string
- type ContainerStats
- func (*ContainerStats) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerStats) GetCPU() float32
- func (x *ContainerStats) GetContainer() *Container
- func (x *ContainerStats) GetMemory() float32
- func (*ContainerStats) ProtoMessage()
- func (x *ContainerStats) ProtoReflect() protoreflect.Message
- func (x *ContainerStats) Reset()
- func (x *ContainerStats) String() string
- type ContainerStatsServiceClient
- type ContainerStatsServiceServer
- type ContainerStatsService_GetStatsStreamClient
- type ContainerStatsService_GetStatsStreamServer
- type GetStatsMessage
- type Stats
- type UnimplementedContainerStatsServiceServer
- type UnsafeContainerStatsServiceServer
Constants ¶
This section is empty.
Variables ¶
var ContainerStatsService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protoStats.ContainerStatsService", HandlerType: (*ContainerStatsServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "getStatsStream", Handler: _ContainerStatsService_GetStatsStream_Handler, ServerStreams: true, }, }, Metadata: "stats.proto", }
ContainerStatsService_ServiceDesc is the grpc.ServiceDesc for ContainerStatsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_stats_proto protoreflect.FileDescriptor
Functions ¶
func RegisterContainerStatsServiceServer ¶
func RegisterContainerStatsServiceServer(s grpc.ServiceRegistrar, srv ContainerStatsServiceServer)
Types ¶
type Container ¶
type Container struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"` // contains filtered or unexported fields }
func (*Container) Descriptor
deprecated
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
func (*Container) ProtoReflect ¶
func (x *Container) ProtoReflect() protoreflect.Message
type ContainerStats ¶
type ContainerStats struct { Container *Container `protobuf:"bytes,1,opt,name=container,proto3" json:"container,omitempty"` CPU float32 `protobuf:"fixed32,2,opt,name=CPU,proto3" json:"CPU,omitempty"` Memory float32 `protobuf:"fixed32,3,opt,name=Memory,proto3" json:"Memory,omitempty"` // contains filtered or unexported fields }
func (*ContainerStats) Descriptor
deprecated
func (*ContainerStats) Descriptor() ([]byte, []int)
Deprecated: Use ContainerStats.ProtoReflect.Descriptor instead.
func (*ContainerStats) GetCPU ¶
func (x *ContainerStats) GetCPU() float32
func (*ContainerStats) GetContainer ¶
func (x *ContainerStats) GetContainer() *Container
func (*ContainerStats) GetMemory ¶
func (x *ContainerStats) GetMemory() float32
func (*ContainerStats) ProtoMessage ¶
func (*ContainerStats) ProtoMessage()
func (*ContainerStats) ProtoReflect ¶
func (x *ContainerStats) ProtoReflect() protoreflect.Message
func (*ContainerStats) Reset ¶
func (x *ContainerStats) Reset()
func (*ContainerStats) String ¶
func (x *ContainerStats) String() string
type ContainerStatsServiceClient ¶
type ContainerStatsServiceClient interface {
GetStatsStream(ctx context.Context, in *GetStatsMessage, opts ...grpc.CallOption) (ContainerStatsService_GetStatsStreamClient, error)
}
ContainerStatsServiceClient is the client API for ContainerStatsService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewContainerStatsServiceClient ¶
func NewContainerStatsServiceClient(cc grpc.ClientConnInterface) ContainerStatsServiceClient
type ContainerStatsServiceServer ¶
type ContainerStatsServiceServer interface { GetStatsStream(*GetStatsMessage, ContainerStatsService_GetStatsStreamServer) error // contains filtered or unexported methods }
ContainerStatsServiceServer is the server API for ContainerStatsService service. All implementations must embed UnimplementedContainerStatsServiceServer for forward compatibility
type ContainerStatsService_GetStatsStreamClient ¶
type ContainerStatsService_GetStatsStreamClient interface { Recv() (*Stats, error) grpc.ClientStream }
type ContainerStatsService_GetStatsStreamServer ¶
type ContainerStatsService_GetStatsStreamServer interface { Send(*Stats) error grpc.ServerStream }
type GetStatsMessage ¶
type GetStatsMessage struct {
// contains filtered or unexported fields
}
func (*GetStatsMessage) Descriptor
deprecated
func (*GetStatsMessage) Descriptor() ([]byte, []int)
Deprecated: Use GetStatsMessage.ProtoReflect.Descriptor instead.
func (*GetStatsMessage) ProtoMessage ¶
func (*GetStatsMessage) ProtoMessage()
func (*GetStatsMessage) ProtoReflect ¶
func (x *GetStatsMessage) ProtoReflect() protoreflect.Message
func (*GetStatsMessage) Reset ¶
func (x *GetStatsMessage) Reset()
func (*GetStatsMessage) String ¶
func (x *GetStatsMessage) String() string
type Stats ¶
type Stats struct { ContainerStats []*ContainerStats `protobuf:"bytes,1,rep,name=containerStats,proto3" json:"containerStats,omitempty"` // contains filtered or unexported fields }
func (*Stats) Descriptor
deprecated
func (*Stats) GetContainerStats ¶
func (x *Stats) GetContainerStats() []*ContainerStats
func (*Stats) ProtoMessage ¶
func (*Stats) ProtoMessage()
func (*Stats) ProtoReflect ¶
func (x *Stats) ProtoReflect() protoreflect.Message
type UnimplementedContainerStatsServiceServer ¶
type UnimplementedContainerStatsServiceServer struct { }
UnimplementedContainerStatsServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedContainerStatsServiceServer) GetStatsStream ¶
func (UnimplementedContainerStatsServiceServer) GetStatsStream(*GetStatsMessage, ContainerStatsService_GetStatsStreamServer) error
type UnsafeContainerStatsServiceServer ¶
type UnsafeContainerStatsServiceServer interface {
// contains filtered or unexported methods
}
UnsafeContainerStatsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContainerStatsServiceServer will result in compilation errors.