telemetry

Sep 18, 2023

Changes in this version

type MessagingTracer

+ func (msg *MessagingTracer) StopSpan()

type PostgresTracer

+ func (d *PostgresTracer) StopSpan()

type Transport

+ Origin http.RoundTripper

Mar 15, 2023

Changes in this version

+ const HookConditionPostHookDB

+ const HookConditionPostHookQueue

+ const HookConditionPreHookDB

+ const HookConditionPreHookQueue

+ var MetricNotificationMessageCounter = stats.Int64("notification.message", "notification messages counter", ...)

+ var MetricNotificationMessageQueueTime = stats.Int64("notification.message.queue.time", ...)

+ var MetricNotificationSubscriberNotFound = stats.Int64("notification.subscriber.notfound", ...)

+ var MetricReceiverHookFailed = stats.Int64("receiver.hook.failed", "failed hook condition", stats.UnitDimensionless)

+ var TagHookCondition = tag.MustNewKey("hook_condition")

+ var TagMessageStatus = tag.MustNewKey("status")

+ var TagNotificationType = tag.MustNewKey("notification_type")

+ var TagReceiverType = tag.MustNewKey("receiver_type")

+ func GaugeMillisecond(ctx context.Context, si64 *stats.Int64Measure, value int64, ...)

+ func IncrementInt64Counter(ctx context.Context, si64 *stats.Int64Measure, tagMutator ...tag.Mutator)

+ func Init(ctx context.Context, cfg Config, lg log.Logger)

+ type Config struct

+ Debug string

+ EnableCPU bool

+ EnableMemory bool

+ EnableNewrelic bool

+ EnableOtelAgent bool

+ NewRelicAPIKey string

+ NewRelicAppName string

+ OpenTelAgentAddr string

+ SamplingFraction float64

+ ServiceName string

+ type MessagingTracer struct

+ func NewMessagingTracer(queueSystem string) *MessagingTracer

+ func (msg MessagingTracer) StartSpan(ctx context.Context, op string, spanAttributes ...trace.Attribute) (context.Context, *trace.Span)

+ type PostgresTracer struct

+ func NewPostgresTracer(url string) (*PostgresTracer, error)

+ func (d PostgresTracer) StartSpan(ctx context.Context, op string, tableName string, ...) (context.Context, *trace.Span)

+ type Transport struct

+ Base http.RoundTripper

+ func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)