metrics

Documentation

Index

• Constants
• Variables
• func ClearSpanMetaContext(ctx context.Context) context.Context
• func GetDbCollTagsForReq(req interface{}) map[string]string
• func GetFdbErrorTags(ctx context.Context, reqMethodName string, code string) map[string]string
• func GetFdbOkTags(ctx context.Context, reqMethodName string) map[string]string
• func GetGlobalTags() map[string]string
• func GetNamespace(ctx context.Context) string
• func GetSearchTags(ctx context.Context, reqMethodName string) map[string]string
• func GetSessionTags(ctx context.Context, sessionMethodName string) map[string]string
• func InitializeMetrics() io.Closer
• func UpdateCollectionSizeMetrics(namespaceName string, dbName string, collectionName string, size int64)
• func UpdateDbSizeMetrics(namespaceName string, dbName string, size int64)
• func UpdateNameSpaceSizeMetrics(namespaceName string, size int64)
• type RequestEndpointMetadata
  • func GetGrpcEndPointMetadataFromFullMethod(ctx context.Context, fullMethod string, methodType string) RequestEndpointMetadata
  • func (r *RequestEndpointMetadata) GetErrorTags(source string, code string) map[string]string
  • func (r *RequestEndpointMetadata) GetMethodName() string
  • func (r *RequestEndpointMetadata) GetOkTags() map[string]string
  • func (r *RequestEndpointMetadata) GetServiceType() string
• type SpanMeta
  • func NewSpanMeta(serviceName string, resourceName string, spanType string, ...) *SpanMeta
  • func SpanMetaFromContext(ctx context.Context) (*SpanMeta, bool)
  • func (s *SpanMeta) AddTags(tags map[string]string)
  • func (s *SpanMeta) CountErrorForScope(scope tally.Scope, err error)
  • func (s *SpanMeta) CountOkForScope(scope tally.Scope)
  • func (s *SpanMeta) CountReceivedBytes(scope tally.Scope, size int)
  • func (s *SpanMeta) CountSentBytes(scope tally.Scope, size int)
  • func (s *SpanMeta) FinishTracing(ctx context.Context) context.Context
  • func (s *SpanMeta) FinishWithError(ctx context.Context, err error)
  • func (s *SpanMeta) GetSpanOptions() []tracer.StartSpanOption
  • func (s *SpanMeta) GetTags() map[string]string
  • func (s *SpanMeta) SaveSpanMetaToContext(ctx context.Context) (context.Context, error)
  • func (s *SpanMeta) StartTracing(ctx context.Context, childOnly bool) context.Context
• type SpanMetaCtxKey

Constants

const (
	SystemTigrisTenantName = "system"
	UnknownValue           = "unknown"
)

const (
	KvTracingServiceName      string = "kv"
	TraceServiceName          string = "tigris.grpc.server"
	SessionManagerServiceName string = "session"
)

Variables

var (
	FdbOkRequests    tally.Scope
	FdbErrorRequests tally.Scope
	FdbRespTime      tally.Scope
)

var (
	Reporter       promreporter.Reporter
	Requests       tally.Scope
	FdbMetrics     tally.Scope
	SearchMetrics  tally.Scope
	SessionMetrics tally.Scope
	SizeMetrics    tally.Scope
	NetworkMetrics tally.Scope
)

var (
	BytesReceived tally.Scope
	BytesSent     tally.Scope
)

var (
	OkRequests       tally.Scope
	ErrorRequests    tally.Scope
	RequestsRespTime tally.Scope
)

var (
	SearchOkRequests    tally.Scope
	SearchErrorRequests tally.Scope
	SearchRespTime      tally.Scope
)

var (
	SessionOkRequests    tally.Scope
	SessionErrorRequests tally.Scope
	SessionRespTime      tally.Scope
)

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) GetErrorTags

func (r *RequestEndpointMetadata) GetErrorTags(source string, code string) map[string]string

func (*RequestEndpointMetadata) GetMethodName

func (r *RequestEndpointMetadata) GetMethodName() string

func (*RequestEndpointMetadata) GetOkTags

func (r *RequestEndpointMetadata) GetOkTags() map[string]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, err error)

func (*SpanMeta) CountOkForScope

func (s *SpanMeta) CountOkForScope(scope tally.Scope)

func (*SpanMeta) CountReceivedBytes

func (s *SpanMeta) CountReceivedBytes(scope tally.Scope, size int)

func (*SpanMeta) CountSentBytes

func (s *SpanMeta) CountSentBytes(scope tally.Scope, 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) 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 {
}