logs

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2021 License: Apache-2.0, Apache-2.0 Imports: 19 Imported by: 8

README

Logs

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Config 

func Config(v *viper.Viper)

func GetJaegerURI 

func GetJaegerURI() string

func GetListenAddr 

func GetListenAddr() string

func NewClientConn 

func NewClientConn(endpoint string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error)

func NewUDPConn 

func NewUDPConn(endpoint string) (connUDP *net.UDPConn, err error)

func RegisterAgent 

func RegisterAgent(server *grpc.Server, listenAddr string)

func RegisterProxy 

func RegisterProxy(server *grpc.Server, jaegerURI string)

func RegisterTraceAgentAdminServer 

func RegisterTraceAgentAdminServer(s *grpc.Server, srv TraceAgentAdminServer)

func RunAgent 

func RunAgent(listenAddr string) (err error)

func Transfer 

func Transfer(conn *grpc.ClientConn, targets ...io.Writer) (err error)

Types

type ListReply 

type ListReply struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListReply) Descriptor 

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

func (*ListReply) GetData 

func (m *ListReply) GetData() []byte

func (*ListReply) ProtoMessage 

func (*ListReply) ProtoMessage()

func (*ListReply) Reset 

func (m *ListReply) Reset()

func (*ListReply) String 

func (m *ListReply) String() string

func (*ListReply) XXX_DiscardUnknown 

func (m *ListReply) XXX_DiscardUnknown()

func (*ListReply) XXX_Marshal 

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

func (*ListReply) XXX_Merge 

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

func (*ListReply) XXX_Size 

func (m *ListReply) XXX_Size() int

func (*ListReply) XXX_Unmarshal 

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

type ListRequest 

type ListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

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

func (*ListRequest) XXX_Merge 

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

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

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

type SpanLogger 

type SpanLogger struct {
	opentracing.Span
	// contains filtered or unexported fields
}

func (*SpanLogger) Debug 

func (l *SpanLogger) Debug(args ...interface{})

Debug is for stuff relevant only to a developer

func (*SpanLogger) Debugf 

func (l *SpanLogger) Debugf(format string, args ...interface{})

func (*SpanLogger) Error 

func (l *SpanLogger) Error(args ...interface{})

Error is for when things don't go according to plan.

func (*SpanLogger) Errorf 

func (l *SpanLogger) Errorf(format string, args ...interface{})

func (*SpanLogger) Finish 

func (l *SpanLogger) Finish()

Finish

func (*SpanLogger) Info 

func (l *SpanLogger) Info(args ...interface{})

Info is for informational messages

func (*SpanLogger) Infof 

func (l *SpanLogger) Infof(format string, args ...interface{})

func (*SpanLogger) Warning 

func (l *SpanLogger) Warning(args ...interface{})

Warning really ought not be used

func (*SpanLogger) Warningf 

func (l *SpanLogger) Warningf(format string, args ...interface{})

func (*SpanLogger) WithError 

func (l *SpanLogger) WithError(err error) *SpanLogger

WithError allows shorthand adding of an error field.

func (*SpanLogger) WithField 

func (l *SpanLogger) WithField(key string, value interface{}) *SpanLogger

WithField allows adding a single key/value pair.

func (*SpanLogger) WithFields 

func (l *SpanLogger) WithFields(arg logrus.Fields) *SpanLogger

WithFields allows adding multiple kv pairs in a struct.

type TraceAgentAdminClient 

type TraceAgentAdminClient interface {
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (TraceAgentAdmin_ListClient, error)
}

TraceAgentAdminClient is the client API for TraceAgentAdmin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTraceAgentAdminClient 

func NewTraceAgentAdminClient(cc *grpc.ClientConn) TraceAgentAdminClient

type TraceAgentAdminServer 

type TraceAgentAdminServer interface {
	List(*ListRequest, TraceAgentAdmin_ListServer) error
}

TraceAgentAdminServer is the server API for TraceAgentAdmin service.

type TraceAgentAdmin_ListClient 

type TraceAgentAdmin_ListClient interface {
	Recv() (*ListReply, error)
	grpc.ClientStream
}

type TraceAgentAdmin_ListServer 

type TraceAgentAdmin_ListServer interface {
	Send(*ListReply) error
	grpc.ServerStream
}

type Tracing 

type Tracing struct {
	opentracing.Tracer
}

Tracing is a wrapper to opentracing tracer

func StartTracing 

func StartTracing(name string) (tr *Tracing)

StartTracing new a tracing with name if it does not exist, or returns the existing one.

func (*Tracing) StartLogging 

func (tracer *Tracing) StartLogging(
	ctx context.Context,
	op string,
	opts ...opentracing.StartSpanOption) (*SpanLogger, context.Context)

StartLogging new a span logger and put it in context, and return the span logger and the context.

type UnimplementedTraceAgentAdminServer 

type UnimplementedTraceAgentAdminServer struct {
}

UnimplementedTraceAgentAdminServer can be embedded to have forward compatible implementations.

func (*UnimplementedTraceAgentAdminServer) List 

func (*UnimplementedTraceAgentAdminServer) List(req *ListRequest, srv TraceAgentAdmin_ListServer) error

Source Files

View all Source files

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.