observability

Documentation

Index

• type PubSubMetrics
  • func (m *PubSubMetrics) Consumed(ctx context.Context, topic, subscription schema.RefKey, startTime time.Time, ...)
  • func (m *PubSubMetrics) Published(ctx context.Context, module, topic, caller string, maybeErr error)

Types

type PubSubMetrics

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

var (
	PubSub *PubSubMetrics
)

func (*PubSubMetrics) Consumed

func (m *PubSubMetrics) Consumed(ctx context.Context, topic, subscription schema.RefKey, startTime time.Time, maybeErr error)

func (*PubSubMetrics) Published

func (m *PubSubMetrics) Published(ctx context.Context, module, topic, caller string, maybeErr error)