protocol

package
v0.0.0-...-5f7612c Latest Latest
Warning

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

 Go to latest Published: May 9, 2024 License: Apache-2.0 Imports: 11 Imported by: 4

Documentation

Index

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 SetLogTime(log *Log, second uint32)

func SetLogTimeWithNano 

func SetLogTimeWithNano(log *Log, second uint32, nanosecond uint32)

Types

type Codec 

type Codec struct{}

func (Codec) Marshal 

func (Codec) Marshal(v interface{}) ([]byte, error)

func (Codec) Name 

func (Codec) Name() string

func (Codec) Unmarshal 

func (Codec) Unmarshal(data []byte, v interface{}) error

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 CloneLog 

func CloneLog(log *Log) *Log

func (*Log) Descriptor 

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

func (*Log) GetContents 

func (m *Log) GetContents() []*Log_Content

func (*Log) GetTime 

func (m *Log) GetTime() uint32

func (*Log) GetTimeNs 

func (m *Log) GetTimeNs() uint32

func (*Log) GetValues 

func (m *Log) GetValues() []string

func (*Log) Marshal 

func (m *Log) Marshal() (dAtA []byte, err error)

func (*Log) MarshalTo 

func (m *Log) MarshalTo(dAtA []byte) (int, error)

func (*Log) MarshalToSizedBuffer 

func (m *Log) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) Size 

func (m *Log) Size() (n int)

func (*Log) String 

func (m *Log) String() string

func (*Log) Unmarshal 

func (m *Log) Unmarshal(dAtA []byte) error

func (*Log) XXX_DiscardUnknown 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal 

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

func (*Log) XXX_Merge 

func (m *Log) XXX_Merge(src proto.Message)

func (*Log) XXX_Size 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*LogGroup) GetCategory 

func (m *LogGroup) GetCategory() string

func (*LogGroup) GetLogTags 

func (m *LogGroup) GetLogTags() []*LogTag

func (*LogGroup) GetLogs 

func (m *LogGroup) GetLogs() []*Log

func (*LogGroup) GetMachineUUID 

func (m *LogGroup) GetMachineUUID() string

func (*LogGroup) GetSource 

func (m *LogGroup) GetSource() string

func (*LogGroup) GetTopic 

func (m *LogGroup) GetTopic() string

func (*LogGroup) Marshal 

func (m *LogGroup) Marshal() (dAtA []byte, err error)

func (*LogGroup) MarshalTo 

func (m *LogGroup) MarshalTo(dAtA []byte) (int, error)

func (*LogGroup) MarshalToSizedBuffer 

func (m *LogGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogGroup) ProtoMessage 

func (*LogGroup) ProtoMessage()

func (*LogGroup) Reset 

func (m *LogGroup) Reset()

func (*LogGroup) Size 

func (m *LogGroup) Size() (n int)

func (*LogGroup) String 

func (m *LogGroup) String() string

func (*LogGroup) Unmarshal 

func (m *LogGroup) Unmarshal(dAtA []byte) error

func (*LogGroup) XXX_DiscardUnknown 

func (m *LogGroup) XXX_DiscardUnknown()

func (*LogGroup) XXX_Marshal 

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

func (*LogGroup) XXX_Merge 

func (m *LogGroup) XXX_Merge(src proto.Message)

func (*LogGroup) XXX_Size 

func (m *LogGroup) XXX_Size() int

func (*LogGroup) XXX_Unmarshal 

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

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) MarshalTo 

func (m *LogGroupList) MarshalTo(dAtA []byte) (int, 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 LogReportService_CollectClient 

type LogReportService_CollectClient interface {
	Send(*LogGroup) error
	CloseAndRecv() (*Response, error)
	grpc.ClientStream
}

type LogReportService_CollectServer 

type LogReportService_CollectServer interface {
	SendAndClose(*Response) error
	Recv() (*LogGroup, error)
	grpc.ServerStream
}

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) Descriptor() ([]byte, []int)

func (*LogTag) GetKey 

func (m *LogTag) GetKey() string

func (*LogTag) GetValue 

func (m *LogTag) GetValue() string

func (*LogTag) Marshal 

func (m *LogTag) Marshal() (dAtA []byte, err error)

func (*LogTag) MarshalTo 

func (m *LogTag) MarshalTo(dAtA []byte) (int, error)

func (*LogTag) MarshalToSizedBuffer 

func (m *LogTag) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogTag) ProtoMessage 

func (*LogTag) ProtoMessage()

func (*LogTag) Reset 

func (m *LogTag) Reset()

func (*LogTag) Size 

func (m *LogTag) Size() (n int)

func (*LogTag) String 

func (m *LogTag) String() string

func (*LogTag) Unmarshal 

func (m *LogTag) Unmarshal(dAtA []byte) error

func (*LogTag) XXX_DiscardUnknown 

func (m *LogTag) XXX_DiscardUnknown()

func (*LogTag) XXX_Marshal 

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

func (*LogTag) XXX_Merge 

func (m *LogTag) XXX_Merge(src proto.Message)

func (*LogTag) XXX_Size 

func (m *LogTag) XXX_Size() int

func (*LogTag) XXX_Unmarshal 

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

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) MarshalTo 

func (m *Log_Content) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Response) GetCode 

func (m *Response) GetCode() ResponseCode

func (*Response) GetMessage 

func (m *Response) GetMessage() string

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

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) MarshalTo 

func (m *SlsLogPackage) MarshalTo(dAtA []byte) (int, 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

View all Source files

Directories

Path Synopsis
common
influxdb
opentelemetry
prometheus
pyroscope
raw
sls
statsd

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.