resiliency

Documentation

Index

• func NewTaskHandler(telCtx domain.TelemetryContext, spec model.TaskSpec, ...) domain.TaskHandler
• func WithCircuitBreaker(spec model.CircuitBreakerSpec, secondaryAdapter secondary.SecodaryPort, ...) (CallWithContextAlias, CircuitBreaker)
• type CallAlias
• type CallWithContextAlias
  • func WithAdaptiveCallTimeout(spec model.AdaptiveTimeoutSpec, secondaryAdapter secondary.SecodaryPort, ...) CallWithContextAlias
  • func WithAdaptiveTaskTimeout(spec model.AdaptiveTimeoutSpec, secondaryAdapter secondary.SecodaryPort, ...) CallWithContextAlias
  • func WithCallDurationMetrics(next CallWithContextAlias) CallWithContextAlias
  • func WithCallTimeout(timeout time.Duration, next CallWithContextAlias) CallWithContextAlias
  • func WithCriticalError(isCritical bool, next CallWithContextAlias) CallWithContextAlias
  • func WithLogger(telCtx domain.TelemetryContext, timing string, ...) CallWithContextAlias
  • func WithRetry(spec model.RetrySpec, next CallWithContextAlias) CallWithContextAlias
  • func WithTaskDurationMetrics(next CallWithContextAlias) CallWithContextAlias
  • func WithTaskTimeout(timeout time.Duration, next CallWithContextAlias) CallWithContextAlias
  • func WithUnWrapTaskContext(next CallAlias) CallWithContextAlias
• type CircuitBreaker
• type TaskContext
  • func (tc *TaskContext) IncAttempt()

Functions

func NewTaskHandler

func NewTaskHandler(telCtx domain.TelemetryContext, spec model.TaskSpec, adapter secondary.SecodaryPort) domain.TaskHandler

func WithCircuitBreaker

func WithCircuitBreaker(spec model.CircuitBreakerSpec, secondaryAdapter secondary.SecodaryPort, next CallWithContextAlias) (CallWithContextAlias, CircuitBreaker)

Types

type CallAlias

type CallAlias = func(context.Context) secondary.SecondaryPortCallResult

type CallWithContextAlias

type CallWithContextAlias = func(context.Context, *TaskContext) secondary.SecondaryPortCallResult

func WithAdaptiveCallTimeout

func WithAdaptiveCallTimeout(spec model.AdaptiveTimeoutSpec, secondaryAdapter secondary.SecodaryPort, next CallWithContextAlias) CallWithContextAlias

func WithAdaptiveTaskTimeout

func WithAdaptiveTaskTimeout(spec model.AdaptiveTimeoutSpec, secondaryAdapter secondary.SecodaryPort, next CallWithContextAlias) CallWithContextAlias

func WithCallDurationMetrics

func WithCallDurationMetrics(next CallWithContextAlias) CallWithContextAlias

func WithCallTimeout

func WithCallTimeout(timeout time.Duration, next CallWithContextAlias) CallWithContextAlias

func WithCriticalError

func WithCriticalError(isCritical bool, next CallWithContextAlias) CallWithContextAlias

func WithLogger

func WithLogger(telCtx domain.TelemetryContext, timing string, secondaryAdapter secondary.SecodaryPort, next CallWithContextAlias) CallWithContextAlias

func WithRetry

func WithRetry(spec model.RetrySpec, next CallWithContextAlias) CallWithContextAlias

func WithTaskDurationMetrics

func WithTaskDurationMetrics(next CallWithContextAlias) CallWithContextAlias

func WithTaskTimeout

func WithTaskTimeout(timeout time.Duration, next CallWithContextAlias) CallWithContextAlias

func WithUnWrapTaskContext

func WithUnWrapTaskContext(next CallAlias) CallWithContextAlias

WithUnWrapTaskContext decorates `next` function with a decorator that unwraps TaskContext into context.Context Should be the first decorator

type CircuitBreaker

type CircuitBreaker = *gobreaker.CircuitBreaker[secondary.SecondaryPortCallResult]

type TaskContext

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

func (*TaskContext) IncAttempt

func (tc *TaskContext) IncAttempt()