grpsink

Nov 8, 2018

Changes in this version

+ var ErrIntOverflowGrpcSink = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthGrpcSink = fmt.Errorf("proto: negative length found during unmarshaling")

+ func RegisterSpanSinkServer(s *grpc.Server, srv SpanSinkServer)

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Marshal() (dAtA []byte, err error)

+ func (m *Empty) MarshalTo(dAtA []byte) (int, error)

+ func (m *Empty) Reset()

+ func (m *Empty) Size() (n int)

+ func (m *Empty) String() string

+ func (m *Empty) Unmarshal(dAtA []byte) error

+ type GRPCSpanSink struct

+ func NewGRPCSpanSink(ctx context.Context, target, name string, log *logrus.Logger, ...) (*GRPCSpanSink, error)

+ func (gs *GRPCSpanSink) Flush()

+ func (gs *GRPCSpanSink) Ingest(ssfSpan *ssf.SSFSpan) error

+ func (gs *GRPCSpanSink) Name() string

+ func (gs *GRPCSpanSink) Start(cl *trace.Client) error

+ type SpanSinkClient interface

+ SendSpan func(ctx context.Context, in *ssf.SSFSpan, opts ...grpc.CallOption) (*Empty, error)

+ func NewSpanSinkClient(cc *grpc.ClientConn) SpanSinkClient

+ type SpanSinkServer interface

+ SendSpan func(context.Context, *ssf.SSFSpan) (*Empty, error)