tracing

Apr 18, 2023

Changes in this version

+ func GetWorkloadFromCache(ctx context.Context, workloadCache map[string]k8sapi.Workload, ...) (k8sapi.Workload, error)

Dec 5, 2022

Changes in this version

+ func GetWorkload(c context.Context, name, namespace, workloadKind string) (obj k8sapi.Workload, err error)

+ func RecordWorkloadInfo(span trace.Span, wl k8sapi.Workload)

Aug 25, 2022

Changes in this version

+ func EndAndRecord(span trace.Span, err error)

+ func NewWrapperFunc() transport.WrapperFunc

Aug 8, 2022

Changes in this version

+ const MaxTraceSize

+ func RecordConnID(span trace.Span, id string)

+ func RecordInterceptInfo(span trace.Span, info *manager.InterceptInfo)

+ func RecordInterceptSpec(span trace.Span, spec *manager.InterceptSpec)

+ type ProtoReader struct

+ func NewProtoReader(in io.Reader, allocator func() T) *ProtoReader[T]

+ func (p *ProtoReader[T]) ReadAll(ctx context.Context) ([]T, error)

+ func (p *ProtoReader[T]) ReadNext(ctx context.Context) (T, error)

+ type ProtoWriter struct

+ func NewProtoWriter(out io.Writer) *ProtoWriter

+ func (p *ProtoWriter) Encode(m proto.Message) error

+ func (p *ProtoWriter) SetWriter(out io.Writer)

+ type TraceServer struct

+ func NewTraceServer(ctx context.Context, componentName string, ...) (*TraceServer, error)

+ func (ts *TraceServer) DumpTraces(ctx context.Context, _ *emptypb.Empty) (*common.Trace, error)

+ func (ts *TraceServer) ServeGrpc(ctx context.Context, port uint16) error

+ func (ts *TraceServer) Shutdown(ctx context.Context)