protocol

package
v0.0.0-...-4030fd3 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLogEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLogEvent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMetricEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetricEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetricEvent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPipelineEventGroup        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPipelineEventGroup          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPipelineEventGroup = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthSpanEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSpanEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSpanEvent = 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,
}
View Source 
var SpanEvent_SpanKind_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "INTERVAL",
	2: "SERVER",
	3: "CLIENT",
	4: "PRODUCER",
	5: "CONSUMER",
}
View Source 
var SpanEvent_SpanKind_value = map[string]int32{
	"UNSPECIFIED": 0,
	"INTERVAL":    1,
	"SERVER":      2,
	"CLIENT":      3,
	"PRODUCER":    4,
	"CONSUMER":    5,
}
View Source 
var SpanEvent_StatusCode_name = map[int32]string{
	0: "Unset",
	1: "Ok",
	2: "Error",
}
View Source 
var SpanEvent_StatusCode_value = map[string]int32{
	"Unset": 0,
	"Ok":    1,
	"Error": 2,
}

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 LogEvent 

type LogEvent struct {
	Timestamp  uint64              `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Contents   []*LogEvent_Content `protobuf:"bytes,2,rep,name=Contents,proto3" json:"Contents,omitempty"`
	Level      []byte              `protobuf:"bytes,3,opt,name=Level,proto3" json:"Level,omitempty"`
	FileOffset uint64              `protobuf:"varint,4,opt,name=FileOffset,proto3" json:"FileOffset,omitempty"`
	RawSize    uint64              `protobuf:"varint,5,opt,name=RawSize,proto3" json:"RawSize,omitempty"`
}

func (*LogEvent) Descriptor 

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

func (*LogEvent) GetContents 

func (m *LogEvent) GetContents() []*LogEvent_Content

func (*LogEvent) GetFileOffset 

func (m *LogEvent) GetFileOffset() uint64

func (*LogEvent) GetLevel 

func (m *LogEvent) GetLevel() []byte

func (*LogEvent) GetRawSize 

func (m *LogEvent) GetRawSize() uint64

func (*LogEvent) GetTimestamp 

func (m *LogEvent) GetTimestamp() uint64

func (*LogEvent) Marshal 

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

func (*LogEvent) MarshalTo 

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

func (*LogEvent) MarshalToSizedBuffer 

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

func (*LogEvent) ProtoMessage 

func (*LogEvent) ProtoMessage()

func (*LogEvent) Reset 

func (m *LogEvent) Reset()

func (*LogEvent) Size 

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

func (*LogEvent) String 

func (m *LogEvent) String() string

func (*LogEvent) Unmarshal 

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

func (*LogEvent) XXX_DiscardUnknown 

func (m *LogEvent) XXX_DiscardUnknown()

func (*LogEvent) XXX_Marshal 

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

func (*LogEvent) XXX_Merge 

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

func (*LogEvent) XXX_Size 

func (m *LogEvent) XXX_Size() int

func (*LogEvent) XXX_Unmarshal 

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

type LogEvent_Content 

type LogEvent_Content struct {
	Key   []byte `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
}

func (*LogEvent_Content) Descriptor 

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

func (*LogEvent_Content) GetKey 

func (m *LogEvent_Content) GetKey() []byte

func (*LogEvent_Content) GetValue 

func (m *LogEvent_Content) GetValue() []byte

func (*LogEvent_Content) Marshal 

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

func (*LogEvent_Content) MarshalTo 

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

func (*LogEvent_Content) MarshalToSizedBuffer 

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

func (*LogEvent_Content) ProtoMessage 

func (*LogEvent_Content) ProtoMessage()

func (*LogEvent_Content) Reset 

func (m *LogEvent_Content) Reset()

func (*LogEvent_Content) Size 

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

func (*LogEvent_Content) String 

func (m *LogEvent_Content) String() string

func (*LogEvent_Content) Unmarshal 

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

