Versions in this module Expand all Collapse all v1 v1.0.1 Nov 8, 2022 Changes in this version + const MaxKeyLen type ImmuDbDriver + func (driver *ImmuDbDriver) OpenSession(database ...string) (immudb.ImmuClient, error) v1.0.0 Nov 3, 2022 Changes in this version + type BWriter struct + func (receiver *BWriter) Write(p []byte) (n int, err error) + type Config struct + Database string + Host string + Port int + Pwd string + User string + type ImmuDbDriver struct + Client immudb.ImmuClient + func New(cfgPath string) (*ImmuDbDriver, error) + func (driver *ImmuDbDriver) CreateDataBase() error + func (driver *ImmuDbDriver) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error) + func (driver *ImmuDbDriver) FindTracesTime(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error) + func (driver *ImmuDbDriver) GetAllSpan(ctx context.Context) ([]*model.Span, error) + func (driver *ImmuDbDriver) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error) + func (driver *ImmuDbDriver) GetServices(ctx context.Context) ([]string, error) + func (driver *ImmuDbDriver) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error) + func (driver *ImmuDbDriver) ImportFromBackup(db *badgerV3.DB) error + func (driver *ImmuDbDriver) Writer(ctx context.Context, key, value []byte) error + type SpanWriter struct + func (s *SpanWriter) WriteSpan(ctx context.Context, span *model.Span) error + type Store struct + func NewStoreQuery(client *ImmuDbDriver, logger hclog.Logger) (*Store, error) + func (s *Store) DependencyReader() dependencystore.Reader + func (s *Store) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error) + func (s *Store) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error) + func (s *Store) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error) + func (s *Store) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error) + func (s *Store) GetServices(ctx context.Context) ([]string, error) + func (s *Store) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error) + func (s *Store) SpanReader() spanstore.Reader + func (s *Store) SpanWriter() spanstore.Writer
Go to main page