Documentation
¶
Index ¶
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
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)
Click to show internal directories.
Click to hide internal directories.