func (*LogEvent_Content) XXX_DiscardUnknown 

func (m *LogEvent_Content) XXX_DiscardUnknown()

func (*LogEvent_Content) XXX_Marshal 

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

func (*LogEvent_Content) XXX_Merge 

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

func (*LogEvent_Content) XXX_Size 

func (m *LogEvent_Content) XXX_Size() int

func (*LogEvent_Content) XXX_Unmarshal 

func (m *LogEvent_Content) 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 MetricEvent 

type MetricEvent struct {
	Timestamp uint64            `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Name      []byte            `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Tags      map[string][]byte `` /* 149-byte string literal not displayed */
	// Types that are valid to be assigned to Value:
	//
	//	*MetricEvent_UntypedSingleValue
	Value isMetricEvent_Value `protobuf_oneof:"Value"`
}

func (*MetricEvent) Descriptor 

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

func (*MetricEvent) GetName 

func (m *MetricEvent) GetName() []byte

func (*MetricEvent) GetTags 

func (m *MetricEvent) GetTags() map[string][]byte

func (*MetricEvent) GetTimestamp 

func (m *MetricEvent) GetTimestamp() uint64

func (*MetricEvent) GetUntypedSingleValue 

func (m *MetricEvent) GetUntypedSingleValue() *UntypedSingleValue

func (*MetricEvent) GetValue 

func (m *MetricEvent) GetValue() isMetricEvent_Value

func (*MetricEvent) Marshal 

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

func (*MetricEvent) MarshalTo 

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

func (*MetricEvent) MarshalToSizedBuffer 

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

func (*MetricEvent) ProtoMessage 

func (*MetricEvent) ProtoMessage()

func (*MetricEvent) Reset 

func (m *MetricEvent) Reset()

func (*MetricEvent) Size 

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

func (*MetricEvent) String 

func (m *MetricEvent) String() string

func (*MetricEvent) Unmarshal 

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

func (*MetricEvent) XXX_DiscardUnknown 

func (m *MetricEvent) XXX_DiscardUnknown()

func (*MetricEvent) XXX_Marshal 

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

func (*MetricEvent) XXX_Merge 

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

func (*MetricEvent) XXX_OneofWrappers 

func (*MetricEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MetricEvent) XXX_Size 

func (m *MetricEvent) XXX_Size() int

func (*MetricEvent) XXX_Unmarshal 

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

type MetricEvent_UntypedSingleValue 

type MetricEvent_UntypedSingleValue struct {
	UntypedSingleValue *UntypedSingleValue `protobuf:"bytes,4,opt,name=UntypedSingleValue,proto3,oneof" json:"UntypedSingleValue,omitempty"`
}

func (*MetricEvent_UntypedSingleValue) MarshalTo 

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

func (*MetricEvent_UntypedSingleValue) MarshalToSizedBuffer 

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

func (*MetricEvent_UntypedSingleValue) Size 

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

type PipelineEventGroup 

type PipelineEventGroup struct {
	Metadata map[string][]byte `` /* 157-byte string literal not displayed */
	Tags     map[string][]byte `` /* 149-byte string literal not displayed */
	// Types that are valid to be assigned to PipelineEvents:
	//	*PipelineEventGroup_Logs
	//	*PipelineEventGroup_Metrics
	//	*PipelineEventGroup_Spans
	PipelineEvents isPipelineEventGroup_PipelineEvents `protobuf_oneof:"PipelineEvents"`
}

func (*PipelineEventGroup) Descriptor 

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

func (*PipelineEventGroup) GetLogs 

func (m *PipelineEventGroup) GetLogs() *PipelineEventGroup_LogEvents

func (*PipelineEventGroup) GetMetadata 

func (m *PipelineEventGroup) GetMetadata() map[string][]byte

func (*PipelineEventGroup) GetMetrics 

func (m *PipelineEventGroup) GetMetrics() *PipelineEventGroup_MetricEvents

