Versions in this module Expand all Collapse all v1 v1.0.0 Jun 4, 2021 Changes in this version + func Config(v *viper.Viper) + func GetJaegerURI() string + func GetListenAddr() string + func NewClientConn(endpoint string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error) + func NewUDPConn(endpoint string) (connUDP *net.UDPConn, err error) + func RegisterAgent(server *grpc.Server, listenAddr string) + func RegisterProxy(server *grpc.Server, jaegerURI string) + func RegisterTraceAgentAdminServer(s *grpc.Server, srv TraceAgentAdminServer) + func RunAgent(listenAddr string) (err error) + func Transfer(conn *grpc.ClientConn, targets ...io.Writer) (err error) + type ListReply struct + Data []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListReply) Descriptor() ([]byte, []int) + func (*ListReply) ProtoMessage() + func (m *ListReply) GetData() []byte + func (m *ListReply) Reset() + func (m *ListReply) String() string + func (m *ListReply) XXX_DiscardUnknown() + func (m *ListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListReply) XXX_Merge(src proto.Message) + func (m *ListReply) XXX_Size() int + func (m *ListReply) XXX_Unmarshal(b []byte) error + type ListRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (m *ListRequest) Reset() + func (m *ListRequest) String() string + func (m *ListRequest) XXX_DiscardUnknown() + func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListRequest) XXX_Merge(src proto.Message) + func (m *ListRequest) XXX_Size() int + func (m *ListRequest) XXX_Unmarshal(b []byte) error + type SpanLogger struct + func (l *SpanLogger) Debug(args ...interface{}) + func (l *SpanLogger) Debugf(format string, args ...interface{}) + func (l *SpanLogger) Error(args ...interface{}) + func (l *SpanLogger) Errorf(format string, args ...interface{}) + func (l *SpanLogger) Finish() + func (l *SpanLogger) Info(args ...interface{}) + func (l *SpanLogger) Infof(format string, args ...interface{}) + func (l *SpanLogger) Warning(args ...interface{}) + func (l *SpanLogger) Warningf(format string, args ...interface{}) + func (l *SpanLogger) WithError(err error) *SpanLogger + func (l *SpanLogger) WithField(key string, value interface{}) *SpanLogger + func (l *SpanLogger) WithFields(arg logrus.Fields) *SpanLogger + type TraceAgentAdminClient interface + List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (TraceAgentAdmin_ListClient, error) + func NewTraceAgentAdminClient(cc *grpc.ClientConn) TraceAgentAdminClient + type TraceAgentAdminServer interface + List func(*ListRequest, TraceAgentAdmin_ListServer) error + type TraceAgentAdmin_ListClient interface + Recv func() (*ListReply, error) + type TraceAgentAdmin_ListServer interface + Send func(*ListReply) error + type Tracing struct + func StartTracing(name string) (tr *Tracing) + func (tracer *Tracing) StartLogging(ctx context.Context, op string, opts ...opentracing.StartSpanOption) (*SpanLogger, context.Context) + type UnimplementedTraceAgentAdminServer struct + func (*UnimplementedTraceAgentAdminServer) List(req *ListRequest, srv TraceAgentAdmin_ListServer) error
Go to main page