proto

package
v0.1.0-alpha.8 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2018 License: MPL-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterOSDServer 

func RegisterOSDServer(s *grpc.Server, srv OSDServer)

Types

type Data 

type Data struct {
	Bytes                []byte   `protobuf:"bytes,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response message containing the requested logs.

func (*Data) Descriptor 

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

func (*Data) GetBytes 

func (m *Data) GetBytes() []byte

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) Reset 

func (m *Data) Reset()

func (*Data) String 

func (m *Data) String() string

func (*Data) XXX_DiscardUnknown 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal 

func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Data) XXX_Merge 

func (dst *Data) XXX_Merge(src proto.Message)

func (*Data) XXX_Size 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal 

func (m *Data) XXX_Unmarshal(b []byte) error

type LogsRequest 

type LogsRequest struct {
	Process              string   `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	Container            bool     `protobuf:"varint,2,opt,name=container,proto3" json:"container,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request message containing the process name.

func (*LogsRequest) Descriptor 

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

func (*LogsRequest) GetContainer 

func (m *LogsRequest) GetContainer() bool

func (*LogsRequest) GetProcess 

func (m *LogsRequest) GetProcess() string

func (*LogsRequest) ProtoMessage 

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) Reset 

func (m *LogsRequest) Reset()

func (*LogsRequest) String 

func (m *LogsRequest) String() string

func (*LogsRequest) XXX_DiscardUnknown 

func (m *LogsRequest) XXX_DiscardUnknown()

func (*LogsRequest) XXX_Marshal 

func (m *LogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogsRequest) XXX_Merge 

func (dst *LogsRequest) XXX_Merge(src proto.Message)

func (*LogsRequest) XXX_Size 

func (m *LogsRequest) XXX_Size() int

func (*LogsRequest) XXX_Unmarshal 

func (m *LogsRequest) XXX_Unmarshal(b []byte) error

type OSDClient 

type OSDClient interface {
	Kubeconfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Data, error)
	Processes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ProcessesReply, error)
	Restart(ctx context.Context, in *RestartRequest, opts ...grpc.CallOption) (*RestartReply, error)
	Reset(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ResetReply, error)
	Reboot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*RebootReply, error)
	Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (OSD_LogsClient, error)
	Dmesg(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Data, error)
	Version(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Data, error)
}

OSDClient is the client API for OSD service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewOSDClient 

func NewOSDClient(cc *grpc.ClientConn) OSDClient

type OSDServer 

type OSDServer interface {
	Kubeconfig(context.Context, *empty.Empty) (*Data, error)
	Processes(context.Context, *empty.Empty) (*ProcessesReply, error)
	Restart(context.Context, *RestartRequest) (*RestartReply, error)
	Reset(context.Context, *empty.Empty) (*ResetReply, error)
	Reboot(context.Context, *empty.Empty) (*RebootReply, error)
	Logs(*LogsRequest, OSD_LogsServer) error
	Dmesg(context.Context, *empty.Empty) (*Data, error)
	Version(context.Context, *empty.Empty) (*Data, error)
}

OSDServer is the server API for OSD service.

type OSD_LogsClient 

type OSD_LogsClient interface {
	Recv() (*Data, error)
	grpc.ClientStream
}

type OSD_LogsServer 

type OSD_LogsServer interface {
	Send(*Data) error
	grpc.ServerStream
}

type Process 

type Process 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"`
	State                string   `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Status               string   `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response message containing the requested processes.

func (*Process) Descriptor 

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

func (*Process) GetId 

func (m *Process) GetId() string

func (*Process) GetName 

func (m *Process) GetName() string

func (*Process) GetState 

func (m *Process) GetState() string

func (*Process) GetStatus 

func (m *Process) GetStatus() string

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) String 

func (m *Process) String() string

func (*Process) XXX_DiscardUnknown 

func (m *Process) XXX_DiscardUnknown()

func (*Process) XXX_Marshal 

func (m *Process) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Process) XXX_Merge 

func (dst *Process) XXX_Merge(src proto.Message)

func (*Process) XXX_Size 

func (m *Process) XXX_Size() int

func (*Process) XXX_Unmarshal 

func (m *Process) XXX_Unmarshal(b []byte) error

type ProcessesReply 

