common

Documentation

Overview

Package common provides implementation of some of the basic functionalities to be used in application.

Index

• func GetRetry(ctx context.Context) uint
• func IncreaseRetry(ctx context.Context) context.Context
• type Cancelable
  • func (c *Cancelable) Cancel()
  • func (c *Cancelable) SetCancel(cancel func())
• type Hooked
  • func (h *Hooked) DoDoneHooks(ctx context.Context) []error
  • func (h *Hooked) DoFailHooks(ctx context.Context) []error
  • func (h *Hooked) SetDoneHooks(hooks []abstraction.Executable)
  • func (h *Hooked) SetFailHooks(failHooks []abstraction.Executable)
• type Retry
  • func (r *Retry) SetMaxRetry(retries uint)
  • func (r *Retry) SetRetryDelay(retryDelay time.Duration)
  • func (r *Retry) WaitForRetry(ctx context.Context) error
• type Timeout
  • func (t *Timeout) ApplyTimeout(ctx context.Context) (context.Context, func())
  • func (t *Timeout) SetTimeout(timeout time.Duration)

Functions

func GetRetry

func GetRetry(ctx context.Context) uint

func IncreaseRetry

func IncreaseRetry(ctx context.Context) context.Context

Types

type Cancelable

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

func (*Cancelable) Cancel

func (c *Cancelable) Cancel()

func (*Cancelable) SetCancel

func (c *Cancelable) SetCancel(cancel func())

type Hooked

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

func (*Hooked) DoDoneHooks

func (h *Hooked) DoDoneHooks(ctx context.Context) []error

func (*Hooked) DoFailHooks

func (h *Hooked) DoFailHooks(ctx context.Context) []error

func (*Hooked) SetDoneHooks

func (h *Hooked) SetDoneHooks(hooks []abstraction.Executable)

func (*Hooked) SetFailHooks

func (h *Hooked) SetFailHooks(failHooks []abstraction.Executable)

type Retry

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

func (*Retry) SetMaxRetry

func (r *Retry) SetMaxRetry(retries uint)

func (*Retry) SetRetryDelay

func (r *Retry) SetRetryDelay(retryDelay time.Duration)

func (*Retry) WaitForRetry

func (r *Retry) WaitForRetry(ctx context.Context) error

type Timeout

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

func (*Timeout) ApplyTimeout

func (t *Timeout) ApplyTimeout(ctx context.Context) (context.Context, func())

func (*Timeout) SetTimeout

func (t *Timeout) SetTimeout(timeout time.Duration)