Documentation ¶
Index ¶
- func RegisterLogMonServer(s *grpc.Server, srv LogMonServer)
- type LogMonClient
- type LogMonServer
- type StartRequest
- func (*StartRequest) Descriptor() ([]byte, []int)
- func (m *StartRequest) GetLogDir() string
- func (m *StartRequest) GetMaxFileSizeMb() uint32
- func (m *StartRequest) GetMaxFiles() uint32
- func (m *StartRequest) GetStderrFifo() string
- func (m *StartRequest) GetStderrFileName() string
- func (m *StartRequest) GetStdoutFifo() string
- func (m *StartRequest) GetStdoutFileName() string
- func (*StartRequest) ProtoMessage()
- func (m *StartRequest) Reset()
- func (m *StartRequest) String() string
- func (m *StartRequest) XXX_DiscardUnknown()
- func (m *StartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartRequest) XXX_Merge(src proto.Message)
- func (m *StartRequest) XXX_Size() int
- func (m *StartRequest) XXX_Unmarshal(b []byte) error
- type StartResponse
- func (*StartResponse) Descriptor() ([]byte, []int)
- func (*StartResponse) ProtoMessage()
- func (m *StartResponse) Reset()
- func (m *StartResponse) String() string
- func (m *StartResponse) XXX_DiscardUnknown()
- func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartResponse) XXX_Merge(src proto.Message)
- func (m *StartResponse) XXX_Size() int
- func (m *StartResponse) XXX_Unmarshal(b []byte) error
- type StopRequest
- func (*StopRequest) Descriptor() ([]byte, []int)
- func (*StopRequest) ProtoMessage()
- func (m *StopRequest) Reset()
- func (m *StopRequest) String() string
- func (m *StopRequest) XXX_DiscardUnknown()
- func (m *StopRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopRequest) XXX_Merge(src proto.Message)
- func (m *StopRequest) XXX_Size() int
- func (m *StopRequest) XXX_Unmarshal(b []byte) error
- type StopResponse
- func (*StopResponse) Descriptor() ([]byte, []int)
- func (*StopResponse) ProtoMessage()
- func (m *StopResponse) Reset()
- func (m *StopResponse) String() string
- func (m *StopResponse) XXX_DiscardUnknown()
- func (m *StopResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopResponse) XXX_Merge(src proto.Message)
- func (m *StopResponse) XXX_Size() int
- func (m *StopResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedLogMonServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterLogMonServer ¶
func RegisterLogMonServer(s *grpc.Server, srv LogMonServer)
Types ¶
type LogMonClient ¶
type LogMonClient interface { Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) }
LogMonClient is the client API for LogMon service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLogMonClient ¶
func NewLogMonClient(cc grpc.ClientConnInterface) LogMonClient
type LogMonServer ¶
type LogMonServer interface { Start(context.Context, *StartRequest) (*StartResponse, error) Stop(context.Context, *StopRequest) (*StopResponse, error) }
LogMonServer is the server API for LogMon service.
type StartRequest ¶
type StartRequest struct { LogDir string `protobuf:"bytes,1,opt,name=log_dir,json=logDir,proto3" json:"log_dir,omitempty"` StdoutFileName string `protobuf:"bytes,2,opt,name=stdout_file_name,json=stdoutFileName,proto3" json:"stdout_file_name,omitempty"` StderrFileName string `protobuf:"bytes,3,opt,name=stderr_file_name,json=stderrFileName,proto3" json:"stderr_file_name,omitempty"` MaxFiles uint32 `protobuf:"varint,4,opt,name=max_files,json=maxFiles,proto3" json:"max_files,omitempty"` MaxFileSizeMb uint32 `protobuf:"varint,5,opt,name=max_file_size_mb,json=maxFileSizeMb,proto3" json:"max_file_size_mb,omitempty"` StdoutFifo string `protobuf:"bytes,6,opt,name=stdout_fifo,json=stdoutFifo,proto3" json:"stdout_fifo,omitempty"` StderrFifo string `protobuf:"bytes,7,opt,name=stderr_fifo,json=stderrFifo,proto3" json:"stderr_fifo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartRequest) Descriptor ¶
func (*StartRequest) Descriptor() ([]byte, []int)
func (*StartRequest) GetLogDir ¶
func (m *StartRequest) GetLogDir() string
func (*StartRequest) GetMaxFileSizeMb ¶
func (m *StartRequest) GetMaxFileSizeMb() uint32
func (*StartRequest) GetMaxFiles ¶
func (m *StartRequest) GetMaxFiles() uint32
func (*StartRequest) GetStderrFifo ¶
func (m *StartRequest) GetStderrFifo() string
func (*StartRequest) GetStderrFileName ¶
func (m *StartRequest) GetStderrFileName() string
func (*StartRequest) GetStdoutFifo ¶
func (m *StartRequest) GetStdoutFifo() string
func (*StartRequest) GetStdoutFileName ¶
func (m *StartRequest) GetStdoutFileName() string
func (*StartRequest) ProtoMessage ¶
func (*StartRequest) ProtoMessage()
func (*StartRequest) Reset ¶
func (m *StartRequest) Reset()
func (*StartRequest) String ¶
func (m *StartRequest) String() string
func (*StartRequest) XXX_DiscardUnknown ¶
func (m *StartRequest) XXX_DiscardUnknown()
func (*StartRequest) XXX_Marshal ¶
func (m *StartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartRequest) XXX_Merge ¶
func (m *StartRequest) XXX_Merge(src proto.Message)
func (*StartRequest) XXX_Size ¶
func (m *StartRequest) XXX_Size() int
func (*StartRequest) XXX_Unmarshal ¶
func (m *StartRequest) XXX_Unmarshal(b []byte) error
type StartResponse ¶
type StartResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartResponse) Descriptor ¶
func (*StartResponse) Descriptor() ([]byte, []int)
func (*StartResponse) ProtoMessage ¶
func (*StartResponse) ProtoMessage()
func (*StartResponse) Reset ¶
func (m *StartResponse) Reset()
func (*StartResponse) String ¶
func (m *StartResponse) String() string
func (*StartResponse) XXX_DiscardUnknown ¶
func (m *StartResponse) XXX_DiscardUnknown()
func (*StartResponse) XXX_Marshal ¶
func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartResponse) XXX_Merge ¶
func (m *StartResponse) XXX_Merge(src proto.Message)
func (*StartResponse) XXX_Size ¶
func (m *StartResponse) XXX_Size() int
func (*StartResponse) XXX_Unmarshal ¶
func (m *StartResponse) XXX_Unmarshal(b []byte) error
type StopRequest ¶
type StopRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StopRequest) Descriptor ¶
func (*StopRequest) Descriptor() ([]byte, []int)
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) Reset ¶
func (m *StopRequest) Reset()
func (*StopRequest) String ¶
func (m *StopRequest) String() string
func (*StopRequest) XXX_DiscardUnknown ¶
func (m *StopRequest) XXX_DiscardUnknown()
func (*StopRequest) XXX_Marshal ¶
func (m *StopRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopRequest) XXX_Merge ¶
func (m *StopRequest) XXX_Merge(src proto.Message)
func (*StopRequest) XXX_Size ¶
func (m *StopRequest) XXX_Size() int
func (*StopRequest) XXX_Unmarshal ¶
func (m *StopRequest) XXX_Unmarshal(b []byte) error
type StopResponse ¶
type StopResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StopResponse) Descriptor ¶
func (*StopResponse) Descriptor() ([]byte, []int)
func (*StopResponse) ProtoMessage ¶
func (*StopResponse) ProtoMessage()
func (*StopResponse) Reset ¶
func (m *StopResponse) Reset()
func (*StopResponse) String ¶
func (m *StopResponse) String() string
func (*StopResponse) XXX_DiscardUnknown ¶
func (m *StopResponse) XXX_DiscardUnknown()
func (*StopResponse) XXX_Marshal ¶
func (m *StopResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopResponse) XXX_Merge ¶
func (m *StopResponse) XXX_Merge(src proto.Message)
func (*StopResponse) XXX_Size ¶
func (m *StopResponse) XXX_Size() int
func (*StopResponse) XXX_Unmarshal ¶
func (m *StopResponse) XXX_Unmarshal(b []byte) error
type UnimplementedLogMonServer ¶ added in v0.11.0
type UnimplementedLogMonServer struct { }
UnimplementedLogMonServer can be embedded to have forward compatible implementations.
func (*UnimplementedLogMonServer) Start ¶ added in v0.11.0
func (*UnimplementedLogMonServer) Start(ctx context.Context, req *StartRequest) (*StartResponse, error)
func (*UnimplementedLogMonServer) Stop ¶ added in v0.11.0
func (*UnimplementedLogMonServer) Stop(ctx context.Context, req *StopRequest) (*StopResponse, error)
Click to show internal directories.
Click to hide internal directories.