immudb_storage

Documentation

Index

• Constants
• type BWriter
  • func (receiver *BWriter) Write(p []byte) (n int, err error)
• type Config
• type ImmuDbDriver
  • 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) OpenSession(database ...string) (immudb.ImmuClient, error)
  • func (driver *ImmuDbDriver) Writer(ctx context.Context, key, value []byte) error
• type SpanWriter
  • func (s *SpanWriter) WriteSpan(ctx context.Context, span *model.Span) error
• type Store
  • 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

Constants

const (
	MaxKeyLen = 1024
)

Types

type BWriter

type BWriter struct {
	// contains filtered or unexported fields
}

func (*BWriter) Write

func (receiver *BWriter) Write(p []byte) (n int, err error)

type Config

type Config struct {
	Host     string `yaml:"host"`
	Port     int    `yaml:"port"`
	Database string `yaml:"database"`
	User     string `yaml:"user"`
	Pwd      string `yaml:"pwd"`
}

type ImmuDbDriver

type ImmuDbDriver struct {
	Client immudb.ImmuClient
	// contains filtered or unexported fields
}

func New

func New(cfgPath string) (*ImmuDbDriver, error)

func (*ImmuDbDriver) CreateDataBase

func (driver *ImmuDbDriver) CreateDataBase() error

func (*ImmuDbDriver) FindTraces

func (driver *ImmuDbDriver) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)

func (*ImmuDbDriver) FindTracesTime

func (driver *ImmuDbDriver) FindTracesTime(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)

func (*ImmuDbDriver) GetAllSpan

func (driver *ImmuDbDriver) GetAllSpan(ctx context.Context) ([]*model.Span, error)

func (*ImmuDbDriver) GetOperations

func (driver *ImmuDbDriver) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)

func (*ImmuDbDriver) GetServices

func (driver *ImmuDbDriver) GetServices(ctx context.Context) ([]string, error)

func (*ImmuDbDriver) GetTrace

func (driver *ImmuDbDriver) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

func (*ImmuDbDriver) ImportFromBackup

func (driver *ImmuDbDriver) ImportFromBackup(db *badgerV3.DB) error

func (*ImmuDbDriver) OpenSession

func (driver *ImmuDbDriver) OpenSession(database ...string) (immudb.ImmuClient, error)

func (*ImmuDbDriver) Writer

func (driver *ImmuDbDriver) Writer(ctx context.Context, key, value []byte) error

type SpanWriter

type SpanWriter struct {
	// contains filtered or unexported fields
}

func (*SpanWriter) WriteSpan

func (s *SpanWriter) WriteSpan(ctx context.Context, span *model.Span) error

type Store

type Store struct {
	// contains filtered or unexported fields
}

func NewStoreQuery

func NewStoreQuery(client *ImmuDbDriver, logger hclog.Logger) (*Store, error)

func (*Store) DependencyReader

func (s *Store) DependencyReader() dependencystore.Reader

func (*Store) FindTraceIDs

func (s *Store) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)

func (*Store) FindTraces

func (s *Store) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)

func (*Store) GetDependencies

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

func (*Store) GetOperations

func (s *Store) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)

func (*Store) GetServices

func (s *Store) GetServices(ctx context.Context) ([]string, error)

func (*Store) GetTrace

func (s *Store) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

func (*Store) SpanReader

func (s *Store) SpanReader() spanstore.Reader

func (*Store) SpanWriter

func (s *Store) SpanWriter() spanstore.Writer