__

Documentation

Index

• Variables
• func RegisterTraceServiceServer(s grpc.ServiceRegistrar, srv TraceServiceServer)
• type GetTracesReply
  • func (*GetTracesReply) Descriptor() ([]byte, []int)
  • func (x *GetTracesReply) GetSpans() []*Span
  • func (*GetTracesReply) ProtoMessage()
  • func (x *GetTracesReply) ProtoReflect() protoreflect.Message
  • func (x *GetTracesReply) Reset()
  • func (x *GetTracesReply) String() string
• type PostSpanRequest
  • func (*PostSpanRequest) Descriptor() ([]byte, []int)
  • func (x *PostSpanRequest) GetSpan() *Span
  • func (*PostSpanRequest) ProtoMessage()
  • func (x *PostSpanRequest) ProtoReflect() protoreflect.Message
  • func (x *PostSpanRequest) Reset()
  • func (x *PostSpanRequest) String() string
• type PutSpanRequest
  • func (*PutSpanRequest) Descriptor() ([]byte, []int)
  • func (x *PutSpanRequest) GetSpan() *Span
  • func (*PutSpanRequest) ProtoMessage()
  • func (x *PutSpanRequest) ProtoReflect() protoreflect.Message
  • func (x *PutSpanRequest) Reset()
  • func (x *PutSpanRequest) String() string
• type Span
  • func (*Span) Descriptor() ([]byte, []int)
  • func (x *Span) GetElapsedTime() string
  • func (x *Span) GetMessage() string
  • func (x *Span) GetSpanId() string
  • func (x *Span) GetStatus() string
  • func (x *Span) GetTraceId() string
  • func (*Span) ProtoMessage()
  • func (x *Span) ProtoReflect() protoreflect.Message
  • func (x *Span) Reset()
  • func (x *Span) String() string
• type TraceServiceClient
  • func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient
• type TraceServiceServer
• type UnimplementedTraceServiceServer
  • func (UnimplementedTraceServiceServer) GetTraces(context.Context, *emptypb.Empty) (*GetTracesReply, error)
  • func (UnimplementedTraceServiceServer) PostSpan(context.Context, *PostSpanRequest) (*emptypb.Empty, error)
  • func (UnimplementedTraceServiceServer) PutSpan(context.Context, *PutSpanRequest) (*emptypb.Empty, error)
• type UnsafeTraceServiceServer

Variables

var File_trace_manager_pkg_proto_trace_proto protoreflect.FileDescriptor

var TraceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.TraceService",
	HandlerType: (*TraceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PostSpan",
			Handler:    _TraceService_PostSpan_Handler,
		},
		{
			MethodName: "PutSpan",
			Handler:    _TraceService_PutSpan_Handler,
		},
		{
			MethodName: "GetTraces",
			Handler:    _TraceService_GetTraces_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "trace-manager/pkg/proto/trace.proto",
}

TraceService_ServiceDesc is the grpc.ServiceDesc for TraceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTraceServiceServer

func RegisterTraceServiceServer(s grpc.ServiceRegistrar, srv TraceServiceServer)

Types

type GetTracesReply

type GetTracesReply struct {
	Spans []*Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTracesReply) Descriptor

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

Deprecated: Use GetTracesReply.ProtoReflect.Descriptor instead.

func (*GetTracesReply) GetSpans

func (x *GetTracesReply) GetSpans() []*Span

func (*GetTracesReply) ProtoMessage

func (*GetTracesReply) ProtoMessage()

func (*GetTracesReply) ProtoReflect

func (x *GetTracesReply) ProtoReflect() protoreflect.Message

func (*GetTracesReply) Reset

func (x *GetTracesReply) Reset()

func (*GetTracesReply) String

func (x *GetTracesReply) String() string

type PostSpanRequest

type PostSpanRequest struct {
	Span *Span `protobuf:"bytes,1,opt,name=span,proto3" json:"span,omitempty"`
	// contains filtered or unexported fields
}