type ProcessesReply struct {
	Processes            []*Process `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

The response message containing the requested processes.

func (*ProcessesReply) Descriptor 

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

func (*ProcessesReply) GetProcesses 

func (m *ProcessesReply) GetProcesses() []*Process

func (*ProcessesReply) ProtoMessage 

func (*ProcessesReply) ProtoMessage()

func (*ProcessesReply) Reset 

func (m *ProcessesReply) Reset()

func (*ProcessesReply) String 

func (m *ProcessesReply) String() string

func (*ProcessesReply) XXX_DiscardUnknown 

func (m *ProcessesReply) XXX_DiscardUnknown()

func (*ProcessesReply) XXX_Marshal 

func (m *ProcessesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessesReply) XXX_Merge 

func (dst *ProcessesReply) XXX_Merge(src proto.Message)

func (*ProcessesReply) XXX_Size 

func (m *ProcessesReply) XXX_Size() int

func (*ProcessesReply) XXX_Unmarshal 

func (m *ProcessesReply) XXX_Unmarshal(b []byte) error

type RebootReply 

type RebootReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response message containing the restart status.

func (*RebootReply) Descriptor 

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

func (*RebootReply) ProtoMessage 

func (*RebootReply) ProtoMessage()

func (*RebootReply) Reset 

func (m *RebootReply) Reset()

func (*RebootReply) String 

func (m *RebootReply) String() string

func (*RebootReply) XXX_DiscardUnknown 

func (m *RebootReply) XXX_DiscardUnknown()

func (*RebootReply) XXX_Marshal 

func (m *RebootReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RebootReply) XXX_Merge 

func (dst *RebootReply) XXX_Merge(src proto.Message)

func (*RebootReply) XXX_Size 

func (m *RebootReply) XXX_Size() int

func (*RebootReply) XXX_Unmarshal 

func (m *RebootReply) XXX_Unmarshal(b []byte) error

type ResetReply 

type ResetReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response message containing the restart status.

func (*ResetReply) Descriptor 

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

func (*ResetReply) ProtoMessage 

func (*ResetReply) ProtoMessage()

func (*ResetReply) Reset 

func (m *ResetReply) Reset()

func (*ResetReply) String 

func (m *ResetReply) String() string

func (*ResetReply) XXX_DiscardUnknown 

func (m *ResetReply) XXX_DiscardUnknown()

func (*ResetReply) XXX_Marshal 

func (m *ResetReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetReply) XXX_Merge 

func (dst *ResetReply) XXX_Merge(src proto.Message)

func (*ResetReply) XXX_Size 

func (m *ResetReply) XXX_Size() int

func (*ResetReply) XXX_Unmarshal 

func (m *ResetReply) XXX_Unmarshal(b []byte) error

type RestartReply 

type RestartReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response message containing the restart status.

func (*RestartReply) Descriptor 

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

func (*RestartReply) ProtoMessage 

func (*RestartReply) ProtoMessage()

func (*RestartReply) Reset 

func (m *RestartReply) Reset()

func (*RestartReply) String 

func (m *RestartReply) String() string

func (*RestartReply) XXX_DiscardUnknown 

func (m *RestartReply) XXX_DiscardUnknown()

func (*RestartReply) XXX_Marshal 

func (m *RestartReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestartReply) XXX_Merge 

func (dst *RestartReply) XXX_Merge(src proto.Message)

func (*RestartReply) XXX_Size 

func (m *RestartReply) XXX_Size() int

func (*RestartReply) XXX_Unmarshal 

func (m *RestartReply) XXX_Unmarshal(b []byte) error

type RestartRequest 

type RestartRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timeout              int32    `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request message containing the process to restart.

func (*RestartRequest) Descriptor 

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

func (*RestartRequest) GetId 

func (m *RestartRequest) GetId() string

func (*RestartRequest) GetTimeout 

func (m *RestartRequest) GetTimeout() int32

func (*RestartRequest) ProtoMessage 

func (*RestartRequest) ProtoMessage()

func (*RestartRequest) Reset 

func (m *RestartRequest) Reset()

func (*RestartRequest) String 

func (m *RestartRequest) String() string

func (*RestartRequest) XXX_DiscardUnknown 

func (m *RestartRequest) XXX_DiscardUnknown()

func (*RestartRequest) XXX_Marshal 

func (m *RestartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestartRequest) XXX_Merge 

func (dst *RestartRequest) XXX_Merge(src proto.Message)

func (*RestartRequest) XXX_Size 

func (m *RestartRequest) XXX_Size() int

func (*RestartRequest) XXX_Unmarshal 

func (m *RestartRequest) XXX_Unmarshal(b []byte) error

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.