func (*PipelineEventGroup) GetPipelineEvents 

func (m *PipelineEventGroup) GetPipelineEvents() isPipelineEventGroup_PipelineEvents

func (*PipelineEventGroup) GetSpans 

func (m *PipelineEventGroup) GetSpans() *PipelineEventGroup_SpanEvents

func (*PipelineEventGroup) GetTags 

func (m *PipelineEventGroup) GetTags() map[string][]byte

func (*PipelineEventGroup) Marshal 

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

func (*PipelineEventGroup) MarshalTo 

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

func (*PipelineEventGroup) MarshalToSizedBuffer 

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

func (*PipelineEventGroup) ProtoMessage 

func (*PipelineEventGroup) ProtoMessage()

func (*PipelineEventGroup) Reset 

func (m *PipelineEventGroup) Reset()

func (*PipelineEventGroup) Size 

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

func (*PipelineEventGroup) String 

func (m *PipelineEventGroup) String() string

func (*PipelineEventGroup) Unmarshal 

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

func (*PipelineEventGroup) XXX_DiscardUnknown 

func (m *PipelineEventGroup) XXX_DiscardUnknown()

func (*PipelineEventGroup) XXX_Marshal 

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

func (*PipelineEventGroup) XXX_Merge 

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

func (*PipelineEventGroup) XXX_OneofWrappers 

func (*PipelineEventGroup) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PipelineEventGroup) XXX_Size 

func (m *PipelineEventGroup) XXX_Size() int

func (*PipelineEventGroup) XXX_Unmarshal 

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

type PipelineEventGroup_LogEvents 

type PipelineEventGroup_LogEvents struct {
	Events []*LogEvent `protobuf:"bytes,1,rep,name=Events,proto3" json:"Events,omitempty"`
}

func (*PipelineEventGroup_LogEvents) Descriptor 

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

func (*PipelineEventGroup_LogEvents) GetEvents 

func (m *PipelineEventGroup_LogEvents) GetEvents() []*LogEvent

func (*PipelineEventGroup_LogEvents) Marshal 

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

func (*PipelineEventGroup_LogEvents) MarshalTo 

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

func (*PipelineEventGroup_LogEvents) MarshalToSizedBuffer 

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

func (*PipelineEventGroup_LogEvents) ProtoMessage 

func (*PipelineEventGroup_LogEvents) ProtoMessage()

func (*PipelineEventGroup_LogEvents) Reset 

func (m *PipelineEventGroup_LogEvents) Reset()

func (*PipelineEventGroup_LogEvents) Size 

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

func (*PipelineEventGroup_LogEvents) String 

func (m *PipelineEventGroup_LogEvents) String() string

func (*PipelineEventGroup_LogEvents) Unmarshal 

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

func (*PipelineEventGroup_LogEvents) XXX_DiscardUnknown 

func (m *PipelineEventGroup_LogEvents) XXX_DiscardUnknown()

func (*PipelineEventGroup_LogEvents) XXX_Marshal 

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

func (*PipelineEventGroup_LogEvents) XXX_Merge 

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

func (*PipelineEventGroup_LogEvents) XXX_Size 

func (m *PipelineEventGroup_LogEvents) XXX_Size() int

func (*PipelineEventGroup_LogEvents) XXX_Unmarshal 

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

type PipelineEventGroup_Logs 

type PipelineEventGroup_Logs struct {
	Logs *PipelineEventGroup_LogEvents `protobuf:"bytes,3,opt,name=Logs,proto3,oneof" json:"Logs,omitempty"`
}

func (*PipelineEventGroup_Logs) MarshalTo 

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

func (*PipelineEventGroup_Logs) MarshalToSizedBuffer 

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

func (*PipelineEventGroup_Logs) Size 

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

type PipelineEventGroup_MetricEvents 

type PipelineEventGroup_MetricEvents struct {
	Events []*MetricEvent `protobuf:"bytes,1,rep,name=Events,proto3" json:"Events,omitempty"`
}

