metrics

package
v1.0.0-alpha.34 Latest Latest
Warning

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

Go to latest
Published: Aug 25, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	KvTracingServiceName      string = "kv"
	TraceServiceName          string = "tigris.grpc.server"
	SessionManagerServiceName string = "session"
	GrpcSpanType              string = "grpc"
	FdbSpanType               string = "fdb"
	SearchSpanType            string = "search"
	SessionSpanType           string = "session"
)
View Source
const (
	UnknownValue = "unknown"
)

Variables

View Source
var (
	FdbOkRequests    tally.Scope
	FdbErrorRequests tally.Scope
	FdbRespTime      tally.Scope
)
View Source
var (
	Reporter       promreporter.Reporter
	Requests       tally.Scope
	FdbMetrics     tally.Scope
	SearchMetrics  tally.Scope
	SessionMetrics tally.Scope
	SizeMetrics    tally.Scope
	NetworkMetrics tally.Scope
)
View Source
var (
	BytesReceived tally.Scope
	BytesSent     tally.Scope
)
View Source
var (
	OkRequests       tally.Scope
	ErrorRequests    tally.Scope
	RequestsRespTime tally.Scope
)
View Source
var (
	SearchOkRequests    tally.Scope
	SearchErrorRequests tally.Scope
	SearchRespTime      tally.Scope
)
View Source
var (
	SessionOkRequests    tally.Scope
	SessionErrorRequests tally.Scope
	SessionRespTime      tally.Scope
)
View Source
var (
	NamespaceSize  tally.Scope
	DbSize         tally.Scope
	CollectionSize tally.Scope
)

Functions

func ClearSpanMetaContext

func ClearSpanMetaContext(ctx context.Context) context.Context

func GetDbCollTagsForReq

func GetDbCollTagsForReq(req interface{}) map[string]string

func GetFdbErrorTags

func GetFdbErrorTags(ctx context.Context, reqMethodName string, code string) map[string]string

func GetFdbOkTags

func GetFdbOkTags(ctx context.Context, reqMethodName string) map[string]string

func GetGlobalTags

func GetGlobalTags() map[string]string

func GetNamespace

func GetNamespace(ctx context.Context) string

func GetSearchTags

func GetSearchTags(ctx context.Context, reqMethodName string) map[string]string

func GetSessionTags

func GetSessionTags(ctx context.Context, sessionMethodName string) map[string]string

func InitializeMetrics

func InitializeMetrics() io.Closer

func UpdateCollectionSizeMetrics

func UpdateCollectionSizeMetrics(namespaceName string, dbName string, collectionName string, size int64)

func UpdateDbSizeMetrics

func UpdateDbSizeMetrics(namespaceName string, dbName string, size int64)

func UpdateNameSpaceSizeMetrics

func UpdateNameSpaceSizeMetrics(namespaceName string, size int64)

Types

type RequestEndpointMetadata

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

func GetGrpcEndPointMetadataFromFullMethod

func GetGrpcEndPointMetadataFromFullMethod(ctx context.Context, fullMethod string, methodType string) RequestEndpointMetadata

func (*RequestEndpointMetadata) GetInitialTags

func (r *RequestEndpointMetadata) GetInitialTags() map[string]string

func (*RequestEndpointMetadata) GetMethodName

func (r *RequestEndpointMetadata) GetMethodName() string

func (*RequestEndpointMetadata) GetServiceType

func (r *RequestEndpointMetadata) GetServiceType() string

type SpanMeta

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

func NewSpanMeta

func NewSpanMeta(serviceName string, resourceName string, spanType string, tags map[string]string) *SpanMeta

func SpanMetaFromContext

func SpanMetaFromContext(ctx context.Context) (*SpanMeta, bool)

func (*SpanMeta) AddTags

func (s *SpanMeta) AddTags(tags map[string]string)

func (*SpanMeta) CountErrorForScope

func (s *SpanMeta) CountErrorForScope(scope tally.Scope, tags map[string]string)

func (*SpanMeta) CountOkForScope

func (s *SpanMeta) CountOkForScope(scope tally.Scope, tags map[string]string)

func (*SpanMeta) CountReceivedBytes

func (s *SpanMeta) CountReceivedBytes(scope tally.Scope, tags map[string]string, size int)

func (*SpanMeta) CountSentBytes

func (s *SpanMeta) CountSentBytes(scope tally.Scope, tags map[string]string, size int)

func (*SpanMeta) FinishTracing

func (s *SpanMeta) FinishTracing(ctx context.Context) context.Context

func (*SpanMeta) FinishWithError

func (s *SpanMeta) FinishWithError(ctx context.Context, err error)

func (*SpanMeta) GetCollectionSizeTags

func (s *SpanMeta) GetCollectionSizeTags() map[string]string

func (*SpanMeta) GetDbSizeTags

func (s *SpanMeta) GetDbSizeTags() map[string]string

func (*SpanMeta) GetFdbErrorTags

func (s *SpanMeta) GetFdbErrorTags(err error) map[string]string

func (*SpanMeta) GetFdbOkTags

func (s *SpanMeta) GetFdbOkTags() map[string]string

func (*SpanMeta) GetFdbTimerTags

func (s *SpanMeta) GetFdbTimerTags() map[string]string

func (*SpanMeta) GetNamespaceSizeTags

func (s *SpanMeta) GetNamespaceSizeTags() map[string]string

func (*SpanMeta) GetNetworkTags

func (s *SpanMeta) GetNetworkTags() map[string]string

func (*SpanMeta) GetRequestErrorTags

func (s *SpanMeta) GetRequestErrorTags(err error) map[string]string

func (*SpanMeta) GetRequestOkTags

func (s *SpanMeta) GetRequestOkTags() map[string]string

func (*SpanMeta) GetRequestTimerTags

func (s *SpanMeta) GetRequestTimerTags() map[string]string

func (*SpanMeta) GetSearchErrorTags

func (s *SpanMeta) GetSearchErrorTags(err error) map[string]string

func (*SpanMeta) GetSearchOkTags

func (s *SpanMeta) GetSearchOkTags() map[string]string

func (*SpanMeta) GetSearchTimerTags

func (s *SpanMeta) GetSearchTimerTags() map[string]string

func (*SpanMeta) GetSessionErrorTags

func (s *SpanMeta) GetSessionErrorTags(err error) map[string]string

func (*SpanMeta) GetSessionOkTags

func (s *SpanMeta) GetSessionOkTags() map[string]string

func (*SpanMeta) GetSessionTimerTags

func (s *SpanMeta) GetSessionTimerTags() map[string]string

func (*SpanMeta) GetSpanOptions

func (s *SpanMeta) GetSpanOptions() []tracer.StartSpanOption

func (*SpanMeta) GetTags

func (s *SpanMeta) GetTags() map[string]string

func (*SpanMeta) SaveSpanMetaToContext

func (s *SpanMeta) SaveSpanMetaToContext(ctx context.Context) (context.Context, error)

func (*SpanMeta) StartTracing

func (s *SpanMeta) StartTracing(ctx context.Context, childOnly bool) context.Context

type SpanMetaCtxKey

type SpanMetaCtxKey struct {
}

Jump to

Keyboard shortcuts

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