talos/api/os/os.pb.go
Andrew Rynhard ad863a7f92 refactor: rename protobuf services, RPCs, and messages
This PR brings our protobuf files into conformance with the protobuf
style guide, and community conventions. It is purely renames, along with
generated docs.

Signed-off-by: Andrew Rynhard <andrew@andrewrynhard.com>
2019-12-11 11:41:40 -08:00

1845 lines
58 KiB
Go

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: os/os.proto
package os
import (
context "context"
fmt "fmt"
math "math"
proto "github.com/golang/protobuf/proto"
empty "github.com/golang/protobuf/ptypes/empty"
grpc "google.golang.org/grpc"
common "github.com/talos-systems/talos/api/common"
)
// Reference imports to suppress errors if they are not otherwise used.
var (
_ = proto.Marshal
_ = fmt.Errorf
_ = math.Inf
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
type ContainersRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
// driver might be default "containerd" or "cri"
Driver common.ContainerDriver `protobuf:"varint,2,opt,name=driver,proto3,enum=common.ContainerDriver" json:"driver,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ContainersRequest) Reset() { *m = ContainersRequest{} }
func (m *ContainersRequest) String() string { return proto.CompactTextString(m) }
func (*ContainersRequest) ProtoMessage() {}
func (*ContainersRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{0}
}
func (m *ContainersRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ContainersRequest.Unmarshal(m, b)
}
func (m *ContainersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ContainersRequest.Marshal(b, m, deterministic)
}
func (m *ContainersRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ContainersRequest.Merge(m, src)
}
func (m *ContainersRequest) XXX_Size() int {
return xxx_messageInfo_ContainersRequest.Size(m)
}
func (m *ContainersRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ContainersRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ContainersRequest proto.InternalMessageInfo
func (m *ContainersRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *ContainersRequest) GetDriver() common.ContainerDriver {
if m != nil {
return m.Driver
}
return common.ContainerDriver_CONTAINERD
}
// The messages message containing the requested containers.
type ContainerInfo struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
Pid uint32 `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"`
Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
PodId string `protobuf:"bytes,6,opt,name=pod_id,json=podId,proto3" json:"pod_id,omitempty"`
Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ContainerInfo) Reset() { *m = ContainerInfo{} }
func (m *ContainerInfo) String() string { return proto.CompactTextString(m) }
func (*ContainerInfo) ProtoMessage() {}
func (*ContainerInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{1}
}
func (m *ContainerInfo) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ContainerInfo.Unmarshal(m, b)
}
func (m *ContainerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ContainerInfo.Marshal(b, m, deterministic)
}
func (m *ContainerInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_ContainerInfo.Merge(m, src)
}
func (m *ContainerInfo) XXX_Size() int {
return xxx_messageInfo_ContainerInfo.Size(m)
}
func (m *ContainerInfo) XXX_DiscardUnknown() {
xxx_messageInfo_ContainerInfo.DiscardUnknown(m)
}
var xxx_messageInfo_ContainerInfo proto.InternalMessageInfo
func (m *ContainerInfo) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *ContainerInfo) GetId() string {
if m != nil {
return m.Id
}
return ""
}
func (m *ContainerInfo) GetImage() string {
if m != nil {
return m.Image
}
return ""
}
func (m *ContainerInfo) GetPid() uint32 {
if m != nil {
return m.Pid
}
return 0
}
func (m *ContainerInfo) GetStatus() string {
if m != nil {
return m.Status
}
return ""
}
func (m *ContainerInfo) GetPodId() string {
if m != nil {
return m.PodId
}
return ""
}
func (m *ContainerInfo) GetName() string {
if m != nil {
return m.Name
}
return ""
}
// The messages message containing the requested containers.
type Container struct {
Metadata *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
Containers []*ContainerInfo `protobuf:"bytes,2,rep,name=containers,proto3" json:"containers,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Container) Reset() { *m = Container{} }
func (m *Container) String() string { return proto.CompactTextString(m) }
func (*Container) ProtoMessage() {}
func (*Container) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{2}
}
func (m *Container) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Container.Unmarshal(m, b)
}
func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Container.Marshal(b, m, deterministic)
}
func (m *Container) XXX_Merge(src proto.Message) {
xxx_messageInfo_Container.Merge(m, src)
}
func (m *Container) XXX_Size() int {
return xxx_messageInfo_Container.Size(m)
}
func (m *Container) XXX_DiscardUnknown() {
xxx_messageInfo_Container.DiscardUnknown(m)
}
var xxx_messageInfo_Container proto.InternalMessageInfo
func (m *Container) GetMetadata() *common.Metadata {
if m != nil {
return m.Metadata
}
return nil
}
func (m *Container) GetContainers() []*ContainerInfo {
if m != nil {
return m.Containers
}
return nil
}
type ContainersResponse struct {
Messages []*Container `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ContainersResponse) Reset() { *m = ContainersResponse{} }
func (m *ContainersResponse) String() string { return proto.CompactTextString(m) }
func (*ContainersResponse) ProtoMessage() {}
func (*ContainersResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{3}
}
func (m *ContainersResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ContainersResponse.Unmarshal(m, b)
}
func (m *ContainersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ContainersResponse.Marshal(b, m, deterministic)
}
func (m *ContainersResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ContainersResponse.Merge(m, src)
}
func (m *ContainersResponse) XXX_Size() int {
return xxx_messageInfo_ContainersResponse.Size(m)
}
func (m *ContainersResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ContainersResponse.DiscardUnknown(m)
}
var xxx_messageInfo_ContainersResponse proto.InternalMessageInfo
func (m *ContainersResponse) GetMessages() []*Container {
if m != nil {
return m.Messages
}
return nil
}
// dmesg
type DmesgRequest struct {
Follow bool `protobuf:"varint,1,opt,name=follow,proto3" json:"follow,omitempty"`
Tail bool `protobuf:"varint,2,opt,name=tail,proto3" json:"tail,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DmesgRequest) Reset() { *m = DmesgRequest{} }
func (m *DmesgRequest) String() string { return proto.CompactTextString(m) }
func (*DmesgRequest) ProtoMessage() {}
func (*DmesgRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{4}
}
func (m *DmesgRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DmesgRequest.Unmarshal(m, b)
}
func (m *DmesgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DmesgRequest.Marshal(b, m, deterministic)
}
func (m *DmesgRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_DmesgRequest.Merge(m, src)
}
func (m *DmesgRequest) XXX_Size() int {
return xxx_messageInfo_DmesgRequest.Size(m)
}
func (m *DmesgRequest) XXX_DiscardUnknown() {
xxx_messageInfo_DmesgRequest.DiscardUnknown(m)
}
var xxx_messageInfo_DmesgRequest proto.InternalMessageInfo
func (m *DmesgRequest) GetFollow() bool {
if m != nil {
return m.Follow
}
return false
}
func (m *DmesgRequest) GetTail() bool {
if m != nil {
return m.Tail
}
return false
}
// rpc processes
type ProcessesRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ProcessesRequest) Reset() { *m = ProcessesRequest{} }
func (m *ProcessesRequest) String() string { return proto.CompactTextString(m) }
func (*ProcessesRequest) ProtoMessage() {}
func (*ProcessesRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{5}
}
func (m *ProcessesRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ProcessesRequest.Unmarshal(m, b)
}
func (m *ProcessesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ProcessesRequest.Marshal(b, m, deterministic)
}
func (m *ProcessesRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ProcessesRequest.Merge(m, src)
}
func (m *ProcessesRequest) XXX_Size() int {
return xxx_messageInfo_ProcessesRequest.Size(m)
}
func (m *ProcessesRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ProcessesRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ProcessesRequest proto.InternalMessageInfo
type ProcessesResponse struct {
Messages []*Process `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ProcessesResponse) Reset() { *m = ProcessesResponse{} }
func (m *ProcessesResponse) String() string { return proto.CompactTextString(m) }
func (*ProcessesResponse) ProtoMessage() {}
func (*ProcessesResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{6}
}
func (m *ProcessesResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ProcessesResponse.Unmarshal(m, b)
}
func (m *ProcessesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ProcessesResponse.Marshal(b, m, deterministic)
}
func (m *ProcessesResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ProcessesResponse.Merge(m, src)
}
func (m *ProcessesResponse) XXX_Size() int {
return xxx_messageInfo_ProcessesResponse.Size(m)
}
func (m *ProcessesResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ProcessesResponse.DiscardUnknown(m)
}
var xxx_messageInfo_ProcessesResponse proto.InternalMessageInfo
func (m *ProcessesResponse) GetMessages() []*Process {
if m != nil {
return m.Messages
}
return nil
}
type Process struct {
Metadata *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
Processes []*ProcessInfo `protobuf:"bytes,2,rep,name=processes,proto3" json:"processes,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Process) Reset() { *m = Process{} }
func (m *Process) String() string { return proto.CompactTextString(m) }
func (*Process) ProtoMessage() {}
func (*Process) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{7}
}
func (m *Process) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Process.Unmarshal(m, b)
}
func (m *Process) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Process.Marshal(b, m, deterministic)
}
func (m *Process) XXX_Merge(src proto.Message) {
xxx_messageInfo_Process.Merge(m, src)
}
func (m *Process) XXX_Size() int {
return xxx_messageInfo_Process.Size(m)
}
func (m *Process) XXX_DiscardUnknown() {
xxx_messageInfo_Process.DiscardUnknown(m)
}
var xxx_messageInfo_Process proto.InternalMessageInfo
func (m *Process) GetMetadata() *common.Metadata {
if m != nil {
return m.Metadata
}
return nil
}
func (m *Process) GetProcesses() []*ProcessInfo {
if m != nil {
return m.Processes
}
return nil
}
type ProcessInfo struct {
Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
Ppid int32 `protobuf:"varint,2,opt,name=ppid,proto3" json:"ppid,omitempty"`
State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
Threads int32 `protobuf:"varint,4,opt,name=threads,proto3" json:"threads,omitempty"`
CpuTime float64 `protobuf:"fixed64,5,opt,name=cpu_time,json=cpuTime,proto3" json:"cpu_time,omitempty"`
VirtualMemory uint64 `protobuf:"varint,6,opt,name=virtual_memory,json=virtualMemory,proto3" json:"virtual_memory,omitempty"`
ResidentMemory uint64 `protobuf:"varint,7,opt,name=resident_memory,json=residentMemory,proto3" json:"resident_memory,omitempty"`
Command string `protobuf:"bytes,8,opt,name=command,proto3" json:"command,omitempty"`
Executable string `protobuf:"bytes,9,opt,name=executable,proto3" json:"executable,omitempty"`
Args string `protobuf:"bytes,10,opt,name=args,proto3" json:"args,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ProcessInfo) Reset() { *m = ProcessInfo{} }
func (m *ProcessInfo) String() string { return proto.CompactTextString(m) }
func (*ProcessInfo) ProtoMessage() {}
func (*ProcessInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{8}
}
func (m *ProcessInfo) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ProcessInfo.Unmarshal(m, b)
}
func (m *ProcessInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ProcessInfo.Marshal(b, m, deterministic)
}
func (m *ProcessInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_ProcessInfo.Merge(m, src)
}
func (m *ProcessInfo) XXX_Size() int {
return xxx_messageInfo_ProcessInfo.Size(m)
}
func (m *ProcessInfo) XXX_DiscardUnknown() {
xxx_messageInfo_ProcessInfo.DiscardUnknown(m)
}
var xxx_messageInfo_ProcessInfo proto.InternalMessageInfo
func (m *ProcessInfo) GetPid() int32 {
if m != nil {
return m.Pid
}
return 0
}
func (m *ProcessInfo) GetPpid() int32 {
if m != nil {
return m.Ppid
}
return 0
}
func (m *ProcessInfo) GetState() string {
if m != nil {
return m.State
}
return ""
}
func (m *ProcessInfo) GetThreads() int32 {
if m != nil {
return m.Threads
}
return 0
}
func (m *ProcessInfo) GetCpuTime() float64 {
if m != nil {
return m.CpuTime
}
return 0
}
func (m *ProcessInfo) GetVirtualMemory() uint64 {
if m != nil {
return m.VirtualMemory
}
return 0
}
func (m *ProcessInfo) GetResidentMemory() uint64 {
if m != nil {
return m.ResidentMemory
}
return 0
}
func (m *ProcessInfo) GetCommand() string {
if m != nil {
return m.Command
}
return ""
}
func (m *ProcessInfo) GetExecutable() string {
if m != nil {
return m.Executable
}
return ""
}
func (m *ProcessInfo) GetArgs() string {
if m != nil {
return m.Args
}
return ""
}
// rpc restart
// The request message containing the process to restart.
type RestartRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
// driver might be default "containerd" or "cri"
Driver common.ContainerDriver `protobuf:"varint,3,opt,name=driver,proto3,enum=common.ContainerDriver" json:"driver,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *RestartRequest) Reset() { *m = RestartRequest{} }
func (m *RestartRequest) String() string { return proto.CompactTextString(m) }
func (*RestartRequest) ProtoMessage() {}
func (*RestartRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{9}
}
func (m *RestartRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RestartRequest.Unmarshal(m, b)
}
func (m *RestartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RestartRequest.Marshal(b, m, deterministic)
}
func (m *RestartRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_RestartRequest.Merge(m, src)
}
func (m *RestartRequest) XXX_Size() int {
return xxx_messageInfo_RestartRequest.Size(m)
}
func (m *RestartRequest) XXX_DiscardUnknown() {
xxx_messageInfo_RestartRequest.DiscardUnknown(m)
}
var xxx_messageInfo_RestartRequest proto.InternalMessageInfo
func (m *RestartRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *RestartRequest) GetId() string {
if m != nil {
return m.Id
}
return ""
}
func (m *RestartRequest) GetDriver() common.ContainerDriver {
if m != nil {
return m.Driver
}
return common.ContainerDriver_CONTAINERD
}
type Restart struct {
Metadata *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Restart) Reset() { *m = Restart{} }
func (m *Restart) String() string { return proto.CompactTextString(m) }
func (*Restart) ProtoMessage() {}
func (*Restart) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{10}
}
func (m *Restart) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Restart.Unmarshal(m, b)
}
func (m *Restart) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Restart.Marshal(b, m, deterministic)
}
func (m *Restart) XXX_Merge(src proto.Message) {
xxx_messageInfo_Restart.Merge(m, src)
}
func (m *Restart) XXX_Size() int {
return xxx_messageInfo_Restart.Size(m)
}
func (m *Restart) XXX_DiscardUnknown() {
xxx_messageInfo_Restart.DiscardUnknown(m)
}
var xxx_messageInfo_Restart proto.InternalMessageInfo
func (m *Restart) GetMetadata() *common.Metadata {
if m != nil {
return m.Metadata
}
return nil
}
// The messages message containing the restart status.
type RestartResponse struct {
Messages []*Restart `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *RestartResponse) Reset() { *m = RestartResponse{} }
func (m *RestartResponse) String() string { return proto.CompactTextString(m) }
func (*RestartResponse) ProtoMessage() {}
func (*RestartResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{11}
}
func (m *RestartResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RestartResponse.Unmarshal(m, b)
}
func (m *RestartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RestartResponse.Marshal(b, m, deterministic)
}
func (m *RestartResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_RestartResponse.Merge(m, src)
}
func (m *RestartResponse) XXX_Size() int {
return xxx_messageInfo_RestartResponse.Size(m)
}
func (m *RestartResponse) XXX_DiscardUnknown() {
xxx_messageInfo_RestartResponse.DiscardUnknown(m)
}
var xxx_messageInfo_RestartResponse proto.InternalMessageInfo
func (m *RestartResponse) GetMessages() []*Restart {
if m != nil {
return m.Messages
}
return nil
}
// The request message containing the containerd namespace.
type StatsRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
// driver might be default "containerd" or "cri"
Driver common.ContainerDriver `protobuf:"varint,2,opt,name=driver,proto3,enum=common.ContainerDriver" json:"driver,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *StatsRequest) Reset() { *m = StatsRequest{} }
func (m *StatsRequest) String() string { return proto.CompactTextString(m) }
func (*StatsRequest) ProtoMessage() {}
func (*StatsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{12}
}
func (m *StatsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_StatsRequest.Unmarshal(m, b)
}
func (m *StatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_StatsRequest.Marshal(b, m, deterministic)
}
func (m *StatsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_StatsRequest.Merge(m, src)
}
func (m *StatsRequest) XXX_Size() int {
return xxx_messageInfo_StatsRequest.Size(m)
}
func (m *StatsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_StatsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_StatsRequest proto.InternalMessageInfo
func (m *StatsRequest) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *StatsRequest) GetDriver() common.ContainerDriver {
if m != nil {
return m.Driver
}
return common.ContainerDriver_CONTAINERD
}
// The messages message containing the requested stats.
type Stats struct {
Metadata *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
Stats []*Stat `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Stats) Reset() { *m = Stats{} }
func (m *Stats) String() string { return proto.CompactTextString(m) }
func (*Stats) ProtoMessage() {}
func (*Stats) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{13}
}
func (m *Stats) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Stats.Unmarshal(m, b)
}
func (m *Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Stats.Marshal(b, m, deterministic)
}
func (m *Stats) XXX_Merge(src proto.Message) {
xxx_messageInfo_Stats.Merge(m, src)
}
func (m *Stats) XXX_Size() int {
return xxx_messageInfo_Stats.Size(m)
}
func (m *Stats) XXX_DiscardUnknown() {
xxx_messageInfo_Stats.DiscardUnknown(m)
}
var xxx_messageInfo_Stats proto.InternalMessageInfo
func (m *Stats) GetMetadata() *common.Metadata {
if m != nil {
return m.Metadata
}
return nil
}
func (m *Stats) GetStats() []*Stat {
if m != nil {
return m.Stats
}
return nil
}
type StatsResponse struct {
Messages []*Stats `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *StatsResponse) Reset() { *m = StatsResponse{} }
func (m *StatsResponse) String() string { return proto.CompactTextString(m) }
func (*StatsResponse) ProtoMessage() {}
func (*StatsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{14}
}
func (m *StatsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_StatsResponse.Unmarshal(m, b)
}
func (m *StatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_StatsResponse.Marshal(b, m, deterministic)
}
func (m *StatsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_StatsResponse.Merge(m, src)
}
func (m *StatsResponse) XXX_Size() int {
return xxx_messageInfo_StatsResponse.Size(m)
}
func (m *StatsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_StatsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_StatsResponse proto.InternalMessageInfo
func (m *StatsResponse) GetMessages() []*Stats {
if m != nil {
return m.Messages
}
return nil
}
// The messages message containing the requested stat.
type Stat struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
MemoryUsage uint64 `protobuf:"varint,4,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`
CpuUsage uint64 `protobuf:"varint,5,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`
PodId string `protobuf:"bytes,6,opt,name=pod_id,json=podId,proto3" json:"pod_id,omitempty"`
Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Stat) Reset() { *m = Stat{} }
func (m *Stat) String() string { return proto.CompactTextString(m) }
func (*Stat) ProtoMessage() {}
func (*Stat) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{15}
}
func (m *Stat) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Stat.Unmarshal(m, b)
}
func (m *Stat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Stat.Marshal(b, m, deterministic)
}
func (m *Stat) XXX_Merge(src proto.Message) {
xxx_messageInfo_Stat.Merge(m, src)
}
func (m *Stat) XXX_Size() int {
return xxx_messageInfo_Stat.Size(m)
}
func (m *Stat) XXX_DiscardUnknown() {
xxx_messageInfo_Stat.DiscardUnknown(m)
}
var xxx_messageInfo_Stat proto.InternalMessageInfo
func (m *Stat) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *Stat) GetId() string {
if m != nil {
return m.Id
}
return ""
}
func (m *Stat) GetMemoryUsage() uint64 {
if m != nil {
return m.MemoryUsage
}
return 0
}
func (m *Stat) GetCpuUsage() uint64 {
if m != nil {
return m.CpuUsage
}
return 0
}
func (m *Stat) GetPodId() string {
if m != nil {
return m.PodId
}
return ""
}
func (m *Stat) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type Memory struct {
Metadata *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
Meminfo *MemInfo `protobuf:"bytes,2,opt,name=meminfo,proto3" json:"meminfo,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Memory) Reset() { *m = Memory{} }
func (m *Memory) String() string { return proto.CompactTextString(m) }
func (*Memory) ProtoMessage() {}
func (*Memory) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{16}
}
func (m *Memory) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Memory.Unmarshal(m, b)
}
func (m *Memory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Memory.Marshal(b, m, deterministic)
}
func (m *Memory) XXX_Merge(src proto.Message) {
xxx_messageInfo_Memory.Merge(m, src)
}
func (m *Memory) XXX_Size() int {
return xxx_messageInfo_Memory.Size(m)
}
func (m *Memory) XXX_DiscardUnknown() {
xxx_messageInfo_Memory.DiscardUnknown(m)
}
var xxx_messageInfo_Memory proto.InternalMessageInfo
func (m *Memory) GetMetadata() *common.Metadata {
if m != nil {
return m.Metadata
}
return nil
}
func (m *Memory) GetMeminfo() *MemInfo {
if m != nil {
return m.Meminfo
}
return nil
}
type MemoryResponse struct {
Messages []*Memory `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *MemoryResponse) Reset() { *m = MemoryResponse{} }
func (m *MemoryResponse) String() string { return proto.CompactTextString(m) }
func (*MemoryResponse) ProtoMessage() {}
func (*MemoryResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{17}
}
func (m *MemoryResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MemoryResponse.Unmarshal(m, b)
}
func (m *MemoryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MemoryResponse.Marshal(b, m, deterministic)
}
func (m *MemoryResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_MemoryResponse.Merge(m, src)
}
func (m *MemoryResponse) XXX_Size() int {
return xxx_messageInfo_MemoryResponse.Size(m)
}
func (m *MemoryResponse) XXX_DiscardUnknown() {
xxx_messageInfo_MemoryResponse.DiscardUnknown(m)
}
var xxx_messageInfo_MemoryResponse proto.InternalMessageInfo
func (m *MemoryResponse) GetMessages() []*Memory {
if m != nil {
return m.Messages
}
return nil
}
type MemInfo struct {
Memtotal uint64 `protobuf:"varint,1,opt,name=memtotal,proto3" json:"memtotal,omitempty"`
Memfree uint64 `protobuf:"varint,2,opt,name=memfree,proto3" json:"memfree,omitempty"`
Memavailable uint64 `protobuf:"varint,3,opt,name=memavailable,proto3" json:"memavailable,omitempty"`
Buffers uint64 `protobuf:"varint,4,opt,name=buffers,proto3" json:"buffers,omitempty"`
Cached uint64 `protobuf:"varint,5,opt,name=cached,proto3" json:"cached,omitempty"`
Swapcached uint64 `protobuf:"varint,6,opt,name=swapcached,proto3" json:"swapcached,omitempty"`
Active uint64 `protobuf:"varint,7,opt,name=active,proto3" json:"active,omitempty"`
Inactive uint64 `protobuf:"varint,8,opt,name=inactive,proto3" json:"inactive,omitempty"`
Activeanon uint64 `protobuf:"varint,9,opt,name=activeanon,proto3" json:"activeanon,omitempty"`
Inactiveanon uint64 `protobuf:"varint,10,opt,name=inactiveanon,proto3" json:"inactiveanon,omitempty"`
Activefile uint64 `protobuf:"varint,11,opt,name=activefile,proto3" json:"activefile,omitempty"`
Inactivefile uint64 `protobuf:"varint,12,opt,name=inactivefile,proto3" json:"inactivefile,omitempty"`
Unevictable uint64 `protobuf:"varint,13,opt,name=unevictable,proto3" json:"unevictable,omitempty"`
Mlocked uint64 `protobuf:"varint,14,opt,name=mlocked,proto3" json:"mlocked,omitempty"`
Swaptotal uint64 `protobuf:"varint,15,opt,name=swaptotal,proto3" json:"swaptotal,omitempty"`
Swapfree uint64 `protobuf:"varint,16,opt,name=swapfree,proto3" json:"swapfree,omitempty"`
Dirty uint64 `protobuf:"varint,17,opt,name=dirty,proto3" json:"dirty,omitempty"`
Writeback uint64 `protobuf:"varint,18,opt,name=writeback,proto3" json:"writeback,omitempty"`
Anonpages uint64 `protobuf:"varint,19,opt,name=anonpages,proto3" json:"anonpages,omitempty"`
Mapped uint64 `protobuf:"varint,20,opt,name=mapped,proto3" json:"mapped,omitempty"`
Shmem uint64 `protobuf:"varint,21,opt,name=shmem,proto3" json:"shmem,omitempty"`
Slab uint64 `protobuf:"varint,22,opt,name=slab,proto3" json:"slab,omitempty"`
Sreclaimable uint64 `protobuf:"varint,23,opt,name=sreclaimable,proto3" json:"sreclaimable,omitempty"`
Sunreclaim uint64 `protobuf:"varint,24,opt,name=sunreclaim,proto3" json:"sunreclaim,omitempty"`
Kernelstack uint64 `protobuf:"varint,25,opt,name=kernelstack,proto3" json:"kernelstack,omitempty"`
Pagetables uint64 `protobuf:"varint,26,opt,name=pagetables,proto3" json:"pagetables,omitempty"`
Nfsunstable uint64 `protobuf:"varint,27,opt,name=nfsunstable,proto3" json:"nfsunstable,omitempty"`
Bounce uint64 `protobuf:"varint,28,opt,name=bounce,proto3" json:"bounce,omitempty"`
Writebacktmp uint64 `protobuf:"varint,29,opt,name=writebacktmp,proto3" json:"writebacktmp,omitempty"`
Commitlimit uint64 `protobuf:"varint,30,opt,name=commitlimit,proto3" json:"commitlimit,omitempty"`
Committedas uint64 `protobuf:"varint,31,opt,name=committedas,proto3" json:"committedas,omitempty"`
Vmalloctotal uint64 `protobuf:"varint,32,opt,name=vmalloctotal,proto3" json:"vmalloctotal,omitempty"`
Vmallocused uint64 `protobuf:"varint,33,opt,name=vmallocused,proto3" json:"vmallocused,omitempty"`
Vmallocchunk uint64 `protobuf:"varint,34,opt,name=vmallocchunk,proto3" json:"vmallocchunk,omitempty"`
Hardwarecorrupted uint64 `protobuf:"varint,35,opt,name=hardwarecorrupted,proto3" json:"hardwarecorrupted,omitempty"`
Anonhugepages uint64 `protobuf:"varint,36,opt,name=anonhugepages,proto3" json:"anonhugepages,omitempty"`
Shmemhugepages uint64 `protobuf:"varint,37,opt,name=shmemhugepages,proto3" json:"shmemhugepages,omitempty"`
Shmempmdmapped uint64 `protobuf:"varint,38,opt,name=shmempmdmapped,proto3" json:"shmempmdmapped,omitempty"`
Cmatotal uint64 `protobuf:"varint,39,opt,name=cmatotal,proto3" json:"cmatotal,omitempty"`
Cmafree uint64 `protobuf:"varint,40,opt,name=cmafree,proto3" json:"cmafree,omitempty"`
Hugepagestotal uint64 `protobuf:"varint,41,opt,name=hugepagestotal,proto3" json:"hugepagestotal,omitempty"`
Hugepagesfree uint64 `protobuf:"varint,42,opt,name=hugepagesfree,proto3" json:"hugepagesfree,omitempty"`
Hugepagesrsvd uint64 `protobuf:"varint,43,opt,name=hugepagesrsvd,proto3" json:"hugepagesrsvd,omitempty"`
Hugepagessurp uint64 `protobuf:"varint,44,opt,name=hugepagessurp,proto3" json:"hugepagessurp,omitempty"`
Hugepagesize uint64 `protobuf:"varint,45,opt,name=hugepagesize,proto3" json:"hugepagesize,omitempty"`
Directmap4K uint64 `protobuf:"varint,46,opt,name=directmap4k,proto3" json:"directmap4k,omitempty"`
Directmap2M uint64 `protobuf:"varint,47,opt,name=directmap2m,proto3" json:"directmap2m,omitempty"`
Directmap1G uint64 `protobuf:"varint,48,opt,name=directmap1g,proto3" json:"directmap1g,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *MemInfo) Reset() { *m = MemInfo{} }
func (m *MemInfo) String() string { return proto.CompactTextString(m) }
func (*MemInfo) ProtoMessage() {}
func (*MemInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_b20a722d09fd3254, []int{18}
}
func (m *MemInfo) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MemInfo.Unmarshal(m, b)
}
func (m *MemInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MemInfo.Marshal(b, m, deterministic)
}
func (m *MemInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_MemInfo.Merge(m, src)
}
func (m *MemInfo) XXX_Size() int {
return xxx_messageInfo_MemInfo.Size(m)
}
func (m *MemInfo) XXX_DiscardUnknown() {
xxx_messageInfo_MemInfo.DiscardUnknown(m)
}
var xxx_messageInfo_MemInfo proto.InternalMessageInfo
func (m *MemInfo) GetMemtotal() uint64 {
if m != nil {
return m.Memtotal
}
return 0
}
func (m *MemInfo) GetMemfree() uint64 {
if m != nil {
return m.Memfree
}
return 0
}
func (m *MemInfo) GetMemavailable() uint64 {
if m != nil {
return m.Memavailable
}
return 0
}
func (m *MemInfo) GetBuffers() uint64 {
if m != nil {
return m.Buffers
}
return 0
}
func (m *MemInfo) GetCached() uint64 {
if m != nil {
return m.Cached
}
return 0
}
func (m *MemInfo) GetSwapcached() uint64 {
if m != nil {
return m.Swapcached
}
return 0
}
func (m *MemInfo) GetActive() uint64 {
if m != nil {
return m.Active
}
return 0
}
func (m *MemInfo) GetInactive() uint64 {
if m != nil {
return m.Inactive
}
return 0
}
func (m *MemInfo) GetActiveanon() uint64 {
if m != nil {
return m.Activeanon
}
return 0
}
func (m *MemInfo) GetInactiveanon() uint64 {
if m != nil {
return m.Inactiveanon
}
return 0
}
func (m *MemInfo) GetActivefile() uint64 {
if m != nil {
return m.Activefile
}
return 0
}
func (m *MemInfo) GetInactivefile() uint64 {
if m != nil {
return m.Inactivefile
}
return 0
}
func (m *MemInfo) GetUnevictable() uint64 {
if m != nil {
return m.Unevictable
}
return 0
}
func (m *MemInfo) GetMlocked() uint64 {
if m != nil {
return m.Mlocked
}
return 0
}
func (m *MemInfo) GetSwaptotal() uint64 {
if m != nil {
return m.Swaptotal
}
return 0
}
func (m *MemInfo) GetSwapfree() uint64 {
if m != nil {
return m.Swapfree
}
return 0
}
func (m *MemInfo) GetDirty() uint64 {
if m != nil {
return m.Dirty
}
return 0
}
func (m *MemInfo) GetWriteback() uint64 {
if m != nil {
return m.Writeback
}
return 0
}
func (m *MemInfo) GetAnonpages() uint64 {
if m != nil {
return m.Anonpages
}
return 0
}
func (m *MemInfo) GetMapped() uint64 {
if m != nil {
return m.Mapped
}
return 0
}
func (m *MemInfo) GetShmem() uint64 {
if m != nil {
return m.Shmem
}
return 0
}
func (m *MemInfo) GetSlab() uint64 {
if m != nil {
return m.Slab
}
return 0
}
func (m *MemInfo) GetSreclaimable() uint64 {
if m != nil {
return m.Sreclaimable
}
return 0
}
func (m *MemInfo) GetSunreclaim() uint64 {
if m != nil {
return m.Sunreclaim
}
return 0
}
func (m *MemInfo) GetKernelstack() uint64 {
if m != nil {
return m.Kernelstack
}
return 0
}
func (m *MemInfo) GetPagetables() uint64 {
if m != nil {
return m.Pagetables
}
return 0
}
func (m *MemInfo) GetNfsunstable() uint64 {
if m != nil {
return m.Nfsunstable
}
return 0
}
func (m *MemInfo) GetBounce() uint64 {
if m != nil {
return m.Bounce
}
return 0
}
func (m *MemInfo) GetWritebacktmp() uint64 {
if m != nil {
return m.Writebacktmp
}
return 0
}
func (m *MemInfo) GetCommitlimit() uint64 {
if m != nil {
return m.Commitlimit
}
return 0
}
func (m *MemInfo) GetCommittedas() uint64 {
if m != nil {
return m.Committedas
}
return 0
}
func (m *MemInfo) GetVmalloctotal() uint64 {
if m != nil {
return m.Vmalloctotal
}
return 0
}
func (m *MemInfo) GetVmallocused() uint64 {
if m != nil {
return m.Vmallocused
}
return 0
}
func (m *MemInfo) GetVmallocchunk() uint64 {
if m != nil {
return m.Vmallocchunk
}
return 0
}
func (m *MemInfo) GetHardwarecorrupted() uint64 {
if m != nil {
return m.Hardwarecorrupted
}
return 0
}
func (m *MemInfo) GetAnonhugepages() uint64 {
if m != nil {
return m.Anonhugepages
}
return 0
}
func (m *MemInfo) GetShmemhugepages() uint64 {
if m != nil {
return m.Shmemhugepages
}
return 0
}
func (m *MemInfo) GetShmempmdmapped() uint64 {
if m != nil {
return m.Shmempmdmapped
}
return 0
}
func (m *MemInfo) GetCmatotal() uint64 {
if m != nil {
return m.Cmatotal
}
return 0
}
func (m *MemInfo) GetCmafree() uint64 {
if m != nil {
return m.Cmafree
}
return 0
}
func (m *MemInfo) GetHugepagestotal() uint64 {
if m != nil {
return m.Hugepagestotal
}
return 0
}
func (m *MemInfo) GetHugepagesfree() uint64 {
if m != nil {
return m.Hugepagesfree
}
return 0
}
func (m *MemInfo) GetHugepagesrsvd() uint64 {
if m != nil {
return m.Hugepagesrsvd
}
return 0
}
func (m *MemInfo) GetHugepagessurp() uint64 {
if m != nil {
return m.Hugepagessurp
}
return 0
}
func (m *MemInfo) GetHugepagesize() uint64 {
if m != nil {
return m.Hugepagesize
}
return 0
}
func (m *MemInfo) GetDirectmap4K() uint64 {
if m != nil {
return m.Directmap4K
}
return 0
}
func (m *MemInfo) GetDirectmap2M() uint64 {
if m != nil {
return m.Directmap2M
}
return 0
}
func (m *MemInfo) GetDirectmap1G() uint64 {
if m != nil {
return m.Directmap1G
}
return 0
}
func init() {
proto.RegisterType((*ContainersRequest)(nil), "os.ContainersRequest")
proto.RegisterType((*ContainerInfo)(nil), "os.ContainerInfo")
proto.RegisterType((*Container)(nil), "os.Container")
proto.RegisterType((*ContainersResponse)(nil), "os.ContainersResponse")
proto.RegisterType((*DmesgRequest)(nil), "os.DmesgRequest")
proto.RegisterType((*ProcessesRequest)(nil), "os.ProcessesRequest")
proto.RegisterType((*ProcessesResponse)(nil), "os.ProcessesResponse")
proto.RegisterType((*Process)(nil), "os.Process")
proto.RegisterType((*ProcessInfo)(nil), "os.ProcessInfo")
proto.RegisterType((*RestartRequest)(nil), "os.RestartRequest")
proto.RegisterType((*Restart)(nil), "os.Restart")
proto.RegisterType((*RestartResponse)(nil), "os.RestartResponse")
proto.RegisterType((*StatsRequest)(nil), "os.StatsRequest")
proto.RegisterType((*Stats)(nil), "os.Stats")
proto.RegisterType((*StatsResponse)(nil), "os.StatsResponse")
proto.RegisterType((*Stat)(nil), "os.Stat")
proto.RegisterType((*Memory)(nil), "os.Memory")
proto.RegisterType((*MemoryResponse)(nil), "os.MemoryResponse")
proto.RegisterType((*MemInfo)(nil), "os.MemInfo")
}
func init() { proto.RegisterFile("os/os.proto", fileDescriptor_b20a722d09fd3254) }
var fileDescriptor_b20a722d09fd3254 = []byte{
// 1437 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x57, 0xdf, 0x6e, 0xdb, 0xb6,
0x17, 0x86, 0x13, 0x3b, 0x8e, 0xe9, 0xc4, 0x49, 0xd8, 0x26, 0x65, 0xd3, 0xfe, 0xfa, 0x4b, 0xbd,
0xa6, 0x4d, 0xb7, 0xd4, 0x6e, 0xb3, 0x62, 0x1b, 0xba, 0x02, 0xc3, 0xba, 0xee, 0xa2, 0x17, 0x45,
0x0b, 0x75, 0xbd, 0x19, 0x50, 0x04, 0xb4, 0x44, 0x3b, 0x44, 0x44, 0x51, 0x13, 0x29, 0x67, 0xd9,
0x2b, 0xec, 0x15, 0x06, 0xec, 0x76, 0x6f, 0xb2, 0xd7, 0x1a, 0xce, 0x21, 0x25, 0x53, 0x09, 0xb6,
0x35, 0x17, 0xbb, 0xb2, 0xce, 0x77, 0x3e, 0x1d, 0x9e, 0x3f, 0x1f, 0x29, 0x9a, 0xf4, 0xb5, 0x19,
0x6b, 0x33, 0xca, 0x0b, 0x6d, 0x35, 0x5d, 0xd2, 0x66, 0xf7, 0xd6, 0x4c, 0xeb, 0x59, 0x2a, 0xc6,
0x88, 0x4c, 0xca, 0xe9, 0x58, 0xa8, 0xdc, 0x9e, 0x3b, 0xc2, 0xee, 0xb5, 0x58, 0x2b, 0xa5, 0xb3,
0xb1, 0xfb, 0x71, 0xe0, 0x70, 0x42, 0xb6, 0xbe, 0xd3, 0x99, 0xe5, 0x32, 0x13, 0x85, 0x89, 0xc4,
0x4f, 0xa5, 0x30, 0x96, 0xde, 0x26, 0xbd, 0x8c, 0x2b, 0x61, 0x72, 0x1e, 0x0b, 0xd6, 0xda, 0x6b,
0x1d, 0xf4, 0xa2, 0x05, 0x40, 0xc7, 0x64, 0x25, 0x29, 0xe4, 0x5c, 0x14, 0x6c, 0x69, 0xaf, 0x75,
0x30, 0x38, 0xba, 0x31, 0xf2, 0x11, 0xeb, 0x40, 0x2f, 0xd1, 0x1d, 0x79, 0xda, 0xf0, 0x8f, 0x16,
0x59, 0xaf, 0x7d, 0xaf, 0xb2, 0xa9, 0xfe, 0x97, 0x05, 0x06, 0x64, 0x49, 0x26, 0x18, 0xbc, 0x17,
0x2d, 0xc9, 0x84, 0x5e, 0x27, 0x1d, 0xa9, 0xf8, 0x4c, 0xb0, 0x65, 0x84, 0x9c, 0x41, 0x37, 0xc9,
0x72, 0x2e, 0x13, 0xd6, 0xde, 0x6b, 0x1d, 0xac, 0x47, 0xf0, 0x48, 0x77, 0xc8, 0x8a, 0xb1, 0xdc,
0x96, 0x86, 0x75, 0x90, 0xe8, 0x2d, 0xba, 0x4d, 0x56, 0x72, 0x9d, 0x1c, 0xcb, 0x84, 0xad, 0xb8,
0x00, 0xb9, 0x4e, 0x5e, 0x25, 0x94, 0x92, 0x36, 0xac, 0xc9, 0xba, 0x08, 0xe2, 0xf3, 0x30, 0x25,
0xbd, 0x3a, 0x53, 0x7a, 0x48, 0x56, 0x95, 0xb0, 0x3c, 0xe1, 0x96, 0x63, 0x92, 0xfd, 0xa3, 0xcd,
0xaa, 0xd4, 0xd7, 0x1e, 0x8f, 0x6a, 0x06, 0x7d, 0x42, 0x48, 0x5c, 0x77, 0x92, 0x2d, 0xed, 0x2d,
0x1f, 0xf4, 0x8f, 0xb6, 0x46, 0xda, 0x8c, 0x1a, 0xa5, 0x47, 0x01, 0x69, 0xf8, 0x0d, 0xa1, 0x61,
0xf3, 0x4d, 0xae, 0x33, 0x23, 0xe8, 0x43, 0x58, 0xd6, 0x18, 0x3e, 0x13, 0x86, 0xb5, 0x30, 0xcc,
0x7a, 0x23, 0x4c, 0x54, 0xbb, 0x87, 0xcf, 0xc8, 0xda, 0x4b, 0x25, 0xcc, 0xac, 0x1a, 0xdc, 0x0e,
0x59, 0x99, 0xea, 0x34, 0xd5, 0x67, 0x98, 0xef, 0x6a, 0xe4, 0x2d, 0x28, 0xd5, 0x72, 0x99, 0x62,
0x4f, 0x57, 0x23, 0x7c, 0x1e, 0x52, 0xb2, 0xf9, 0xb6, 0xd0, 0xb1, 0x30, 0x46, 0x54, 0x83, 0x1f,
0x3e, 0x27, 0x5b, 0x01, 0xe6, 0xf3, 0x79, 0x70, 0x29, 0x9f, 0x3e, 0xe4, 0xe3, 0x89, 0x41, 0x36,
0x53, 0xd2, 0xf5, 0xe0, 0x15, 0x5b, 0xf7, 0x88, 0xf4, 0xf2, 0x6a, 0x59, 0xdf, 0xb9, 0x8d, 0x60,
0x09, 0xec, 0xdb, 0x82, 0x31, 0xfc, 0x6d, 0x89, 0xf4, 0x03, 0x57, 0xa5, 0x04, 0x58, 0xa7, 0xe3,
0x94, 0x40, 0x49, 0x3b, 0xcf, 0xbd, 0x86, 0x3a, 0x11, 0x3e, 0x83, 0x8a, 0x40, 0x0f, 0xb5, 0x8a,
0xd0, 0xa0, 0x8c, 0x74, 0xed, 0x49, 0x21, 0x78, 0x62, 0x50, 0x49, 0x9d, 0xa8, 0x32, 0xe9, 0x4d,
0xb2, 0x1a, 0xe7, 0xe5, 0xb1, 0x95, 0x4a, 0xa0, 0x9e, 0x5a, 0x51, 0x37, 0xce, 0xcb, 0x1f, 0xa4,
0x12, 0x74, 0x9f, 0x0c, 0xe6, 0xb2, 0xb0, 0x25, 0x4f, 0x8f, 0x95, 0x50, 0xba, 0x38, 0x47, 0x61,
0xb5, 0xa3, 0x75, 0x8f, 0xbe, 0x46, 0x90, 0x3e, 0x20, 0x1b, 0x85, 0x30, 0x32, 0x11, 0x99, 0xad,
0x78, 0x5d, 0xe4, 0x0d, 0x2a, 0xd8, 0x13, 0x19, 0xe9, 0x42, 0x73, 0x78, 0x96, 0xb0, 0x55, 0x4c,
0xae, 0x32, 0xe9, 0x1d, 0x42, 0xc4, 0xcf, 0x22, 0x2e, 0x2d, 0x9f, 0xa4, 0x82, 0xf5, 0xd0, 0x19,
0x20, 0x50, 0x28, 0x2f, 0x66, 0x86, 0x11, 0xa7, 0x61, 0x78, 0x1e, 0x6a, 0x32, 0x88, 0x84, 0xb1,
0xbc, 0xb0, 0x1f, 0xb7, 0x9f, 0x2f, 0x6e, 0xb7, 0xc5, 0xfe, 0x5e, 0xfe, 0xb8, 0xfd, 0xfd, 0x25,
0xe9, 0xfa, 0x05, 0xaf, 0x36, 0xf7, 0xe1, 0x33, 0xb2, 0x51, 0x67, 0xfa, 0xcf, 0x62, 0xab, 0x68,
0x0b, 0xb1, 0x7d, 0x20, 0x6b, 0xef, 0x2c, 0xb7, 0xff, 0xd5, 0x99, 0xf5, 0x9e, 0x74, 0x30, 0xfc,
0x15, 0x95, 0x7c, 0xc7, 0x89, 0xac, 0x52, 0xf1, 0x2a, 0xe4, 0x0e, 0x71, 0x9c, 0xdc, 0xcc, 0xf0,
0x0b, 0xb2, 0xee, 0xb3, 0xf6, 0xf5, 0xee, 0x5f, 0xaa, 0xb7, 0x57, 0xbd, 0x13, 0x6e, 0xad, 0xdf,
0x5b, 0xa4, 0x0d, 0xd8, 0x15, 0x47, 0x79, 0x97, 0xac, 0x39, 0xe1, 0x1d, 0x97, 0x10, 0x07, 0x25,
0xde, 0x8e, 0xfa, 0x0e, 0x7b, 0x0f, 0x10, 0xbd, 0x45, 0x7a, 0x20, 0x73, 0xe7, 0xef, 0xa0, 0x1f,
0x74, 0xef, 0x9c, 0x57, 0x38, 0x39, 0x3f, 0x90, 0x15, 0xaf, 0xe6, 0xab, 0x75, 0x6c, 0x9f, 0x74,
0x95, 0x50, 0x32, 0x9b, 0x6a, 0xcc, 0xdb, 0xcf, 0xfb, 0xb5, 0x50, 0xb8, 0xeb, 0x2b, 0xdf, 0xf0,
0x2b, 0x32, 0x70, 0xe1, 0xeb, 0xce, 0xdd, 0xbf, 0xd4, 0x39, 0xe2, 0xdf, 0x04, 0xd6, 0xa2, 0x75,
0xbf, 0xae, 0x91, 0xae, 0x0f, 0x47, 0x77, 0xe1, 0x1d, 0x65, 0xb5, 0xe5, 0x29, 0xa6, 0xd6, 0x8e,
0x6a, 0x1b, 0x36, 0xa1, 0x12, 0x6a, 0x5a, 0x08, 0x81, 0x89, 0xb4, 0xa3, 0xca, 0xa4, 0x43, 0xec,
0x22, 0x9f, 0x73, 0x99, 0xe2, 0x36, 0x5c, 0x46, 0x77, 0x03, 0x83, 0xb7, 0x27, 0xe5, 0x74, 0x0a,
0x47, 0xbf, 0x6b, 0x72, 0x65, 0xc2, 0x99, 0x1c, 0xf3, 0xf8, 0x44, 0x24, 0xbe, 0xbb, 0xde, 0x82,
0xad, 0x6d, 0xce, 0x78, 0xee, 0x7d, 0xee, 0x00, 0x09, 0x10, 0x78, 0x8f, 0xc7, 0x56, 0xce, 0x85,
0x3f, 0x34, 0xbc, 0x05, 0x35, 0xc8, 0xcc, 0x7b, 0x56, 0x5d, 0x0d, 0x95, 0x0d, 0x31, 0xdd, 0x13,
0xcf, 0x74, 0x86, 0xc7, 0x45, 0x3b, 0x0a, 0x10, 0xa8, 0xa4, 0xe2, 0x22, 0x83, 0xb8, 0x4a, 0x42,
0x6c, 0x11, 0x63, 0x2a, 0x53, 0xc1, 0xfa, 0x61, 0x0c, 0x40, 0xc2, 0x18, 0xc8, 0x58, 0x6b, 0xc6,
0x40, 0xce, 0x1e, 0xe9, 0x97, 0x99, 0x98, 0xcb, 0xd8, 0x9d, 0x5b, 0xeb, 0x4e, 0x76, 0x01, 0x84,
0xdd, 0x4e, 0x75, 0x7c, 0x2a, 0x12, 0x36, 0xf0, 0xdd, 0x76, 0x26, 0x28, 0x1c, 0xba, 0xe0, 0x86,
0xb4, 0x81, 0xbe, 0x05, 0x00, 0xd5, 0x83, 0x81, 0x63, 0xda, 0x74, 0xd5, 0x57, 0x36, 0x9c, 0xf0,
0x89, 0x2c, 0xec, 0x39, 0xdb, 0x42, 0x87, 0x33, 0x20, 0xde, 0x59, 0x21, 0xad, 0x98, 0xf0, 0xf8,
0x94, 0x51, 0x17, 0xaf, 0x06, 0xc0, 0x0b, 0x55, 0xe7, 0x28, 0xa3, 0x6b, 0xce, 0x5b, 0x03, 0x30,
0x03, 0xc5, 0xf3, 0x5c, 0x24, 0xec, 0xba, 0x9b, 0x81, 0xb3, 0xf0, 0x5b, 0x72, 0xa2, 0x84, 0x62,
0xdb, 0x6e, 0x25, 0x34, 0x60, 0x5b, 0x98, 0x94, 0x4f, 0xd8, 0x0e, 0x82, 0xf8, 0x0c, 0xdd, 0x32,
0x85, 0x88, 0x53, 0x2e, 0x15, 0xb6, 0xe2, 0x86, 0xeb, 0x56, 0x88, 0xa1, 0x12, 0xca, 0xcc, 0x23,
0x8c, 0x79, 0x25, 0xd4, 0x08, 0x74, 0xf3, 0x54, 0x14, 0x99, 0x48, 0x8d, 0x85, 0x1a, 0x6e, 0xba,
0x6e, 0x06, 0x10, 0x44, 0x80, 0x84, 0xb1, 0xb5, 0x86, 0xed, 0xba, 0x08, 0x0b, 0x04, 0x22, 0x64,
0x53, 0x53, 0x66, 0xc6, 0xcd, 0xe3, 0x96, 0x8b, 0x10, 0x40, 0x50, 0xe9, 0x44, 0x97, 0x59, 0x2c,
0xd8, 0x6d, 0x57, 0xa9, 0xb3, 0x20, 0xff, 0xba, 0x59, 0x56, 0xe5, 0xec, 0x7f, 0x2e, 0xff, 0x10,
0x83, 0xe8, 0xb0, 0xbf, 0xa5, 0x4d, 0xa5, 0x92, 0x96, 0xdd, 0x71, 0xd1, 0x03, 0x68, 0xc1, 0xb0,
0x22, 0xe1, 0x86, 0xfd, 0x3f, 0x64, 0x20, 0x04, 0xeb, 0xcc, 0x15, 0x4f, 0x53, 0x1d, 0xbb, 0xc1,
0xef, 0xb9, 0x75, 0x42, 0x0c, 0xa2, 0x78, 0xbb, 0x34, 0x22, 0x61, 0x77, 0x5d, 0x94, 0x00, 0x0a,
0xa2, 0xc4, 0x27, 0x65, 0x76, 0xca, 0x86, 0x8d, 0x28, 0x88, 0xd1, 0x43, 0xb2, 0x75, 0xc2, 0x8b,
0xe4, 0x8c, 0x17, 0x22, 0xd6, 0x45, 0x51, 0xe6, 0x56, 0x24, 0xec, 0x13, 0x24, 0x5e, 0x76, 0xd0,
0x7b, 0x64, 0x1d, 0xe4, 0x70, 0x52, 0xce, 0x84, 0xd3, 0xc8, 0x3d, 0xf7, 0xa5, 0x6f, 0x80, 0xf4,
0x3e, 0x19, 0xa0, 0x04, 0x16, 0xb4, 0x7d, 0xf7, 0xa1, 0x6f, 0xa2, 0x35, 0x2f, 0x57, 0x89, 0xd7,
0xd5, 0xfd, 0x80, 0x57, 0xa3, 0xa0, 0xf2, 0x58, 0x71, 0xd7, 0x89, 0x07, 0xfe, 0x4c, 0xf6, 0x36,
0x5e, 0x16, 0x14, 0xc7, 0x0d, 0x70, 0xe0, 0x76, 0x8e, 0x37, 0x21, 0x7a, 0xbd, 0x94, 0x7b, 0xf7,
0xa1, 0x8b, 0xde, 0x44, 0xa1, 0xa6, 0x1a, 0xc1, 0x38, 0x9f, 0xba, 0x9a, 0x1a, 0x60, 0x83, 0x55,
0x98, 0x79, 0xc2, 0x3e, 0xbb, 0xc0, 0x02, 0xb0, 0xc1, 0x32, 0x65, 0x91, 0xb3, 0xc3, 0x0b, 0x2c,
0x00, 0x61, 0x2e, 0x35, 0x20, 0x7f, 0x11, 0xec, 0x91, 0x9b, 0x4b, 0x88, 0xc1, 0x74, 0x13, 0x59,
0x88, 0xd8, 0x2a, 0x9e, 0x3f, 0x3d, 0x65, 0x23, 0x37, 0xdd, 0x00, 0x6a, 0x30, 0x8e, 0x14, 0x1b,
0x5f, 0x60, 0x1c, 0xa9, 0x06, 0xe3, 0xc9, 0x8c, 0x3d, 0xbe, 0xc0, 0x78, 0x32, 0x3b, 0xfa, 0x73,
0x89, 0xf4, 0xde, 0xbc, 0x7b, 0x27, 0x8a, 0xb9, 0x8c, 0x05, 0xfd, 0x9a, 0x90, 0xc5, 0x05, 0x9c,
0x6e, 0x37, 0xae, 0xd9, 0xd5, 0xcd, 0x62, 0x77, 0xe7, 0x22, 0x5c, 0xdf, 0xd3, 0x3b, 0x78, 0xf9,
0xa6, 0x9b, 0x40, 0x08, 0xef, 0xe1, 0xbb, 0x6b, 0xd5, 0x07, 0xef, 0x25, 0xb7, 0xfc, 0x71, 0x8b,
0x3e, 0xad, 0x3f, 0x8e, 0x3b, 0x23, 0xf7, 0x17, 0x6d, 0x54, 0xfd, 0x45, 0x1b, 0x7d, 0x0f, 0x7f,
0xd1, 0x76, 0x69, 0xf0, 0xed, 0xaa, 0x16, 0x78, 0x46, 0x7a, 0xf5, 0x6d, 0xfc, 0x6f, 0x5f, 0xdc,
0x0e, 0x2e, 0xca, 0xc1, 0xa5, 0xfd, 0x68, 0x71, 0x27, 0xa3, 0xe1, 0x05, 0xca, 0x27, 0x78, 0xad,
0x81, 0xf9, 0x77, 0x0e, 0xab, 0x3b, 0xcf, 0xe6, 0xe2, 0x0a, 0xe2, 0xf9, 0x5b, 0x01, 0xe2, 0xd8,
0x2f, 0x9e, 0xc3, 0xff, 0x1d, 0x05, 0x38, 0xcf, 0xe5, 0x8b, 0xce, 0x1b, 0xf3, 0x6d, 0x2e, 0xdf,
0xb6, 0x7e, 0xdc, 0x9f, 0x49, 0x7b, 0x52, 0x4e, 0xa0, 0x01, 0x63, 0xcb, 0x53, 0x6d, 0x1e, 0x99,
0x73, 0x63, 0x85, 0x32, 0xce, 0x1a, 0xf3, 0x5c, 0x8e, 0xb5, 0x99, 0xac, 0x60, 0x19, 0x9f, 0xff,
0x15, 0x00, 0x00, 0xff, 0xff, 0xef, 0x25, 0xa5, 0xa9, 0xc3, 0x0e, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var (
_ context.Context
_ grpc.ClientConn
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// OSServiceClient is the client API for OSService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type OSServiceClient interface {
Containers(ctx context.Context, in *ContainersRequest, opts ...grpc.CallOption) (*ContainersResponse, error)
Dmesg(ctx context.Context, in *DmesgRequest, opts ...grpc.CallOption) (OSService_DmesgClient, error)
Memory(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*MemoryResponse, error)
Processes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ProcessesResponse, error)
Restart(ctx context.Context, in *RestartRequest, opts ...grpc.CallOption) (*RestartResponse, error)
Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error)
}
type oSServiceClient struct {
cc *grpc.ClientConn
}
func NewOSServiceClient(cc *grpc.ClientConn) OSServiceClient {
return &oSServiceClient{cc}
}
func (c *oSServiceClient) Containers(ctx context.Context, in *ContainersRequest, opts ...grpc.CallOption) (*ContainersResponse, error) {
out := new(ContainersResponse)
err := c.cc.Invoke(ctx, "/os.OSService/Containers", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *oSServiceClient) Dmesg(ctx context.Context, in *DmesgRequest, opts ...grpc.CallOption) (OSService_DmesgClient, error) {
stream, err := c.cc.NewStream(ctx, &_OSService_serviceDesc.Streams[0], "/os.OSService/Dmesg", opts...)
if err != nil {
return nil, err
}
x := &oSServiceDmesgClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type OSService_DmesgClient interface {
Recv() (*common.Data, error)
grpc.ClientStream
}
type oSServiceDmesgClient struct {
grpc.ClientStream
}
func (x *oSServiceDmesgClient) Recv() (*common.Data, error) {
m := new(common.Data)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *oSServiceClient) Memory(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*MemoryResponse, error) {
out := new(MemoryResponse)
err := c.cc.Invoke(ctx, "/os.OSService/Memory", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *oSServiceClient) Processes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ProcessesResponse, error) {
out := new(ProcessesResponse)
err := c.cc.Invoke(ctx, "/os.OSService/Processes", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *oSServiceClient) Restart(ctx context.Context, in *RestartRequest, opts ...grpc.CallOption) (*RestartResponse, error) {
out := new(RestartResponse)
err := c.cc.Invoke(ctx, "/os.OSService/Restart", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *oSServiceClient) Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error) {
out := new(StatsResponse)
err := c.cc.Invoke(ctx, "/os.OSService/Stats", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// OSServiceServer is the server API for OSService service.
type OSServiceServer interface {
Containers(context.Context, *ContainersRequest) (*ContainersResponse, error)
Dmesg(*DmesgRequest, OSService_DmesgServer) error
Memory(context.Context, *empty.Empty) (*MemoryResponse, error)
Processes(context.Context, *empty.Empty) (*ProcessesResponse, error)
Restart(context.Context, *RestartRequest) (*RestartResponse, error)
Stats(context.Context, *StatsRequest) (*StatsResponse, error)
}
func RegisterOSServiceServer(s *grpc.Server, srv OSServiceServer) {
s.RegisterService(&_OSService_serviceDesc, srv)
}
func _OSService_Containers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ContainersRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OSServiceServer).Containers(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/os.OSService/Containers",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OSServiceServer).Containers(ctx, req.(*ContainersRequest))
}
return interceptor(ctx, in, info, handler)
}
func _OSService_Dmesg_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(DmesgRequest)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(OSServiceServer).Dmesg(m, &oSServiceDmesgServer{stream})
}
type OSService_DmesgServer interface {
Send(*common.Data) error
grpc.ServerStream
}
type oSServiceDmesgServer struct {
grpc.ServerStream
}
func (x *oSServiceDmesgServer) Send(m *common.Data) error {
return x.ServerStream.SendMsg(m)
}
func _OSService_Memory_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OSServiceServer).Memory(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/os.OSService/Memory",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OSServiceServer).Memory(ctx, req.(*empty.Empty))
}
return interceptor(ctx, in, info, handler)
}
func _OSService_Processes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(empty.Empty)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OSServiceServer).Processes(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/os.OSService/Processes",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OSServiceServer).Processes(ctx, req.(*empty.Empty))
}
return interceptor(ctx, in, info, handler)
}
func _OSService_Restart_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RestartRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OSServiceServer).Restart(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/os.OSService/Restart",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OSServiceServer).Restart(ctx, req.(*RestartRequest))
}
return interceptor(ctx, in, info, handler)
}
func _OSService_Stats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(StatsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OSServiceServer).Stats(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/os.OSService/Stats",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OSServiceServer).Stats(ctx, req.(*StatsRequest))
}
return interceptor(ctx, in, info, handler)
}
var _OSService_serviceDesc = grpc.ServiceDesc{
ServiceName: "os.OSService",
HandlerType: (*OSServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Containers",
Handler: _OSService_Containers_Handler,
},
{
MethodName: "Memory",
Handler: _OSService_Memory_Handler,
},
{
MethodName: "Processes",
Handler: _OSService_Processes_Handler,
},
{
MethodName: "Restart",
Handler: _OSService_Restart_Handler,
},
{
MethodName: "Stats",
Handler: _OSService_Stats_Handler,
},
},
Streams: []grpc.StreamDesc{
{
StreamName: "Dmesg",
Handler: _OSService_Dmesg_Handler,
ServerStreams: true,
},
},
Metadata: "os/os.proto",
}