proto

Documentation

Index

• func RegisterOSDServer(s *grpc.Server, srv OSDServer)
• type Data
  • func (*Data) Descriptor() ([]byte, []int)
  • func (m *Data) GetBytes() []byte
  • func (*Data) ProtoMessage()
  • func (m *Data) Reset()
  • func (m *Data) String() string
  • func (m *Data) XXX_DiscardUnknown()
  • func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *Data) XXX_Merge(src proto.Message)
  • func (m *Data) XXX_Size() int
  • func (m *Data) XXX_Unmarshal(b []byte) error
• type LogsRequest
  • func (*LogsRequest) Descriptor() ([]byte, []int)
  • func (m *LogsRequest) GetContainer() bool
  • func (m *LogsRequest) GetProcess() string
  • func (*LogsRequest) ProtoMessage()
  • func (m *LogsRequest) Reset()
  • func (m *LogsRequest) String() string
  • func (m *LogsRequest) XXX_DiscardUnknown()
  • func (m *LogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *LogsRequest) XXX_Merge(src proto.Message)
  • func (m *LogsRequest) XXX_Size() int
  • func (m *LogsRequest) XXX_Unmarshal(b []byte) error
• type OSDClient
  • func NewOSDClient(cc *grpc.ClientConn) OSDClient
• type OSDServer
• type OSD_LogsClient
• type OSD_LogsServer
• type ProcessesReply
  • func (*ProcessesReply) Descriptor() ([]byte, []int)
  • func (m *ProcessesReply) GetContent() []byte
  • func (*ProcessesReply) ProtoMessage()
  • func (m *ProcessesReply) Reset()
  • func (m *ProcessesReply) String() string
  • func (m *ProcessesReply) XXX_DiscardUnknown()
  • func (m *ProcessesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *ProcessesReply) XXX_Merge(src proto.Message)
  • func (m *ProcessesReply) XXX_Size() int
  • func (m *ProcessesReply) XXX_Unmarshal(b []byte) error
• type ProcessesRequest
  • func (*ProcessesRequest) Descriptor() ([]byte, []int)
  • func (m *ProcessesRequest) GetProcess() string
  • func (*ProcessesRequest) ProtoMessage()
  • func (m *ProcessesRequest) Reset()
  • func (m *ProcessesRequest) String() string
  • func (m *ProcessesRequest) XXX_DiscardUnknown()
  • func (m *ProcessesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *ProcessesRequest) XXX_Merge(src proto.Message)
  • func (m *ProcessesRequest) XXX_Size() int
  • func (m *ProcessesRequest) XXX_Unmarshal(b []byte) error

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 *ProcessesRequest, opts ...grpc.CallOption) (*ProcessesReply, 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, *ProcessesRequest) (*ProcessesReply, 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 ProcessesReply

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

The response message containing the requested logs.

func (*ProcessesReply) Descriptor

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

func (*ProcessesReply) GetContent

func (m *ProcessesReply) GetContent() []byte

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 ProcessesRequest

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

The request message containing the process name.

func (*ProcessesRequest) Descriptor

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

func (*ProcessesRequest) GetProcess

func (m *ProcessesRequest) GetProcess() string

func (*ProcessesRequest) ProtoMessage

func (*ProcessesRequest) ProtoMessage()

func (*ProcessesRequest) Reset

func (m *ProcessesRequest) Reset()

func (*ProcessesRequest) String

func (m *ProcessesRequest) String() string

func (*ProcessesRequest) XXX_DiscardUnknown

func (m *ProcessesRequest) XXX_DiscardUnknown()

func (*ProcessesRequest) XXX_Marshal

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

func (*ProcessesRequest) XXX_Merge

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

func (*ProcessesRequest) XXX_Size

func (m *ProcessesRequest) XXX_Size() int

func (*ProcessesRequest) XXX_Unmarshal

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