sql

package

Go to main page

Versions in this module

v1

v1.8.0

Jan 29, 2025

v1.7.0

Apr 4, 2024

v1.6.0

Mar 28, 2024

v1.5.1

Mar 18, 2024

Changes in this version

type FindTraceIDsParams

+ DurationMaximumEnableFilter bool

+ DurationMinimumEnableFilter bool

+ OperationNameEnableFilter bool

+ ServiceNameEnableFilter bool

+ StartTimeMaximumEnableFilter bool

+ StartTimeMinimumEnableFilter bool

type Queries

+ func (q *Queries) GetSpansCount(ctx context.Context) (int64, error)

v1.5.0

Mar 17, 2024

v1.4.0

Mar 13, 2024

v1.3.0

Mar 13, 2024

v1.2.0

Mar 11, 2024

Changes in this version

type Queries

+ func (q *Queries) GetSpansDiskSize(ctx context.Context) (int64, error)

v1.1.0

Mar 10, 2024

Changes in this version

type Queries

+ func (q *Queries) CleanSpans(ctx context.Context, pruneBefore pgtype.Timestamp) (int64, error)

v1.0.0

Mar 9, 2024

v1.0.0-6

Mar 9, 2024

v1.0.0-5

Mar 9, 2024

v1.0.0-4

Mar 9, 2024

v1.0.0-3

Mar 9, 2024

v1.0.0-2

Mar 9, 2024

v1.0.0-1

Mar 9, 2024

v1.0.0-0

Mar 9, 2024

v0

v0.4.4-0

Mar 8, 2024

v0.4.3

Mar 8, 2024

v0.4.2

Mar 8, 2024

v0.4.1

Mar 8, 2024

v0.4.0

Mar 8, 2024

v0.3.0

Mar 7, 2024

Changes in this version

type GetTraceSpansRow

+ Refs []byte

type InsertSpanParams

+ Refs []byte

type Span

+ Refs []byte

v0.2.0

Mar 7, 2024

Changes in this version

+ func Migrate(logger hclog.Logger, connStr string) error

+ type DBTX interface

+ CopyFrom func(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)

+ Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+ Query func(context.Context, string, ...interface{}) (pgx.Rows, error)

+ QueryRow func(context.Context, string, ...interface{}) pgx.Row

+ type FindTraceIDsParams struct

+ DurationMaximum pgtype.Interval

+ DurationMaximumEnable bool

+ DurationMinimum pgtype.Interval

+ DurationMinimumEnable bool

+ NumTraces int

+ OperationName string

+ OperationNameEnable bool

+ ServiceName string

+ ServiceNameEnable bool

+ StartTimeMaximum pgtype.Timestamptz

+ StartTimeMaximumEnable bool

+ StartTimeMinimum pgtype.Timestamptz

+ StartTimeMinimumEnable bool

+ type GetDependenciesRow struct

+ CallCount int64

+ Child string

+ Parent string

+ Source string

+ type GetOperationIDParams struct

+ Kind Spankind

+ Name string

+ ServiceID int64

+ type GetOperationsRow struct

+ Kind Spankind

+ Name string

+ type GetTraceSpansRow struct

+ Duration pgtype.Interval

+ Flags pgtype.Int8

+ Kind Spankind

+ Logs []byte

+ OperationName string

+ ProcessID string

+ ProcessName string

+ ProcessTags []byte

+ SpanID []byte

+ StartTime pgtype.Timestamptz

+ Tags []byte

+ TraceID []byte

+ Warnings []string

+ type InsertSpanParams struct

+ Duration pgtype.Interval

+ Flags int64

+ Kind Spankind

+ Logs []byte

+ OperationID int64

+ ProcessID string

+ ProcessTags []byte

+ ServiceID int64

+ SpanID []byte

+ StartTime pgtype.Timestamptz

+ Tags []byte

+ TraceID []byte

+ Warnings []string

+ type InsertSpanRefsParams struct

+ ChildSpanID []byte

+ RefType string

+ SourceSpanID []byte

+ TraceID []byte

+ type NullSpankind struct

+ Spankind Spankind

+ Valid bool

+ func (ns *NullSpankind) Scan(value interface{}) error

+ func (ns NullSpankind) Value() (driver.Value, error)

+ type Operation struct

+ ID int64

+ Kind Spankind

+ Name string

+ ServiceID int64

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) FindTraceIDs(ctx context.Context, arg FindTraceIDsParams) ([][]byte, error)

+ func (q *Queries) GetDependencies(ctx context.Context) ([]GetDependenciesRow, error)

+ func (q *Queries) GetOperationID(ctx context.Context, arg GetOperationIDParams) (int64, error)

+ func (q *Queries) GetOperations(ctx context.Context, serviceName string) ([]GetOperationsRow, error)

+ func (q *Queries) GetServiceID(ctx context.Context, name string) (int64, error)

+ func (q *Queries) GetServices(ctx context.Context) ([]string, error)

+ func (q *Queries) GetTraceSpans(ctx context.Context, traceID []byte) ([]GetTraceSpansRow, error)

+ func (q *Queries) InsertSpan(ctx context.Context, arg InsertSpanParams) (int64, error)

+ func (q *Queries) InsertSpanRefs(ctx context.Context, arg []InsertSpanRefsParams) (int64, error)

+ func (q *Queries) UpsertOperation(ctx context.Context, arg UpsertOperationParams) error

+ func (q *Queries) UpsertService(ctx context.Context, name string) error

+ func (q *Queries) WithTx(tx pgx.Tx) *Queries

+ type Service struct

+ ID int64

+ Name string

+ type Span struct

+ Duration pgtype.Interval

+ Flags pgtype.Int8

+ HackID int64

+ Kind Spankind

+ Logs []byte

+ OperationID int64

+ ProcessID string

+ ProcessTags []byte

+ ServiceID int64

+ SpanID []byte

+ StartTime pgtype.Timestamptz

+ Tags []byte

+ TraceID []byte

+ Warnings []string

+ type Spankind string

+ const SpankindClient

+ const SpankindConsumer

+ const SpankindEphemeral

+ const SpankindInternal

+ const SpankindProducer

+ const SpankindServer

+ const SpankindUnspecified

+ func (e *Spankind) Scan(src interface{}) error

+ type Spanref struct

+ ChildSpanID []byte

+ ID int64

+ RefType string

+ SourceSpanID []byte

+ TraceID []byte

+ type UpsertOperationParams struct

+ Kind Spankind

+ Name string

+ ServiceID int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL