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 {
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.