func (*PostSpanRequest) Descriptor

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

Deprecated: Use PostSpanRequest.ProtoReflect.Descriptor instead.

func (*PostSpanRequest) GetSpan

func (x *PostSpanRequest) GetSpan() *Span

func (*PostSpanRequest) ProtoMessage

func (*PostSpanRequest) ProtoMessage()

func (*PostSpanRequest) ProtoReflect

func (x *PostSpanRequest) ProtoReflect() protoreflect.Message

func (*PostSpanRequest) Reset

func (x *PostSpanRequest) Reset()

func (*PostSpanRequest) String

func (x *PostSpanRequest) String() string

type PutSpanRequest

type PutSpanRequest struct {
	Span *Span `protobuf:"bytes,1,opt,name=span,proto3" json:"span,omitempty"`
	// contains filtered or unexported fields
}

func (*PutSpanRequest) Descriptor

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

Deprecated: Use PutSpanRequest.ProtoReflect.Descriptor instead.

func (*PutSpanRequest) GetSpan

func (x *PutSpanRequest) GetSpan() *Span

func (*PutSpanRequest) ProtoMessage

func (*PutSpanRequest) ProtoMessage()

func (*PutSpanRequest) ProtoReflect

func (x *PutSpanRequest) ProtoReflect() protoreflect.Message

func (*PutSpanRequest) Reset

func (x *PutSpanRequest) Reset()

func (*PutSpanRequest) String

func (x *PutSpanRequest) String() string

type Span

type Span struct {
	TraceId     string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	SpanId      string `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	ElapsedTime string `protobuf:"bytes,3,opt,name=elapsed_time,json=elapsedTime,proto3" json:"elapsed_time,omitempty"`
	Status      string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	Message     string `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Span) Descriptor

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

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) GetElapsedTime

func (x *Span) GetElapsedTime() string

func (*Span) GetMessage

func (x *Span) GetMessage() string

func (*Span) GetSpanId

func (x *Span) GetSpanId() string

func (*Span) GetStatus

func (x *Span) GetStatus() string

func (*Span) GetTraceId

func (x *Span) GetTraceId() string

func (*Span) ProtoMessage

func (*Span) ProtoMessage()

func (*Span) ProtoReflect

func (x *Span) ProtoReflect() protoreflect.Message

func (*Span) Reset

func (x *Span) Reset()

func (*Span) String

func (x *Span) String() string

type TraceServiceClient

type TraceServiceClient interface {
	PostSpan(ctx context.Context, in *PostSpanRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PutSpan(ctx context.Context, in *PutSpanRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetTraces(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetTracesReply, error)
}

TraceServiceClient is the client API for TraceService 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 NewTraceServiceClient

func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient

type TraceServiceServer

type TraceServiceServer interface {
	PostSpan(context.Context, *PostSpanRequest) (*emptypb.Empty, error)
	PutSpan(context.Context, *PutSpanRequest) (*emptypb.Empty, error)
	GetTraces(context.Context, *emptypb.Empty) (*GetTracesReply, error)
	// contains filtered or unexported methods
}

TraceServiceServer is the server API for TraceService service. All implementations must embed UnimplementedTraceServiceServer for forward compatibility

type UnimplementedTraceServiceServer

type UnimplementedTraceServiceServer struct {
}

UnimplementedTraceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTraceServiceServer) GetTraces

func (UnimplementedTraceServiceServer) GetTraces(context.Context, *emptypb.Empty) (*GetTracesReply, error)

func (UnimplementedTraceServiceServer) PostSpan

func (UnimplementedTraceServiceServer) PostSpan(context.Context, *PostSpanRequest) (*emptypb.Empty, error)

func (UnimplementedTraceServiceServer) PutSpan

func (UnimplementedTraceServiceServer) PutSpan(context.Context, *PutSpanRequest) (*emptypb.Empty, error)

type UnsafeTraceServiceServer

type UnsafeTraceServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTraceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TraceServiceServer will result in compilation errors.