Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterLogServiceServer(s grpc.ServiceRegistrar, srv LogServiceServer)
- type Attribute
- type LogMessageRequest
- func (*LogMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogMessageRequest) GetMessage() string
- func (x *LogMessageRequest) GetTimestamp() *timestamppb.Timestamp
- func (*LogMessageRequest) ProtoMessage()
- func (x *LogMessageRequest) ProtoReflect() protoreflect.Message
- func (x *LogMessageRequest) Reset()
- func (x *LogMessageRequest) String() string
- type LogMessageResponse
- func (*LogMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LogMessageResponse) GetSuccess() bool
- func (*LogMessageResponse) ProtoMessage()
- func (x *LogMessageResponse) ProtoReflect() protoreflect.Message
- func (x *LogMessageResponse) Reset()
- func (x *LogMessageResponse) String() string
- type LogServiceClient
- type LogServiceServer
- type OneSpan
- func (*OneSpan) Descriptor() ([]byte, []int)deprecated
- func (x *OneSpan) GetChildSpanCount() int32
- func (x *OneSpan) GetDuration() int64
- func (x *OneSpan) GetEvents_Attributes() []*Attribute
- func (x *OneSpan) GetEvents_Name() []string
- func (x *OneSpan) GetEvents_Timestamp() []*timestamppb.Timestamp
- func (x *OneSpan) GetLinks_Attributes() []*Attribute
- func (x *OneSpan) GetLinks_SpanId() []string
- func (x *OneSpan) GetLinks_TraceId() []string
- func (x *OneSpan) GetLinks_TraceState() []string
- func (x *OneSpan) GetParentSpanId() string
- func (x *OneSpan) GetResourceAttributes() map[string]string
- func (x *OneSpan) GetServiceName() string
- func (x *OneSpan) GetSpanAttributes() map[string]string
- func (x *OneSpan) GetSpanId() string
- func (x *OneSpan) GetSpanKind() string
- func (x *OneSpan) GetSpanName() string
- func (x *OneSpan) GetStatusCode() int32
- func (x *OneSpan) GetStatusMessage() string
- func (x *OneSpan) GetTimestamp() *timestamppb.Timestamp
- func (x *OneSpan) GetTraceId() string
- func (x *OneSpan) GetTraceState() string
- func (*OneSpan) ProtoMessage()
- func (x *OneSpan) ProtoReflect() protoreflect.Message
- func (x *OneSpan) Reset()
- func (x *OneSpan) String() string
- type Spans
- type UnimplementedLogServiceServer
- type UnsafeLogServiceServer
Constants ¶
const ( LogService_LogMessage_FullMethodName = "/logs.LogService/LogMessage" LogService_SendSpans_FullMethodName = "/logs.LogService/SendSpans" )
Variables ¶
var File_logs_proto protoreflect.FileDescriptor
var LogService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "logs.LogService", HandlerType: (*LogServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "LogMessage", Handler: _LogService_LogMessage_Handler, }, { MethodName: "SendSpans", Handler: _LogService_SendSpans_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "logs.proto", }
LogService_ServiceDesc is the grpc.ServiceDesc for LogService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLogServiceServer ¶
func RegisterLogServiceServer(s grpc.ServiceRegistrar, srv LogServiceServer)
Types ¶
type Attribute ¶
type Attribute struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Attribute) Descriptor
deprecated
func (*Attribute) ProtoMessage ¶
func (*Attribute) ProtoMessage()
func (*Attribute) ProtoReflect ¶
func (x *Attribute) ProtoReflect() protoreflect.Message
type LogMessageRequest ¶
type LogMessageRequest struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*LogMessageRequest) Descriptor
deprecated
func (*LogMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogMessageRequest.ProtoReflect.Descriptor instead.
func (*LogMessageRequest) GetMessage ¶
func (x *LogMessageRequest) GetMessage() string
func (*LogMessageRequest) GetTimestamp ¶
func (x *LogMessageRequest) GetTimestamp() *timestamppb.Timestamp
func (*LogMessageRequest) ProtoMessage ¶
func (*LogMessageRequest) ProtoMessage()
func (*LogMessageRequest) ProtoReflect ¶
func (x *LogMessageRequest) ProtoReflect() protoreflect.Message
func (*LogMessageRequest) Reset ¶
func (x *LogMessageRequest) Reset()
func (*LogMessageRequest) String ¶
func (x *LogMessageRequest) String() string
type LogMessageResponse ¶
type LogMessageResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*LogMessageResponse) Descriptor
deprecated
func (*LogMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogMessageResponse.ProtoReflect.Descriptor instead.
func (*LogMessageResponse) GetSuccess ¶
func (x *LogMessageResponse) GetSuccess() bool
func (*LogMessageResponse) ProtoMessage ¶
func (*LogMessageResponse) ProtoMessage()
func (*LogMessageResponse) ProtoReflect ¶
func (x *LogMessageResponse) ProtoReflect() protoreflect.Message
func (*LogMessageResponse) Reset ¶
func (x *LogMessageResponse) Reset()
func (*LogMessageResponse) String ¶
func (x *LogMessageResponse) String() string
type LogServiceClient ¶
type LogServiceClient interface { LogMessage(ctx context.Context, in *LogMessageRequest, opts ...grpc.CallOption) (*LogMessageResponse, error) SendSpans(ctx context.Context, in *Spans, opts ...grpc.CallOption) (*LogMessageResponse, error) }
LogServiceClient is the client API for LogService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewLogServiceClient ¶
func NewLogServiceClient(cc grpc.ClientConnInterface) LogServiceClient
type LogServiceServer ¶
type LogServiceServer interface { LogMessage(context.Context, *LogMessageRequest) (*LogMessageResponse, error) SendSpans(context.Context, *Spans) (*LogMessageResponse, error) // contains filtered or unexported methods }
LogServiceServer is the server API for LogService service. All implementations must embed UnimplementedLogServiceServer for forward compatibility
type OneSpan ¶
type OneSpan struct { Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"` TraceId string `protobuf:"bytes,2,opt,name=TraceId,proto3" json:"TraceId,omitempty"` SpanId string `protobuf:"bytes,3,opt,name=SpanId,proto3" json:"SpanId,omitempty"` ParentSpanId string `protobuf:"bytes,4,opt,name=ParentSpanId,proto3" json:"ParentSpanId,omitempty"` TraceState string `protobuf:"bytes,5,opt,name=TraceState,proto3" json:"TraceState,omitempty"` SpanName string `protobuf:"bytes,6,opt,name=SpanName,proto3" json:"SpanName,omitempty"` SpanKind string `protobuf:"bytes,7,opt,name=SpanKind,proto3" json:"SpanKind,omitempty"` ServiceName string `protobuf:"bytes,8,opt,name=ServiceName,proto3" json:"ServiceName,omitempty"` ResourceAttributes map[string]string `` /* 177-byte string literal not displayed */ SpanAttributes map[string]string `` /* 170-byte string literal not displayed */ Duration int64 `protobuf:"varint,11,opt,name=Duration,proto3" json:"Duration,omitempty"` StatusCode int32 `protobuf:"varint,12,opt,name=StatusCode,proto3" json:"StatusCode,omitempty"` StatusMessage string `protobuf:"bytes,13,opt,name=StatusMessage,proto3" json:"StatusMessage,omitempty"` Events_Timestamp []*timestamppb.Timestamp `protobuf:"bytes,14,rep,name=Events_Timestamp,json=EventsTimestamp,proto3" json:"Events_Timestamp,omitempty"` Events_Name []string `protobuf:"bytes,15,rep,name=Events_Name,json=EventsName,proto3" json:"Events_Name,omitempty"` Events_Attributes []*Attribute `protobuf:"bytes,16,rep,name=Events_Attributes,json=EventsAttributes,proto3" json:"Events_Attributes,omitempty"` Links_TraceId []string `protobuf:"bytes,17,rep,name=Links_TraceId,json=LinksTraceId,proto3" json:"Links_TraceId,omitempty"` Links_SpanId []string `protobuf:"bytes,18,rep,name=Links_SpanId,json=LinksSpanId,proto3" json:"Links_SpanId,omitempty"` Links_TraceState []string `protobuf:"bytes,19,rep,name=Links_TraceState,json=LinksTraceState,proto3" json:"Links_TraceState,omitempty"` Links_Attributes []*Attribute `protobuf:"bytes,20,rep,name=Links_Attributes,json=LinksAttributes,proto3" json:"Links_Attributes,omitempty"` ChildSpanCount int32 `protobuf:"varint,21,opt,name=ChildSpanCount,proto3" json:"ChildSpanCount,omitempty"` // contains filtered or unexported fields }
func (*OneSpan) Descriptor
deprecated
func (*OneSpan) GetChildSpanCount ¶
func (*OneSpan) GetDuration ¶
func (*OneSpan) GetEvents_Attributes ¶
func (*OneSpan) GetEvents_Name ¶
func (*OneSpan) GetEvents_Timestamp ¶
func (x *OneSpan) GetEvents_Timestamp() []*timestamppb.Timestamp
func (*OneSpan) GetLinks_Attributes ¶
func (*OneSpan) GetLinks_SpanId ¶
func (*OneSpan) GetLinks_TraceId ¶
func (*OneSpan) GetLinks_TraceState ¶
func (*OneSpan) GetParentSpanId ¶
func (*OneSpan) GetResourceAttributes ¶
func (*OneSpan) GetServiceName ¶
func (*OneSpan) GetSpanAttributes ¶
func (*OneSpan) GetSpanKind ¶
func (*OneSpan) GetSpanName ¶
func (*OneSpan) GetStatusCode ¶
func (*OneSpan) GetStatusMessage ¶
func (*OneSpan) GetTimestamp ¶
func (x *OneSpan) GetTimestamp() *timestamppb.Timestamp
func (*OneSpan) GetTraceId ¶
func (*OneSpan) GetTraceState ¶
func (*OneSpan) ProtoMessage ¶
func (*OneSpan) ProtoMessage()
func (*OneSpan) ProtoReflect ¶
func (x *OneSpan) ProtoReflect() protoreflect.Message
type Spans ¶
type Spans struct { Spans []*OneSpan `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"` // contains filtered or unexported fields }
func (*Spans) Descriptor
deprecated
func (*Spans) ProtoMessage ¶
func (*Spans) ProtoMessage()
func (*Spans) ProtoReflect ¶
func (x *Spans) ProtoReflect() protoreflect.Message
type UnimplementedLogServiceServer ¶
type UnimplementedLogServiceServer struct { }
UnimplementedLogServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedLogServiceServer) LogMessage ¶
func (UnimplementedLogServiceServer) LogMessage(context.Context, *LogMessageRequest) (*LogMessageResponse, error)
func (UnimplementedLogServiceServer) SendSpans ¶
func (UnimplementedLogServiceServer) SendSpans(context.Context, *Spans) (*LogMessageResponse, error)
type UnsafeLogServiceServer ¶
type UnsafeLogServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLogServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogServiceServer will result in compilation errors.