func (*PipelineEventGroup_MetricEvents) Descriptor 

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

func (*PipelineEventGroup_MetricEvents) GetEvents 

func (m *PipelineEventGroup_MetricEvents) GetEvents() []*MetricEvent

func (*PipelineEventGroup_MetricEvents) Marshal 

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

func (*PipelineEventGroup_MetricEvents) MarshalTo 

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

func (*PipelineEventGroup_MetricEvents) MarshalToSizedBuffer 

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

func (*PipelineEventGroup_MetricEvents) ProtoMessage 

func (*PipelineEventGroup_MetricEvents) ProtoMessage()

func (*PipelineEventGroup_MetricEvents) Reset 

func (m *PipelineEventGroup_MetricEvents) Reset()

func (*PipelineEventGroup_MetricEvents) Size 

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

func (*PipelineEventGroup_MetricEvents) String 

func (m *PipelineEventGroup_MetricEvents) String() string

func (*PipelineEventGroup_MetricEvents) Unmarshal 

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

func (*PipelineEventGroup_MetricEvents) XXX_DiscardUnknown 

func (m *PipelineEventGroup_MetricEvents) XXX_DiscardUnknown()

func (*PipelineEventGroup_MetricEvents) XXX_Marshal 

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

func (*PipelineEventGroup_MetricEvents) XXX_Merge 

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

func (*PipelineEventGroup_MetricEvents) XXX_Size 

func (m *PipelineEventGroup_MetricEvents) XXX_Size() int

func (*PipelineEventGroup_MetricEvents) XXX_Unmarshal 

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

type PipelineEventGroup_Metrics 

type PipelineEventGroup_Metrics struct {
	Metrics *PipelineEventGroup_MetricEvents `protobuf:"bytes,4,opt,name=Metrics,proto3,oneof" json:"Metrics,omitempty"`
}

func (*PipelineEventGroup_Metrics) MarshalTo 

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

func (*PipelineEventGroup_Metrics) MarshalToSizedBuffer 

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

func (*PipelineEventGroup_Metrics) Size 

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

type PipelineEventGroup_SpanEvents 

type PipelineEventGroup_SpanEvents struct {
	Events []*SpanEvent `protobuf:"bytes,1,rep,name=Events,proto3" json:"Events,omitempty"`
}

func (*PipelineEventGroup_SpanEvents) Descriptor 

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

func (*PipelineEventGroup_SpanEvents) GetEvents 

func (m *PipelineEventGroup_SpanEvents) GetEvents() []*SpanEvent

func (*PipelineEventGroup_SpanEvents) Marshal 

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

func (*PipelineEventGroup_SpanEvents) MarshalTo 

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

func (*PipelineEventGroup_SpanEvents) MarshalToSizedBuffer 

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

func (*PipelineEventGroup_SpanEvents) ProtoMessage 

func (*PipelineEventGroup_SpanEvents) ProtoMessage()

func (*PipelineEventGroup_SpanEvents) Reset 

func (m *PipelineEventGroup_SpanEvents) Reset()

func (*PipelineEventGroup_SpanEvents) Size 

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

func (*PipelineEventGroup_SpanEvents) String 

func (m *PipelineEventGroup_SpanEvents) String() string

func (*PipelineEventGroup_SpanEvents) Unmarshal 

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

func (*PipelineEventGroup_SpanEvents) XXX_DiscardUnknown 

func (m *PipelineEventGroup_SpanEvents) XXX_DiscardUnknown()

func (*PipelineEventGroup_SpanEvents) XXX_Marshal 

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

func (*PipelineEventGroup_SpanEvents) XXX_Merge 

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

func (*PipelineEventGroup_SpanEvents) XXX_Size 

func (m *PipelineEventGroup_SpanEvents) XXX_Size() int

func (*PipelineEventGroup_SpanEvents) XXX_Unmarshal 

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

type PipelineEventGroup_Spans 

