shared

package

Go to main page

Versions in this module

v1

v1.63.0

Nov 10, 2024

v1.62.0

Oct 7, 2024

v1.61.0

Sep 15, 2024

v1.60.0

Aug 6, 2024

v1.59.0

Jul 10, 2024

v1.58.1

Jun 22, 2024

v1.58.0

Jun 11, 2024

Changes in this version

+ type GRPCClient struct

+ func (c *GRPCClient) ArchiveSpanReader() spanstore.Reader

+ func (c *GRPCClient) ArchiveSpanWriter() spanstore.Writer

+ func (c *GRPCClient) Capabilities() (*Capabilities, error)

+ func (c *GRPCClient) Close() error

+ func (c *GRPCClient) DependencyReader() dependencystore.Reader

+ func (c *GRPCClient) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)

+ func (c *GRPCClient) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)

+ func (c *GRPCClient) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)

+ func (c *GRPCClient) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)

+ func (c *GRPCClient) GetServices(ctx context.Context) ([]string, error)

+ func (c *GRPCClient) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

+ func (c *GRPCClient) SpanReader() spanstore.Reader

+ func (c *GRPCClient) SpanWriter() spanstore.Writer

+ func (c *GRPCClient) StreamingSpanWriter() spanstore.Writer

+ func (c *GRPCClient) WriteSpan(ctx context.Context, span *model.Span) error

v1.57.0

May 1, 2024

v1.56.0

Apr 3, 2024

v1.55.0

Mar 7, 2024

v1.54.0

Feb 6, 2024

v1.53.0

Jan 8, 2024

v1.52.0

Dec 6, 2023

v1.51.0

Nov 2, 2023

v1.50.0

Oct 6, 2023

v1.49.0

Sep 7, 2023

v1.48.0

Aug 15, 2023

v1.47.0

Jul 6, 2023

v1.46.0

Jun 5, 2023

v1.45.0

May 5, 2023

v1.44.0

Apr 10, 2023

v1.43.0

Mar 15, 2023

v1.42.0

Feb 5, 2023

v1.41.0

Jan 3, 2023

v1.40.0

Dec 8, 2022

v1.39.0

Nov 1, 2022

v1.38.1

Oct 5, 2022

v1.38.0

Sep 16, 2022

v1.37.0

Aug 3, 2022

Changes in this version

+ type GRPCHandler struct

+ func NewGRPCHandler(impl *GRPCHandlerStorageImpl) *GRPCHandler

+ func NewGRPCHandlerWithPlugins(mainImpl StoragePlugin, archiveImpl ArchiveStoragePlugin, ...) *GRPCHandler

+ func (s *GRPCHandler) Capabilities(ctx context.Context, request *storage_v1.CapabilitiesRequest) (*storage_v1.CapabilitiesResponse, error)

+ func (s *GRPCHandler) Close(ctx context.Context, r *storage_v1.CloseWriterRequest) (*storage_v1.CloseWriterResponse, error)

+ func (s *GRPCHandler) FindTraceIDs(ctx context.Context, r *storage_v1.FindTraceIDsRequest) (*storage_v1.FindTraceIDsResponse, error)

+ func (s *GRPCHandler) FindTraces(r *storage_v1.FindTracesRequest, ...) error

+ func (s *GRPCHandler) GetArchiveTrace(r *storage_v1.GetTraceRequest, ...) error

+ func (s *GRPCHandler) GetDependencies(ctx context.Context, r *storage_v1.GetDependenciesRequest) (*storage_v1.GetDependenciesResponse, error)

+ func (s *GRPCHandler) GetOperations(ctx context.Context, r *storage_v1.GetOperationsRequest) (*storage_v1.GetOperationsResponse, error)

+ func (s *GRPCHandler) GetServices(ctx context.Context, r *storage_v1.GetServicesRequest) (*storage_v1.GetServicesResponse, error)

+ func (s *GRPCHandler) GetTrace(r *storage_v1.GetTraceRequest, ...) error

+ func (s *GRPCHandler) Register(ss *grpc.Server) error

+ func (s *GRPCHandler) WriteArchiveSpan(ctx context.Context, r *storage_v1.WriteSpanRequest) (*storage_v1.WriteSpanResponse, error)

+ func (s *GRPCHandler) WriteSpan(ctx context.Context, r *storage_v1.WriteSpanRequest) (*storage_v1.WriteSpanResponse, error)

+ func (s *GRPCHandler) WriteSpanStream(stream storage_v1.StreamingSpanWriterPlugin_WriteSpanStreamServer) error

+ type GRPCHandlerStorageImpl struct

+ ArchiveSpanReader func() spanstore.Reader

+ ArchiveSpanWriter func() spanstore.Writer

+ DependencyReader func() dependencystore.Reader

+ SpanReader func() spanstore.Reader

+ SpanWriter func() spanstore.Writer

+ StreamingSpanWriter func() spanstore.Writer

v1.36.0

Jul 5, 2022

v1.35.2

May 31, 2022

v1.35.1

May 31, 2022

v1.35.0

May 30, 2022

v1.34.1

May 16, 2022

v1.34.0

May 11, 2022

Changes in this version

type Capabilities

+ StreamingSpanWriter bool

type PluginServices

+ StreamingSpanWriter StreamingSpanWriterPlugin

type StorageGRPCPlugin

+ StreamImpl StreamingSpanWriterPlugin

+ type StreamingSpanWriterPlugin interface

+ StreamingSpanWriter func() spanstore.Writer

v1.33.0

Apr 11, 2022

v1.32.0

Mar 6, 2022

v1.31.0

Feb 4, 2022

v1.30.0

Jan 11, 2022

Changes in this version

+ func NewGRPCClient(c *grpc.ClientConn) *grpcClient

type StorageGRPCPlugin

+ func (p *StorageGRPCPlugin) RegisterHandlers(s *grpc.Server) error

v1.29.0

Dec 1, 2021

v1.28.0

Nov 6, 2021

Changes in this version

+ const BearerTokenKey

v1.27.0

Oct 6, 2021

v1.26.0

Sep 6, 2021

v1.25.0

Aug 5, 2021

v1.24.0

Jul 7, 2021

v1.23.0

Jun 4, 2021

Changes in this version

+ type ContextUpgradeFunc func(ctx context.Context) context.Context

v1.22.0

Feb 23, 2021

v1.21.0

Nov 16, 2020

v1.20.0

Sep 29, 2020

Changes in this version

+ type ArchiveStoragePlugin interface

+ ArchiveSpanReader func() spanstore.Reader

+ ArchiveSpanWriter func() spanstore.Writer

+ type Capabilities struct

+ ArchiveSpanReader bool

+ ArchiveSpanWriter bool

+ type PluginCapabilities interface

+ Capabilities func() (*Capabilities, error)

+ type PluginServices struct

+ ArchiveStore ArchiveStoragePlugin

+ Store StoragePlugin

type StorageGRPCPlugin

+ ArchiveImpl ArchiveStoragePlugin

v1.19.2

Aug 27, 2020

v1.19.1

Aug 26, 2020

v1.19.0

Aug 26, 2020

v1.18.1

Jun 19, 2020

v1.18.0

May 14, 2020 GO-2022-0834