Documentation ¶
Index ¶
- func RegisterLogUnitServiceServer(s *grpc.Server, srv LogUnitServiceServer)
- type DefaultLogUnitService
- func (s *DefaultLogUnitService) GetUnits(rq *Empty, stream LogUnitService_GetUnitsServer) error
- func (s *DefaultLogUnitService) NLines(rq *NLineRQ, stream LogUnitService_NLinesServer) error
- func (s *DefaultLogUnitService) NLogs(rq *NLogRQ, stream LogUnitService_NLogsServer) error
- func (s *DefaultLogUnitService) TLogs(rq *TLogRQ, stream LogUnitService_TLogsServer) error
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type LogRS
- func (*LogRS) Descriptor() ([]byte, []int)
- func (m *LogRS) GetLog() string
- func (*LogRS) ProtoMessage()
- func (m *LogRS) Reset()
- func (m *LogRS) String() string
- func (m *LogRS) XXX_DiscardUnknown()
- func (m *LogRS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *LogRS) XXX_Merge(src proto.Message)
- func (m *LogRS) XXX_Size() int
- func (m *LogRS) XXX_Unmarshal(b []byte) error
- type LogUnitServiceClient
- type LogUnitServiceServer
- type LogUnitService_GetUnitsClient
- type LogUnitService_GetUnitsServer
- type LogUnitService_NLinesClient
- type LogUnitService_NLinesServer
- type LogUnitService_NLogsClient
- type LogUnitService_NLogsServer
- type LogUnitService_TLogsClient
- type LogUnitService_TLogsServer
- type NLineRQ
- func (*NLineRQ) Descriptor() ([]byte, []int)
- func (m *NLineRQ) GetCount() int32
- func (m *NLineRQ) GetUnitId() string
- func (*NLineRQ) ProtoMessage()
- func (m *NLineRQ) Reset()
- func (m *NLineRQ) String() string
- func (m *NLineRQ) XXX_DiscardUnknown()
- func (m *NLineRQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NLineRQ) XXX_Merge(src proto.Message)
- func (m *NLineRQ) XXX_Size() int
- func (m *NLineRQ) XXX_Unmarshal(b []byte) error
- type NLineRS
- func (*NLineRS) Descriptor() ([]byte, []int)
- func (m *NLineRS) GetLine() string
- func (*NLineRS) ProtoMessage()
- func (m *NLineRS) Reset()
- func (m *NLineRS) String() string
- func (m *NLineRS) XXX_DiscardUnknown()
- func (m *NLineRS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NLineRS) XXX_Merge(src proto.Message)
- func (m *NLineRS) XXX_Size() int
- func (m *NLineRS) XXX_Unmarshal(b []byte) error
- type NLogRQ
- func (*NLogRQ) Descriptor() ([]byte, []int)
- func (m *NLogRQ) GetCount() int32
- func (m *NLogRQ) GetDateTimeLayout() string
- func (m *NLogRQ) GetLogPattern() string
- func (m *NLogRQ) GetUnitId() string
- func (*NLogRQ) ProtoMessage()
- func (m *NLogRQ) Reset()
- func (m *NLogRQ) String() string
- func (m *NLogRQ) XXX_DiscardUnknown()
- func (m *NLogRQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NLogRQ) XXX_Merge(src proto.Message)
- func (m *NLogRQ) XXX_Size() int
- func (m *NLogRQ) XXX_Unmarshal(b []byte) error
- type TLogRQ
- func (*TLogRQ) Descriptor() ([]byte, []int)
- func (m *TLogRQ) GetDateTimeLayout() string
- func (m *TLogRQ) GetDuration() string
- func (m *TLogRQ) GetLogPattern() string
- func (m *TLogRQ) GetOffset() int64
- func (m *TLogRQ) GetUnitId() string
- func (*TLogRQ) ProtoMessage()
- func (m *TLogRQ) Reset()
- func (m *TLogRQ) String() string
- func (m *TLogRQ) XXX_DiscardUnknown()
- func (m *TLogRQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TLogRQ) XXX_Merge(src proto.Message)
- func (m *TLogRQ) XXX_Size() int
- func (m *TLogRQ) XXX_Unmarshal(b []byte) error
- type UnitRS
- func (*UnitRS) Descriptor() ([]byte, []int)
- func (m *UnitRS) GetUnit() string
- func (*UnitRS) ProtoMessage()
- func (m *UnitRS) Reset()
- func (m *UnitRS) String() string
- func (m *UnitRS) XXX_DiscardUnknown()
- func (m *UnitRS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *UnitRS) XXX_Merge(src proto.Message)
- func (m *UnitRS) XXX_Size() int
- func (m *UnitRS) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterLogUnitServiceServer ¶
func RegisterLogUnitServiceServer(s *grpc.Server, srv LogUnitServiceServer)
Types ¶
type DefaultLogUnitService ¶
type DefaultLogUnitService struct {
// contains filtered or unexported fields
}
func (*DefaultLogUnitService) GetUnits ¶
func (s *DefaultLogUnitService) GetUnits(rq *Empty, stream LogUnitService_GetUnitsServer) error
func (*DefaultLogUnitService) NLines ¶
func (s *DefaultLogUnitService) NLines(rq *NLineRQ, stream LogUnitService_NLinesServer) error
func (*DefaultLogUnitService) NLogs ¶
func (s *DefaultLogUnitService) NLogs(rq *NLogRQ, stream LogUnitService_NLogsServer) error
func (*DefaultLogUnitService) TLogs ¶
func (s *DefaultLogUnitService) TLogs(rq *TLogRQ, stream LogUnitService_TLogsServer) error
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type LogRS ¶
type LogRS struct { Log string `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogRS) Descriptor ¶
func (*LogRS) ProtoMessage ¶
func (*LogRS) ProtoMessage()
func (*LogRS) XXX_DiscardUnknown ¶
func (m *LogRS) XXX_DiscardUnknown()
func (*LogRS) XXX_Marshal ¶
func (*LogRS) XXX_Unmarshal ¶
type LogUnitServiceClient ¶
type LogUnitServiceClient interface { GetUnits(ctx context.Context, in *Empty, opts ...grpc.CallOption) (LogUnitService_GetUnitsClient, error) NLines(ctx context.Context, in *NLineRQ, opts ...grpc.CallOption) (LogUnitService_NLinesClient, error) NLogs(ctx context.Context, in *NLogRQ, opts ...grpc.CallOption) (LogUnitService_NLogsClient, error) TLogs(ctx context.Context, in *TLogRQ, opts ...grpc.CallOption) (LogUnitService_TLogsClient, error) }
LogUnitServiceClient is the client API for LogUnitService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLogUnitServiceClient ¶
func NewLogUnitServiceClient(cc *grpc.ClientConn) LogUnitServiceClient
type LogUnitServiceServer ¶
type LogUnitServiceServer interface { GetUnits(*Empty, LogUnitService_GetUnitsServer) error NLines(*NLineRQ, LogUnitService_NLinesServer) error NLogs(*NLogRQ, LogUnitService_NLogsServer) error TLogs(*TLogRQ, LogUnitService_TLogsServer) error }
LogUnitServiceServer is the server API for LogUnitService service.
func NewLogService ¶
func NewLogService(logUnits unit.LogUnits) (LogUnitServiceServer, error)
type LogUnitService_GetUnitsClient ¶
type LogUnitService_GetUnitsClient interface { Recv() (*UnitRS, error) grpc.ClientStream }
type LogUnitService_GetUnitsServer ¶
type LogUnitService_GetUnitsServer interface { Send(*UnitRS) error grpc.ServerStream }
type LogUnitService_NLinesClient ¶
type LogUnitService_NLinesClient interface { Recv() (*NLineRS, error) grpc.ClientStream }
type LogUnitService_NLinesServer ¶
type LogUnitService_NLinesServer interface { Send(*NLineRS) error grpc.ServerStream }
type LogUnitService_NLogsClient ¶
type LogUnitService_NLogsClient interface { Recv() (*LogRS, error) grpc.ClientStream }
type LogUnitService_NLogsServer ¶
type LogUnitService_NLogsServer interface { Send(*LogRS) error grpc.ServerStream }
type LogUnitService_TLogsClient ¶
type LogUnitService_TLogsClient interface { Recv() (*LogRS, error) grpc.ClientStream }
type LogUnitService_TLogsServer ¶
type LogUnitService_TLogsServer interface { Send(*LogRS) error grpc.ServerStream }
type NLineRQ ¶
type NLineRQ struct { UnitId string `protobuf:"bytes,1,opt,name=unit_id,json=unitId,proto3" json:"unit_id,omitempty"` Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NLineRQ) Descriptor ¶
func (*NLineRQ) ProtoMessage ¶
func (*NLineRQ) ProtoMessage()
func (*NLineRQ) XXX_DiscardUnknown ¶
func (m *NLineRQ) XXX_DiscardUnknown()
func (*NLineRQ) XXX_Marshal ¶
func (*NLineRQ) XXX_Unmarshal ¶
type NLineRS ¶
type NLineRS struct { Line string `protobuf:"bytes,1,opt,name=line,proto3" json:"line,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NLineRS) Descriptor ¶
func (*NLineRS) ProtoMessage ¶
func (*NLineRS) ProtoMessage()
func (*NLineRS) XXX_DiscardUnknown ¶
func (m *NLineRS) XXX_DiscardUnknown()
func (*NLineRS) XXX_Marshal ¶
func (*NLineRS) XXX_Unmarshal ¶
type NLogRQ ¶
type NLogRQ struct { UnitId string `protobuf:"bytes,1,opt,name=unit_id,json=unitId,proto3" json:"unit_id,omitempty"` Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` LogPattern string `protobuf:"bytes,3,opt,name=log_pattern,json=logPattern,proto3" json:"log_pattern,omitempty"` DateTimeLayout string `protobuf:"bytes,4,opt,name=date_time_layout,json=dateTimeLayout,proto3" json:"date_time_layout,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NLogRQ) Descriptor ¶
func (*NLogRQ) GetDateTimeLayout ¶
func (*NLogRQ) GetLogPattern ¶
func (*NLogRQ) ProtoMessage ¶
func (*NLogRQ) ProtoMessage()
func (*NLogRQ) XXX_DiscardUnknown ¶
func (m *NLogRQ) XXX_DiscardUnknown()
func (*NLogRQ) XXX_Marshal ¶
func (*NLogRQ) XXX_Unmarshal ¶
type TLogRQ ¶
type TLogRQ struct { UnitId string `protobuf:"bytes,1,opt,name=unit_id,json=unitId,proto3" json:"unit_id,omitempty"` Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Duration string `protobuf:"bytes,4,opt,name=duration,proto3" json:"duration,omitempty"` LogPattern string `protobuf:"bytes,5,opt,name=log_pattern,json=logPattern,proto3" json:"log_pattern,omitempty"` DateTimeLayout string `protobuf:"bytes,6,opt,name=date_time_layout,json=dateTimeLayout,proto3" json:"date_time_layout,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TLogRQ) Descriptor ¶
func (*TLogRQ) GetDateTimeLayout ¶
func (*TLogRQ) GetDuration ¶
func (*TLogRQ) GetLogPattern ¶
func (*TLogRQ) ProtoMessage ¶
func (*TLogRQ) ProtoMessage()
func (*TLogRQ) XXX_DiscardUnknown ¶
func (m *TLogRQ) XXX_DiscardUnknown()
func (*TLogRQ) XXX_Marshal ¶
func (*TLogRQ) XXX_Unmarshal ¶
type UnitRS ¶
type UnitRS struct { Unit string `protobuf:"bytes,1,opt,name=unit,proto3" json:"unit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UnitRS) Descriptor ¶
func (*UnitRS) ProtoMessage ¶
func (*UnitRS) ProtoMessage()
func (*UnitRS) XXX_DiscardUnknown ¶
func (m *UnitRS) XXX_DiscardUnknown()
func (*UnitRS) XXX_Marshal ¶
func (*UnitRS) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.