Documentation ¶
Index ¶
- Variables
- func RegisterLogReportServiceServer(s *grpc.Server, srv LogReportServiceServer)
- func SetLogTime(log *Log, second uint32)
- func SetLogTimeWithNano(log *Log, second uint32, nanosecond uint32)
- type Codec
- type Log
- func (*Log) Descriptor() ([]byte, []int)
- func (m *Log) GetContents() []*Log_Content
- func (m *Log) GetTime() uint32
- func (m *Log) GetTimeNs() uint32
- func (m *Log) GetValues() []string
- func (m *Log) Marshal() (dAtA []byte, err error)
- func (m *Log) MarshalTo(dAtA []byte) (int, error)
- func (m *Log) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Log) ProtoMessage()
- func (m *Log) Reset()
- func (m *Log) Size() (n int)
- func (m *Log) String() string
- func (m *Log) Unmarshal(dAtA []byte) error
- func (m *Log) XXX_DiscardUnknown()
- func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Log) XXX_Merge(src proto.Message)
- func (m *Log) XXX_Size() int
- func (m *Log) XXX_Unmarshal(b []byte) error
- type LogGroup
- func (*LogGroup) Descriptor() ([]byte, []int)
- func (m *LogGroup) GetCategory() string
- func (m *LogGroup) GetLogTags() []*LogTag
- func (m *LogGroup) GetLogs() []*Log
- func (m *LogGroup) GetMachineUUID() string
- func (m *LogGroup) GetSource() string
- func (m *LogGroup) GetTopic() string
- func (m *LogGroup) Marshal() (dAtA []byte, err error)
- func (m *LogGroup) MarshalTo(dAtA []byte) (int, error)
- func (m *LogGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogGroup) ProtoMessage()
- func (m *LogGroup) Reset()
- func (m *LogGroup) Size() (n int)
- func (m *LogGroup) String() string
- func (m *LogGroup) Unmarshal(dAtA []byte) error
- func (m *LogGroup) XXX_DiscardUnknown()
- func (m *LogGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogGroup) XXX_Merge(src proto.Message)
- func (m *LogGroup) XXX_Size() int
- func (m *LogGroup) XXX_Unmarshal(b []byte) error
- type LogGroupList
- func (*LogGroupList) Descriptor() ([]byte, []int)
- func (m *LogGroupList) GetLogGroupList() []*LogGroup
- func (m *LogGroupList) Marshal() (dAtA []byte, err error)
- func (m *LogGroupList) MarshalTo(dAtA []byte) (int, error)
- func (m *LogGroupList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogGroupList) ProtoMessage()
- func (m *LogGroupList) Reset()
- func (m *LogGroupList) Size() (n int)
- func (m *LogGroupList) String() string
- func (m *LogGroupList) Unmarshal(dAtA []byte) error
- func (m *LogGroupList) XXX_DiscardUnknown()
- func (m *LogGroupList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogGroupList) XXX_Merge(src proto.Message)
- func (m *LogGroupList) XXX_Size() int
- func (m *LogGroupList) XXX_Unmarshal(b []byte) error
- type LogReportServiceClient
- type LogReportServiceServer
- type LogReportService_CollectClient
- type LogReportService_CollectServer
- type LogTag
- func (*LogTag) Descriptor() ([]byte, []int)
- func (m *LogTag) GetKey() string
- func (m *LogTag) GetValue() string
- func (m *LogTag) Marshal() (dAtA []byte, err error)
- func (m *LogTag) MarshalTo(dAtA []byte) (int, error)
- func (m *LogTag) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogTag) ProtoMessage()
- func (m *LogTag) Reset()
- func (m *LogTag) Size() (n int)
- func (m *LogTag) String() string
- func (m *LogTag) Unmarshal(dAtA []byte) error
- func (m *LogTag) XXX_DiscardUnknown()
- func (m *LogTag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogTag) XXX_Merge(src proto.Message)
- func (m *LogTag) XXX_Size() int
- func (m *LogTag) XXX_Unmarshal(b []byte) error
- type Log_Content
- func (*Log_Content) Descriptor() ([]byte, []int)
- func (m *Log_Content) GetKey() string
- func (m *Log_Content) GetValue() string
- func (m *Log_Content) Marshal() (dAtA []byte, err error)
- func (m *Log_Content) MarshalTo(dAtA []byte) (int, error)
- func (m *Log_Content) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Log_Content) ProtoMessage()
- func (m *Log_Content) Reset()
- func (m *Log_Content) Size() (n int)
- func (m *Log_Content) String() string
- func (m *Log_Content) Unmarshal(dAtA []byte) error
- func (m *Log_Content) XXX_DiscardUnknown()
- func (m *Log_Content) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Log_Content) XXX_Merge(src proto.Message)
- func (m *Log_Content) XXX_Size() int
- func (m *Log_Content) XXX_Unmarshal(b []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetCode() ResponseCode
- func (m *Response) GetMessage() string
- func (m *Response) Marshal() (dAtA []byte, err error)
- func (m *Response) MarshalTo(dAtA []byte) (int, error)
- func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) Size() (n int)
- func (m *Response) String() string
- func (m *Response) Unmarshal(dAtA []byte) error
- func (m *Response) XXX_DiscardUnknown()
- func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response) XXX_Merge(src proto.Message)
- func (m *Response) XXX_Size() int
- func (m *Response) XXX_Unmarshal(b []byte) error
- type ResponseCode
- type SlsLogPackage
- func (*SlsLogPackage) Descriptor() ([]byte, []int)
- func (m *SlsLogPackage) GetData() []byte
- func (m *SlsLogPackage) GetUncompressSize() int32
- func (m *SlsLogPackage) Marshal() (dAtA []byte, err error)
- func (m *SlsLogPackage) MarshalTo(dAtA []byte) (int, error)
- func (m *SlsLogPackage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SlsLogPackage) ProtoMessage()
- func (m *SlsLogPackage) Reset()
- func (m *SlsLogPackage) Size() (n int)
- func (m *SlsLogPackage) String() string
- func (m *SlsLogPackage) Unmarshal(dAtA []byte) error
- func (m *SlsLogPackage) XXX_DiscardUnknown()
- func (m *SlsLogPackage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SlsLogPackage) XXX_Merge(src proto.Message)
- func (m *SlsLogPackage) XXX_Size() int
- func (m *SlsLogPackage) XXX_Unmarshal(b []byte) error
- type SlsLogPackageList
- func (*SlsLogPackageList) Descriptor() ([]byte, []int)
- func (m *SlsLogPackageList) GetPackages() []*SlsLogPackage
- func (m *SlsLogPackageList) Marshal() (dAtA []byte, err error)
- func (m *SlsLogPackageList) MarshalTo(dAtA []byte) (int, error)
- func (m *SlsLogPackageList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SlsLogPackageList) ProtoMessage()
- func (m *SlsLogPackageList) Reset()
- func (m *SlsLogPackageList) Size() (n int)
- func (m *SlsLogPackageList) String() string
- func (m *SlsLogPackageList) Unmarshal(dAtA []byte) error
- func (m *SlsLogPackageList) XXX_DiscardUnknown()
- func (m *SlsLogPackageList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SlsLogPackageList) XXX_Merge(src proto.Message)
- func (m *SlsLogPackageList) XXX_Size() int
- func (m *SlsLogPackageList) XXX_Unmarshal(b []byte) error
- type UnimplementedLogReportServiceServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthSlsLogs = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSlsLogs = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupSlsLogs = fmt.Errorf("proto: unexpected end of group") )
View Source
var ( ErrInvalidLengthSlsLogsTransfer = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSlsLogsTransfer = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupSlsLogsTransfer = fmt.Errorf("proto: unexpected end of group") )
View Source
var ResponseCode_name = map[int32]string{
0: "Success",
1: "Failure",
}
View Source
var ResponseCode_value = map[string]int32{
"Success": 0,
"Failure": 1,
}
Functions ¶
func RegisterLogReportServiceServer ¶
func RegisterLogReportServiceServer(s *grpc.Server, srv LogReportServiceServer)
func SetLogTime ¶
func SetLogTimeWithNano ¶
Types ¶
type Log ¶
type Log struct { Time uint32 `protobuf:"varint,1,req,name=Time" json:"Time"` Contents []*Log_Content `protobuf:"bytes,2,rep,name=Contents" json:"Contents,omitempty"` Values []string `protobuf:"bytes,3,rep,name=values" json:"values,omitempty"` TimeNs *uint32 `protobuf:"fixed32,4,opt,name=Time_ns,json=TimeNs" json:"Time_ns,omitempty"` }
func (*Log) Descriptor ¶
func (*Log) GetContents ¶
func (m *Log) GetContents() []*Log_Content
func (*Log) ProtoMessage ¶
func (*Log) ProtoMessage()
func (*Log) XXX_DiscardUnknown ¶
func (m *Log) XXX_DiscardUnknown()
func (*Log) XXX_Unmarshal ¶
type LogGroup ¶
type LogGroup struct { Logs []*Log `protobuf:"bytes,1,rep,name=Logs" json:"Logs,omitempty"` Category string `protobuf:"bytes,2,opt,name=Category" json:"Category"` Topic string `protobuf:"bytes,3,opt,name=Topic" json:"Topic"` Source string `protobuf:"bytes,4,opt,name=Source" json:"Source"` MachineUUID string `protobuf:"bytes,5,opt,name=MachineUUID" json:"MachineUUID"` LogTags []*LogTag `protobuf:"bytes,6,rep,name=LogTags" json:"LogTags,omitempty"` }
func (*LogGroup) Descriptor ¶
func (*LogGroup) GetCategory ¶
func (*LogGroup) GetLogTags ¶
func (*LogGroup) GetMachineUUID ¶
func (*LogGroup) MarshalToSizedBuffer ¶
func (*LogGroup) ProtoMessage ¶
func (*LogGroup) ProtoMessage()
func (*LogGroup) XXX_DiscardUnknown ¶
func (m *LogGroup) XXX_DiscardUnknown()
func (*LogGroup) XXX_Marshal ¶
func (*LogGroup) XXX_Unmarshal ¶
type LogGroupList ¶
type LogGroupList struct {
LogGroupList []*LogGroup `protobuf:"bytes,1,rep,name=logGroupList" json:"logGroupList,omitempty"`
}
func (*LogGroupList) Descriptor ¶
func (*LogGroupList) Descriptor() ([]byte, []int)
func (*LogGroupList) GetLogGroupList ¶
func (m *LogGroupList) GetLogGroupList() []*LogGroup
func (*LogGroupList) Marshal ¶
func (m *LogGroupList) Marshal() (dAtA []byte, err error)
func (*LogGroupList) MarshalToSizedBuffer ¶
func (m *LogGroupList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogGroupList) ProtoMessage ¶
func (*LogGroupList) ProtoMessage()
func (*LogGroupList) Reset ¶
func (m *LogGroupList) Reset()
func (*LogGroupList) Size ¶
func (m *LogGroupList) Size() (n int)
func (*LogGroupList) String ¶
func (m *LogGroupList) String() string
func (*LogGroupList) Unmarshal ¶
func (m *LogGroupList) Unmarshal(dAtA []byte) error
func (*LogGroupList) XXX_DiscardUnknown ¶
func (m *LogGroupList) XXX_DiscardUnknown()
func (*LogGroupList) XXX_Marshal ¶
func (m *LogGroupList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogGroupList) XXX_Merge ¶
func (m *LogGroupList) XXX_Merge(src proto.Message)
func (*LogGroupList) XXX_Size ¶
func (m *LogGroupList) XXX_Size() int
func (*LogGroupList) XXX_Unmarshal ¶
func (m *LogGroupList) XXX_Unmarshal(b []byte) error
type LogReportServiceClient ¶
type LogReportServiceClient interface {
Collect(ctx context.Context, opts ...grpc.CallOption) (LogReportService_CollectClient, error)
}
LogReportServiceClient is the client API for LogReportService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLogReportServiceClient ¶
func NewLogReportServiceClient(cc *grpc.ClientConn) LogReportServiceClient
type LogReportServiceServer ¶
type LogReportServiceServer interface {
Collect(LogReportService_CollectServer) error
}
LogReportServiceServer is the server API for LogReportService service.
type LogTag ¶
type LogTag struct { Key string `protobuf:"bytes,1,req,name=Key" json:"Key"` Value string `protobuf:"bytes,2,req,name=Value" json:"Value"` }
func (*LogTag) Descriptor ¶
func (*LogTag) MarshalToSizedBuffer ¶
func (*LogTag) ProtoMessage ¶
func (*LogTag) ProtoMessage()
func (*LogTag) XXX_DiscardUnknown ¶
func (m *LogTag) XXX_DiscardUnknown()
func (*LogTag) XXX_Marshal ¶
func (*LogTag) XXX_Unmarshal ¶
type Log_Content ¶
type Log_Content struct { Key string `protobuf:"bytes,1,req,name=Key" json:"Key"` Value string `protobuf:"bytes,2,req,name=Value" json:"Value"` }
func (*Log_Content) Descriptor ¶
func (*Log_Content) Descriptor() ([]byte, []int)
func (*Log_Content) GetKey ¶
func (m *Log_Content) GetKey() string
func (*Log_Content) GetValue ¶
func (m *Log_Content) GetValue() string
func (*Log_Content) Marshal ¶
func (m *Log_Content) Marshal() (dAtA []byte, err error)
func (*Log_Content) MarshalToSizedBuffer ¶
func (m *Log_Content) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Log_Content) ProtoMessage ¶
func (*Log_Content) ProtoMessage()
func (*Log_Content) Reset ¶
func (m *Log_Content) Reset()
func (*Log_Content) Size ¶
func (m *Log_Content) Size() (n int)
func (*Log_Content) String ¶
func (m *Log_Content) String() string
func (*Log_Content) Unmarshal ¶
func (m *Log_Content) Unmarshal(dAtA []byte) error
func (*Log_Content) XXX_DiscardUnknown ¶
func (m *Log_Content) XXX_DiscardUnknown()
func (*Log_Content) XXX_Marshal ¶
func (m *Log_Content) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Log_Content) XXX_Merge ¶
func (m *Log_Content) XXX_Merge(src proto.Message)
func (*Log_Content) XXX_Size ¶
func (m *Log_Content) XXX_Size() int
func (*Log_Content) XXX_Unmarshal ¶
func (m *Log_Content) XXX_Unmarshal(b []byte) error
type Response ¶
type Response struct { Code ResponseCode `protobuf:"varint,1,req,name=code,enum=sls_logs.ResponseCode" json:"code"` Message string `protobuf:"bytes,2,req,name=message" json:"message"` }
func (*Response) Descriptor ¶
func (*Response) GetCode ¶
func (m *Response) GetCode() ResponseCode
func (*Response) GetMessage ¶
func (*Response) MarshalToSizedBuffer ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) XXX_DiscardUnknown ¶
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶
func (*Response) XXX_Unmarshal ¶
type ResponseCode ¶
type ResponseCode int32
const ( ResponseCode_Success ResponseCode = 0 ResponseCode_Failure ResponseCode = 1 )
func (ResponseCode) Enum ¶
func (x ResponseCode) Enum() *ResponseCode
func (ResponseCode) EnumDescriptor ¶
func (ResponseCode) EnumDescriptor() ([]byte, []int)
func (ResponseCode) String ¶
func (x ResponseCode) String() string
func (*ResponseCode) UnmarshalJSON ¶
func (x *ResponseCode) UnmarshalJSON(data []byte) error
type SlsLogPackage ¶
type SlsLogPackage struct { Data []byte `protobuf:"bytes,1,req,name=data" json:"data"` UncompressSize int32 `protobuf:"varint,2,opt,name=uncompress_size,json=uncompressSize" json:"uncompress_size"` }
func (*SlsLogPackage) Descriptor ¶
func (*SlsLogPackage) Descriptor() ([]byte, []int)
func (*SlsLogPackage) GetData ¶
func (m *SlsLogPackage) GetData() []byte
func (*SlsLogPackage) GetUncompressSize ¶
func (m *SlsLogPackage) GetUncompressSize() int32
func (*SlsLogPackage) Marshal ¶
func (m *SlsLogPackage) Marshal() (dAtA []byte, err error)
func (*SlsLogPackage) MarshalToSizedBuffer ¶
func (m *SlsLogPackage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SlsLogPackage) ProtoMessage ¶
func (*SlsLogPackage) ProtoMessage()
func (*SlsLogPackage) Reset ¶
func (m *SlsLogPackage) Reset()
func (*SlsLogPackage) Size ¶
func (m *SlsLogPackage) Size() (n int)
func (*SlsLogPackage) String ¶
func (m *SlsLogPackage) String() string
func (*SlsLogPackage) Unmarshal ¶
func (m *SlsLogPackage) Unmarshal(dAtA []byte) error
func (*SlsLogPackage) XXX_DiscardUnknown ¶
func (m *SlsLogPackage) XXX_DiscardUnknown()
func (*SlsLogPackage) XXX_Marshal ¶
func (m *SlsLogPackage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SlsLogPackage) XXX_Merge ¶
func (m *SlsLogPackage) XXX_Merge(src proto.Message)
func (*SlsLogPackage) XXX_Size ¶
func (m *SlsLogPackage) XXX_Size() int
func (*SlsLogPackage) XXX_Unmarshal ¶
func (m *SlsLogPackage) XXX_Unmarshal(b []byte) error
type SlsLogPackageList ¶
type SlsLogPackageList struct {
Packages []*SlsLogPackage `protobuf:"bytes,1,rep,name=packages" json:"packages,omitempty"`
}
func (*SlsLogPackageList) Descriptor ¶
func (*SlsLogPackageList) Descriptor() ([]byte, []int)
func (*SlsLogPackageList) GetPackages ¶
func (m *SlsLogPackageList) GetPackages() []*SlsLogPackage
func (*SlsLogPackageList) Marshal ¶
func (m *SlsLogPackageList) Marshal() (dAtA []byte, err error)
func (*SlsLogPackageList) MarshalTo ¶
func (m *SlsLogPackageList) MarshalTo(dAtA []byte) (int, error)
func (*SlsLogPackageList) MarshalToSizedBuffer ¶
func (m *SlsLogPackageList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SlsLogPackageList) ProtoMessage ¶
func (*SlsLogPackageList) ProtoMessage()
func (*SlsLogPackageList) Reset ¶
func (m *SlsLogPackageList) Reset()
func (*SlsLogPackageList) Size ¶
func (m *SlsLogPackageList) Size() (n int)
func (*SlsLogPackageList) String ¶
func (m *SlsLogPackageList) String() string
func (*SlsLogPackageList) Unmarshal ¶
func (m *SlsLogPackageList) Unmarshal(dAtA []byte) error
func (*SlsLogPackageList) XXX_DiscardUnknown ¶
func (m *SlsLogPackageList) XXX_DiscardUnknown()
func (*SlsLogPackageList) XXX_Marshal ¶
func (m *SlsLogPackageList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SlsLogPackageList) XXX_Merge ¶
func (m *SlsLogPackageList) XXX_Merge(src proto.Message)
func (*SlsLogPackageList) XXX_Size ¶
func (m *SlsLogPackageList) XXX_Size() int
func (*SlsLogPackageList) XXX_Unmarshal ¶
func (m *SlsLogPackageList) XXX_Unmarshal(b []byte) error
type UnimplementedLogReportServiceServer ¶
type UnimplementedLogReportServiceServer struct { }
UnimplementedLogReportServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedLogReportServiceServer) Collect ¶
func (*UnimplementedLogReportServiceServer) Collect(srv LogReportService_CollectServer) error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.