otel

package

v0.12.1 Latest Latest Go to latest Published: Nov 17, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rancher/opni

Links

Open Source Insights

Documentation ¶

Index ¶

type Forwarder
- func NewForwarder(logsForwarder *LogsForwarder, traceForwarder *TraceForwarder) *Forwarder
- func (f *Forwarder) BackgroundInitClient()
- func (f *Forwarder) ConfigureRoutes(router *gin.Engine)
type ForwarderOption
type LogsForwarder
- func NewLogsForwarder(opts ...ForwarderOption) *LogsForwarder
- func (f *LogsForwarder) Export(ctx context.Context, request *collogspb.ExportLogsServiceRequest) (*collogspb.ExportLogsServiceResponse, error)
- func (f *LogsForwarder) SetClient(cc grpc.ClientConnInterface)
type TraceForwarder
- func NewTraceForwarder(opts ...ForwarderOption) *TraceForwarder

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Forwarder ¶ added in v0.12.1

type Forwarder struct {
	*LogsForwarder
	*TraceForwarder
}

func NewForwarder ¶ added in v0.12.1

func NewForwarder(logsForwarder *LogsForwarder, traceForwarder *TraceForwarder) *Forwarder

func (*Forwarder) BackgroundInitClient ¶ added in v0.12.1

func (f *Forwarder) BackgroundInitClient()

func (*Forwarder) ConfigureRoutes ¶ added in v0.12.1

func (f *Forwarder) ConfigureRoutes(router *gin.Engine)

type ForwarderOption ¶ added in v0.12.1

type ForwarderOption func(*forwarderOptions)

func WithAddress ¶

func WithAddress(address string) ForwarderOption

func WithClientConn ¶

func WithClientConn(cc grpc.ClientConnInterface) ForwarderOption

func WithDialOptions ¶

func WithDialOptions(opts ...grpc.DialOption) ForwarderOption

func WithLogger ¶

func WithLogger(lg *slog.Logger) ForwarderOption

func WithPrivileged ¶ added in v0.12.1

func WithPrivileged(privileged bool) ForwarderOption

type LogsForwarder ¶ added in v0.12.1

type LogsForwarder struct {
	collogspb.UnsafeLogsServiceServer

	Client *util.AsyncClient[collogspb.LogsServiceClient]
	// contains filtered or unexported fields
}

func NewLogsForwarder ¶ added in v0.12.1

func NewLogsForwarder(opts ...ForwarderOption) *LogsForwarder

func (*LogsForwarder) Export ¶ added in v0.12.1

func (f *LogsForwarder) Export(
	ctx context.Context,
	request *collogspb.ExportLogsServiceRequest,
) (*collogspb.ExportLogsServiceResponse, error)

func (*LogsForwarder) SetClient ¶ added in v0.12.1

func (f *LogsForwarder) SetClient(cc grpc.ClientConnInterface)

type TraceForwarder ¶ added in v0.12.1

type TraceForwarder struct {
	coltracepb.UnsafeTraceServiceServer

	Client *util.AsyncClient[coltracepb.TraceServiceClient]
	// contains filtered or unexported fields
}

func NewTraceForwarder ¶ added in v0.12.1

func NewTraceForwarder(opts ...ForwarderOption) *TraceForwarder

func (*TraceForwarder) Export ¶ added in v0.12.1

func (f *TraceForwarder) Export(
	ctx context.Context,
	request *coltracepb.ExportTraceServiceRequest,
) (*coltracepb.ExportTraceServiceResponse, error)

func (*TraceForwarder) InitializeTraceForwarder ¶ added in v0.12.1

func (f *TraceForwarder) InitializeTraceForwarder() coltracepb.TraceServiceClient

func (*TraceForwarder) SetClient ¶ added in v0.12.1

func (f *TraceForwarder) SetClient(cc grpc.ClientConnInterface)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL