Documentation
¶
Index ¶
- func Migrate(logger hclog.Logger, connStr string) error
- type DBTX
- type FindTraceIDsParams
- type GetDependenciesRow
- type GetOperationIDParams
- type GetOperationsRow
- type GetTraceSpansRow
- type InsertSpanParams
- type InsertSpanRefsParams
- type NullSpankind
- type Operation
- type 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
- type Span
- type Spankind
- type Spanref
- type UpsertOperationParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DBTX ¶
type DBTX interface {
Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
Query(context.Context, string, ...interface{}) (pgx.Rows, error)
QueryRow(context.Context, string, ...interface{}) pgx.Row
CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
}
type FindTraceIDsParams ¶
type FindTraceIDsParams struct {
ServiceName string
ServiceNameEnable bool
OperationName string
OperationNameEnable bool
StartTimeMinimum pgtype.Timestamptz
StartTimeMinimumEnable bool
StartTimeMaximum pgtype.Timestamptz
StartTimeMaximumEnable bool
DurationMinimum pgtype.Interval
DurationMinimumEnable bool
DurationMaximum pgtype.Interval
DurationMaximumEnable bool
NumTraces int
}
type GetDependenciesRow ¶
type GetOperationIDParams ¶
type GetOperationsRow ¶
type GetTraceSpansRow ¶
type InsertSpanParams ¶
type InsertSpanRefsParams ¶
type NullSpankind ¶
func (*NullSpankind) Scan ¶
func (ns *NullSpankind) Scan(value interface{}) error
Scan implements the Scanner interface.
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) FindTraceIDs ¶
func (*Queries) GetDependencies ¶
func (q *Queries) GetDependencies(ctx context.Context) ([]GetDependenciesRow, error)
func (*Queries) GetOperationID ¶
func (*Queries) GetOperations ¶
func (*Queries) GetServiceID ¶
func (*Queries) GetTraceSpans ¶
func (*Queries) InsertSpan ¶
func (*Queries) InsertSpanRefs ¶
func (*Queries) UpsertOperation ¶
func (q *Queries) UpsertOperation(ctx context.Context, arg UpsertOperationParams) error
func (*Queries) UpsertService ¶
-- name: FindTraceIDs :many SELECT DISTINCT spans.trace_id FROM spans
INNER JOIN operations ON (operations.id = spans.operation_id) INNER JOIN services ON (services.id = spans.service_id)
WHERE
(services.name = sqlc.arg(service_name)::VARCHAR OR sqlc.arg(service_name_enable)::BOOLEAN = FALSE) AND (operations.name = sqlc.arg(operation_name)::VARCHAR OR sqlc.arg(operation_name_enable)::BOOLEAN = FALSE) AND (start_time >= sqlc.arg(start_time_minimum)::TIMESTAMPTZ OR sqlc.arg(start_time_minimum_enable)::BOOLEAN = FALSE) AND (start_time < sqlc.arg(start_time_maximum)::TIMESTAMPTZ OR sqlc.arg(start_time_maximum_enable)::BOOLEAN = FALSE) AND (duration > sqlc.arg(duration_minimum)::INTERVAL OR sqlc.arg(duration_minimum_enable)::BOOLEAN = FALSE) AND (duration < sqlc.arg(duration_maximum)::INTERVAL OR sqlc.arg(duration_maximum_enable)::BOOLEAN = FALSE)
; LIMIT sqlc.arg(limit)::INT;
type UpsertOperationParams ¶
Click to show internal directories.
Click to hide internal directories.