dao

package
v0.0.0-...-83adff0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 6, 2020 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TimeDesc     = "time:desc"
	TimeAsc      = "time:asc"
	DurationDesc = "duration:desc"
	DurationAsc  = "duration:asc"
)

Order

View Source
const (
	DefaultHbaseNameSpace = "ugc"
	DefaultInfluxDatabase = "dapper"
	HbaseRawTraceTable    = "DapperRawtrace"
	HbaseRawTraceFamily   = "pb"
	HbaseListIdxTable     = "DapperListidx"
	HbaseListIdxFamily    = "kind"
	ServiceNameTag        = "service_name"
	OperationNameTag      = "operation_name"
	PeerServiceTag        = "peer.service"
	SpanKindTag           = "span.kind"
	MaxDurationField      = "max_duration"
	MinDurationField      = "min_duration"
	AvgDurationField      = "avg_duration"
	SpanpointMeasurement  = "span_point"
	ErrorsField           = "errors"
)

table name

Variables

View Source
var ErrNotFound = errors.New("not found")

ErrNotFound data not found

Functions

This section is empty.

Types

type Dao

type Dao interface {
	// list all ServiceNames
	ServiceNames(ctx context.Context) ([]string, error)
	// list OperationName for specifically service
	OperationNames(ctx context.Context, serviceName string) ([]string, error)
	// QuerySpan by family title and sel
	QuerySpanList(ctx context.Context, serviceName, operationName string, sel *Selector, order string) ([]model.SpanListRef, error)
	// Trace get trace by trace id span sort by start_time
	Trace(ctx context.Context, traceID uint64, spanIDs ...uint64) ([]*model.Span, error)
	// PeerService query all peer service depend by service
	PeerService(ctx context.Context, serviceName string) ([]string, error)
	// Ping pong
	Ping(ctx context.Context) error
	// Close dao
	Close(ctx context.Context) error
	// SupportOrder checkou order support
	SupportOrder(order string) bool
	// MeanOperationNameField
	MeanOperationNameField(ctx context.Context, whereMap map[string]string, field string, start, end int64, groupby []string) ([]model.MeanOperationNameValue, error)
	// SpanSeriesMean
	SpanSeriesMean(ctx context.Context, serviceName, operationName string, fields []string, start, end, interval int64) (*model.Series, error)
	// SpanSeriesCount
	SpanSeriesCount(ctx context.Context, serviceName, operationName string, fields []string, start, end, interval int64) (*model.Series, error)
}

Dao dapper dao

func New

func New(cfg *conf.Config) (Dao, error)

New dao

type Selector

type Selector struct {
	Start     int64
	End       int64
	Limit     int
	Offset    int
	OnlyError bool
}

Selector to selector span

Jump to

Keyboard shortcuts

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