type PipelineEventGroup_Spans struct {
	Spans *PipelineEventGroup_SpanEvents `protobuf:"bytes,5,opt,name=Spans,proto3,oneof" json:"Spans,omitempty"`
}

func (*PipelineEventGroup_Spans) MarshalTo 

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

func (*PipelineEventGroup_Spans) MarshalToSizedBuffer 

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

func (*PipelineEventGroup_Spans) Size 

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

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 SpanEvent 

type SpanEvent struct {
	Timestamp    uint64                  `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	TraceID      []byte                  `protobuf:"bytes,2,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	SpanID       []byte                  `protobuf:"bytes,3,opt,name=SpanID,proto3" json:"SpanID,omitempty"`
	TraceState   []byte                  `protobuf:"bytes,4,opt,name=TraceState,proto3" json:"TraceState,omitempty"`
	ParentSpanID []byte                  `protobuf:"bytes,5,opt,name=ParentSpanID,proto3" json:"ParentSpanID,omitempty"`
	Name         []byte                  `protobuf:"bytes,6,opt,name=Name,proto3" json:"Name,omitempty"`
	Kind         SpanEvent_SpanKind      `protobuf:"varint,7,opt,name=Kind,proto3,enum=logtail.models.SpanEvent_SpanKind" json:"Kind,omitempty"`
	StartTime    uint64                  `protobuf:"varint,8,opt,name=StartTime,proto3" json:"StartTime,omitempty"`
	EndTime      uint64                  `protobuf:"varint,9,opt,name=EndTime,proto3" json:"EndTime,omitempty"`
	Tags         map[string][]byte       `` /* 150-byte string literal not displayed */
	Events       []*SpanEvent_InnerEvent `protobuf:"bytes,11,rep,name=Events,proto3" json:"Events,omitempty"`
	Links        []*SpanEvent_SpanLink   `protobuf:"bytes,12,rep,name=Links,proto3" json:"Links,omitempty"`
	Status       SpanEvent_StatusCode    `protobuf:"varint,13,opt,name=Status,proto3,enum=logtail.models.SpanEvent_StatusCode" json:"Status,omitempty"`
	ScopeTags    map[string][]byte       `` /* 160-byte string literal not displayed */
}

func (*SpanEvent) Descriptor 

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

func (*SpanEvent) GetEndTime 

func (m *SpanEvent) GetEndTime() uint64

func (*SpanEvent) GetEvents 

func (m *SpanEvent) GetEvents() []*SpanEvent_InnerEvent

func (*SpanEvent) GetKind 

func (m *SpanEvent) GetKind() SpanEvent_SpanKind
func (m *SpanEvent) GetLinks() []*SpanEvent_SpanLink

func (*SpanEvent) GetName 

func (m *SpanEvent) GetName() []byte

func (*SpanEvent) GetParentSpanID 

func (m *SpanEvent) GetParentSpanID() []byte

func (*SpanEvent) GetScopeTags 

func (m *SpanEvent) GetScopeTags() map[string][]byte

func (*SpanEvent) GetSpanID 

func (m *SpanEvent) GetSpanID() []byte

func (*SpanEvent) GetStartTime 

func (m *SpanEvent) GetStartTime() uint64

func (*SpanEvent) GetStatus 

func (m *SpanEvent) GetStatus() SpanEvent_StatusCode

func (*SpanEvent) GetTags 

func (m *SpanEvent) GetTags() map[string][]byte

func (*SpanEvent) GetTimestamp 

func (m *SpanEvent) GetTimestamp() uint64

func (*SpanEvent) GetTraceID 

func (m *SpanEvent) GetTraceID() []byte

func (*SpanEvent) GetTraceState 

func (m *SpanEvent) GetTraceState() []byte

func (*SpanEvent) Marshal 

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

func (*SpanEvent) MarshalTo 

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

func (*SpanEvent) MarshalToSizedBuffer 

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

