observability

Documentation

Index

• Variables
• type FSMMetrics
  • func (m *FSMMetrics) InstanceCompleted(ctx context.Context, fsm schema.RefKey)
  • func (m *FSMMetrics) InstanceCreated(ctx context.Context, fsm schema.RefKey)
  • func (m *FSMMetrics) TransitionCompleted(ctx context.Context, fsm schema.RefKey)
  • func (m *FSMMetrics) TransitionStarted(ctx context.Context, fsm schema.RefKey, destState schema.RefKey)
• type PubSubMetrics
  • func (m *PubSubMetrics) PropagationFailed(ctx context.Context, failedOp, topic string, subscription schema.RefKey, ...)
  • func (m *PubSubMetrics) Published(ctx context.Context, module, topic string, maybeErr error)
  • func (m *PubSubMetrics) SinkCalled(ctx context.Context, topic string, subscription, sink schema.RefKey)

Variables

var (
	FSM    *FSMMetrics
	PubSub *PubSubMetrics
)

Types

type FSMMetrics

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

func (*FSMMetrics) InstanceCompleted

func (m *FSMMetrics) InstanceCompleted(ctx context.Context, fsm schema.RefKey)

func (*FSMMetrics) InstanceCreated

func (m *FSMMetrics) InstanceCreated(ctx context.Context, fsm schema.RefKey)

func (*FSMMetrics) TransitionCompleted

func (m *FSMMetrics) TransitionCompleted(ctx context.Context, fsm schema.RefKey)

func (*FSMMetrics) TransitionStarted

func (m *FSMMetrics) TransitionStarted(ctx context.Context, fsm schema.RefKey, destState schema.RefKey)

type PubSubMetrics

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

func (*PubSubMetrics) PropagationFailed

func (m *PubSubMetrics) PropagationFailed(ctx context.Context, failedOp, topic string, subscription schema.RefKey, sink optional.Option[schema.RefKey])

func (*PubSubMetrics) Published

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

func (*PubSubMetrics) SinkCalled

func (m *PubSubMetrics) SinkCalled(ctx context.Context, topic string, subscription, sink schema.RefKey)