metrics

Documentation

Index

• Constants
• Variables
• func GetFdbSpecificErrorTags(ctx context.Context, reqMethodName string, code string) map[string]string
• func GetFdbTags(ctx context.Context, reqMethodName string) map[string]string
• func GetGlobalTags() map[string]string
• func GetSearchTags(ctx context.Context, reqMethodName string) map[string]string
• func InitializeFdbScopes()
• func InitializeMetrics() io.Closer
• func InitializeRequestScopes()
• func InitializeSearchScopes()
• type RequestEndpointMetadata
  • func GetGrpcEndPointMetadataFromFullMethod(ctx context.Context, fullMethod string, methodType string) RequestEndpointMetadata
  • func (r *RequestEndpointMetadata) GetMethodName() string
  • func (r *RequestEndpointMetadata) GetServiceType() string
  • func (r *RequestEndpointMetadata) GetSpecificErrorTags(source string, code string) map[string]string
  • func (r *RequestEndpointMetadata) GetTags() map[string]string
• type SpanMeta
  • func NewSpanMeta(serviceName string, resourceName string, spanType string, ...) *SpanMeta
  • func (s *SpanMeta) GetSpanOptions() []tracer.StartSpanOption
  • func (s *SpanMeta) StartTracing(ctx context.Context, childOnly bool) (context.Context, func())

Constants

const (
	AdminServiceName            = "tigrisdata.admin.v1.Admin"
	SystemTigrisTenantName      = "system"
	DefaultReportedTigrisTenant = "unknown"
)

const (
	GrpcTracingServiceName      = "tigris.grpc"
	KvTracingServiceName        = "tigris.fdb.kv"
	TxManagerTracingServiceName = "tigris.tx.manager"
)

Variables

var (
	FdbRequests         tally.Scope
	FdbErrorRequests    tally.Scope
	MeasuredFdbRequests = []string{
		"Delete",
		"DeleteRange",
		"CreateTable",
		"DropTable",
		"SetVersionstampedValue",
		"SetVersionstampedKey",
		"Get",
		"Insert",
		"Replace",
		"Read",
		"ReadRange",
		"Update",
		"UpdateRange",
		"BeginTx",
	}
)

var (
	Reporter promreporter.Reporter

	// GRPC and HTTP related metric scopes
	Requests         tally.Scope
	ErrorRequests    tally.Scope
	RequestsRespTime tally.Scope
	// Fdb related metric scopes
	FdbMetrics tally.Scope
	// Search related metrics scopes
	SearchMetrics tally.Scope
)

var (
	SearchRequests      tally.Scope
	SearchErrorRequests tally.Scope
)

Functions

func GetFdbSpecificErrorTags

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

func GetFdbTags

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

func GetGlobalTags

func GetGlobalTags() map[string]string

func GetSearchTags

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

func InitializeFdbScopes

func InitializeFdbScopes()

func InitializeMetrics

func InitializeMetrics() io.Closer

func InitializeRequestScopes

func InitializeRequestScopes()

func InitializeSearchScopes

func InitializeSearchScopes()

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

func (r *RequestEndpointMetadata) GetMethodName() string

func (*RequestEndpointMetadata) GetServiceType

func (r *RequestEndpointMetadata) GetServiceType() string

func (*RequestEndpointMetadata) GetSpecificErrorTags

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

func (*RequestEndpointMetadata) GetTags

func (r *RequestEndpointMetadata) GetTags() map[string]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 (*SpanMeta) GetSpanOptions

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

func (*SpanMeta) StartTracing

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