func (*SpanEvent) ProtoMessage 

func (*SpanEvent) ProtoMessage()

func (*SpanEvent) Reset 

func (m *SpanEvent) Reset()

func (*SpanEvent) Size 

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

func (*SpanEvent) String 

func (m *SpanEvent) String() string

func (*SpanEvent) Unmarshal 

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

func (*SpanEvent) XXX_DiscardUnknown 

func (m *SpanEvent) XXX_DiscardUnknown()

func (*SpanEvent) XXX_Marshal 

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

func (*SpanEvent) XXX_Merge 

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

func (*SpanEvent) XXX_Size 

func (m *SpanEvent) XXX_Size() int

func (*SpanEvent) XXX_Unmarshal 

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

type SpanEvent_InnerEvent 

type SpanEvent_InnerEvent struct {
	Timestamp uint64            `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Name      []byte            `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Tags      map[string][]byte `` /* 149-byte string literal not displayed */
}

func (*SpanEvent_InnerEvent) Descriptor 

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

func (*SpanEvent_InnerEvent) GetName 

func (m *SpanEvent_InnerEvent) GetName() []byte

func (*SpanEvent_InnerEvent) GetTags 

func (m *SpanEvent_InnerEvent) GetTags() map[string][]byte

func (*SpanEvent_InnerEvent) GetTimestamp 

func (m *SpanEvent_InnerEvent) GetTimestamp() uint64

func (*SpanEvent_InnerEvent) Marshal 

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

func (*SpanEvent_InnerEvent) MarshalTo 

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

func (*SpanEvent_InnerEvent) MarshalToSizedBuffer 

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

func (*SpanEvent_InnerEvent) ProtoMessage 

func (*SpanEvent_InnerEvent) ProtoMessage()

func (*SpanEvent_InnerEvent) Reset 

func (m *SpanEvent_InnerEvent) Reset()

func (*SpanEvent_InnerEvent) Size 

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

func (*SpanEvent_InnerEvent) String 

func (m *SpanEvent_InnerEvent) String() string

func (*SpanEvent_InnerEvent) Unmarshal 

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

func (*SpanEvent_InnerEvent) XXX_DiscardUnknown 

func (m *SpanEvent_InnerEvent) XXX_DiscardUnknown()

func (*SpanEvent_InnerEvent) XXX_Marshal 

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

func (*SpanEvent_InnerEvent) XXX_Merge 

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

func (*SpanEvent_InnerEvent) XXX_Size 

func (m *SpanEvent_InnerEvent) XXX_Size() int

func (*SpanEvent_InnerEvent) XXX_Unmarshal 

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

type SpanEvent_SpanKind 

type SpanEvent_SpanKind int32
const (
	SpanEvent_UNSPECIFIED SpanEvent_SpanKind = 0
	SpanEvent_INTERVAL    SpanEvent_SpanKind = 1
	SpanEvent_SERVER      SpanEvent_SpanKind = 2
	SpanEvent_CLIENT      SpanEvent_SpanKind = 3
	SpanEvent_PRODUCER    SpanEvent_SpanKind = 4
	SpanEvent_CONSUMER    SpanEvent_SpanKind = 5
)

func (SpanEvent_SpanKind) EnumDescriptor 

func (SpanEvent_SpanKind) EnumDescriptor() ([]byte, []int)

func (SpanEvent_SpanKind) String 

