observability

Documentation

Index

• Variables
• type AsyncCallMetrics
  • func (m *AsyncCallMetrics) Acquired(ctx context.Context, verb schema.RefKey, ...)
  • func (m *AsyncCallMetrics) Completed(ctx context.Context, verb schema.RefKey, ...)
  • func (m *AsyncCallMetrics) Created(ctx context.Context, verb schema.RefKey, ...)
  • func (m *AsyncCallMetrics) Executed(ctx context.Context, verb schema.RefKey, ...)
  • func (m *AsyncCallMetrics) RecordQueueDepth(ctx context.Context, queueDepth int64)
• type CallMetrics
  • func (m *CallMetrics) Request(ctx context.Context, verb *schemapb.Ref, startTime time.Time, ...)
• type CronMetrics
  • func (m *CronMetrics) JobFailed(ctx context.Context, job model.CronJob)
  • func (m *CronMetrics) JobFailedStart(ctx context.Context, job model.CronJob)
  • func (m *CronMetrics) JobKilled(ctx context.Context, job model.CronJob)
  • func (m *CronMetrics) JobStarted(ctx context.Context, job model.CronJob)
  • func (m *CronMetrics) JobSuccess(ctx context.Context, job model.CronJob)
• type DeploymentMetrics
  • func (m *DeploymentMetrics) ReconciliationComplete(ctx context.Context, module string, key string)
  • func (m *DeploymentMetrics) ReconciliationFailure(ctx context.Context, module string, key string)
  • func (m *DeploymentMetrics) ReconciliationStart(ctx context.Context, module string, key string)
  • func (m *DeploymentMetrics) ReplicasUpdated(ctx context.Context, module string, key string, delta int)
• 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 string, topic model.TopicPayload, ...)
  • func (m *PubSubMetrics) Published(ctx context.Context, module, topic, caller string, maybeErr error)
  • func (m *PubSubMetrics) SinkCalled(ctx context.Context, topic model.TopicPayload, ...)

Variables

var (
	AsyncCalls *AsyncCallMetrics
	Calls      *CallMetrics
	Deployment *DeploymentMetrics
	FSM        *FSMMetrics
	PubSub     *PubSubMetrics
	Cron       *CronMetrics
)

Types

type AsyncCallMetrics

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

func (*AsyncCallMetrics) Acquired

func (m *AsyncCallMetrics) Acquired(ctx context.Context, verb schema.RefKey, catchVerb optional.Option[schema.RefKey], origin string, scheduledAt time.Time, isCatching bool, maybeErr error)

func (*AsyncCallMetrics) Completed

func (m *AsyncCallMetrics) Completed(ctx context.Context, verb schema.RefKey, catchVerb optional.Option[schema.RefKey], origin string, scheduledAt time.Time, isCatching bool, queueDepth int64, maybeErr error)

func (*AsyncCallMetrics) Created

func (m *AsyncCallMetrics) Created(ctx context.Context, verb schema.RefKey, catchVerb optional.Option[schema.RefKey], origin string, remainingAttempts int64, maybeErr error)

func (*AsyncCallMetrics) Executed

func (m *AsyncCallMetrics) Executed(ctx context.Context, verb schema.RefKey, catchVerb optional.Option[schema.RefKey], origin string, scheduledAt time.Time, isCatching bool, maybeFailureMode optional.Option[string])

func (*AsyncCallMetrics) RecordQueueDepth

func (m *AsyncCallMetrics) RecordQueueDepth(ctx context.Context, queueDepth int64)

type CallMetrics

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

func (*CallMetrics) Request

func (m *CallMetrics) Request(ctx context.Context, verb *schemapb.Ref, startTime time.Time, maybeFailureMode optional.Option[string])

type CronMetrics

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

func (*CronMetrics) JobFailed

func (m *CronMetrics) JobFailed(ctx context.Context, job model.CronJob)

func (*CronMetrics) JobFailedStart

func (m *CronMetrics) JobFailedStart(ctx context.Context, job model.CronJob)

func (*CronMetrics) JobKilled

func (m *CronMetrics) JobKilled(ctx context.Context, job model.CronJob)

func (*CronMetrics) JobStarted

func (m *CronMetrics) JobStarted(ctx context.Context, job model.CronJob)

func (*CronMetrics) JobSuccess

func (m *CronMetrics) JobSuccess(ctx context.Context, job model.CronJob)

type DeploymentMetrics

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

func (*DeploymentMetrics) ReconciliationComplete

func (m *DeploymentMetrics) ReconciliationComplete(ctx context.Context, module string, key string)

func (*DeploymentMetrics) ReconciliationFailure

func (m *DeploymentMetrics) ReconciliationFailure(ctx context.Context, module string, key string)

func (*DeploymentMetrics) ReconciliationStart

func (m *DeploymentMetrics) ReconciliationStart(ctx context.Context, module string, key string)

func (*DeploymentMetrics) ReplicasUpdated

func (m *DeploymentMetrics) ReplicasUpdated(ctx context.Context, module string, key string, delta int)

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 string, topic model.TopicPayload, optCaller optional.Option[string], subscription schema.RefKey, sink optional.Option[schema.RefKey])

func (*PubSubMetrics) Published

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

func (*PubSubMetrics) SinkCalled

func (m *PubSubMetrics) SinkCalled(ctx context.Context, topic model.TopicPayload, optCaller optional.Option[string], subscription, sink schema.RefKey)