func (x SpanEvent_SpanKind) String() string
type SpanEvent_SpanLink struct {
	TraceID    []byte            `protobuf:"bytes,1,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	SpanID     []byte            `protobuf:"bytes,2,opt,name=SpanID,proto3" json:"SpanID,omitempty"`
	TraceState []byte            `protobuf:"bytes,3,opt,name=TraceState,proto3" json:"TraceState,omitempty"`
	Tags       map[string][]byte `` /* 149-byte string literal not displayed */
}

func (*SpanEvent_SpanLink) Descriptor 

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

func (*SpanEvent_SpanLink) GetSpanID 

func (m *SpanEvent_SpanLink) GetSpanID() []byte

func (*SpanEvent_SpanLink) GetTags 

func (m *SpanEvent_SpanLink) GetTags() map[string][]byte

func (*SpanEvent_SpanLink) GetTraceID 

func (m *SpanEvent_SpanLink) GetTraceID() []byte

func (*SpanEvent_SpanLink) GetTraceState 

func (m *SpanEvent_SpanLink) GetTraceState() []byte

func (*SpanEvent_SpanLink) Marshal 

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

func (*SpanEvent_SpanLink) MarshalTo 

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

func (*SpanEvent_SpanLink) MarshalToSizedBuffer 

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

func (*SpanEvent_SpanLink) ProtoMessage 

func (*SpanEvent_SpanLink) ProtoMessage()

func (*SpanEvent_SpanLink) Reset 

func (m *SpanEvent_SpanLink) Reset()

func (*SpanEvent_SpanLink) Size 

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

func (*SpanEvent_SpanLink) String 

func (m *SpanEvent_SpanLink) String() string

func (*SpanEvent_SpanLink) Unmarshal 

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

func (*SpanEvent_SpanLink) XXX_DiscardUnknown 

func (m *SpanEvent_SpanLink) XXX_DiscardUnknown()

func (*SpanEvent_SpanLink) XXX_Marshal 

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

func (*SpanEvent_SpanLink) XXX_Merge 

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

func (*SpanEvent_SpanLink) XXX_Size 

func (m *SpanEvent_SpanLink) XXX_Size() int

func (*SpanEvent_SpanLink) XXX_Unmarshal 

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

type SpanEvent_StatusCode 

type SpanEvent_StatusCode int32
const (
	SpanEvent_Unset SpanEvent_StatusCode = 0
	SpanEvent_Ok    SpanEvent_StatusCode = 1
	SpanEvent_Error SpanEvent_StatusCode = 2
)

func (SpanEvent_StatusCode) EnumDescriptor 

func (SpanEvent_StatusCode) EnumDescriptor() ([]byte, []int)

func (SpanEvent_StatusCode) String 

func (x SpanEvent_StatusCode) String() string

type UnimplementedLogReportServiceServer 

type UnimplementedLogReportServiceServer struct {
}

UnimplementedLogReportServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogReportServiceServer) Collect 

func (*UnimplementedLogReportServiceServer) Collect(srv LogReportService_CollectServer) error

type UntypedSingleValue 

type UntypedSingleValue struct {
	Value float64 `protobuf:"fixed64,1,opt,name=Value,proto3" json:"Value,omitempty"`
}

func (*UntypedSingleValue) Descriptor 

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

func (*UntypedSingleValue) GetValue 

func (m *UntypedSingleValue) GetValue() float64

func (*UntypedSingleValue) Marshal 

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

func (*UntypedSingleValue) MarshalTo 

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

func (*UntypedSingleValue) MarshalToSizedBuffer 

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

func (*UntypedSingleValue) ProtoMessage 

func (*UntypedSingleValue) ProtoMessage()

func (*UntypedSingleValue) Reset 

func (m *UntypedSingleValue) Reset()

func (*UntypedSingleValue) Size 

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

func (*UntypedSingleValue) String 

func (m *UntypedSingleValue) String() string

func (*UntypedSingleValue) Unmarshal 

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

func (*UntypedSingleValue) XXX_DiscardUnknown 

func (m *UntypedSingleValue) XXX_DiscardUnknown()

func (*UntypedSingleValue) XXX_Marshal 

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

func (*UntypedSingleValue) XXX_Merge 

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

func (*UntypedSingleValue) XXX_Size 

func (m *UntypedSingleValue) XXX_Size() int

func (*UntypedSingleValue) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis
common
influxdb
opentelemetry
prometheus
pyroscope
raw
sls
statsd
common
prometheus

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.