signaller

Documentation

Index

• type Signal
• type Signaller
  • func NewSignaller(address string, port int, workersCount int, maxRetries int, ...) *Signaller
  • func (b *Signaller) GetErrors() chan error
  • func (b *Signaller) ProcessSignalQueue()
  • func (b *Signaller) Retry(signal Signal)
  • func (b *Signaller) Run() error
  • func (b *Signaller) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (b *Signaller) SetEndpoints(e *watcher.EndpointConfig)

Types

type Signal

type Signal struct {
	Request *http.Request
	Attempt int
}

type Signaller

type Signaller struct {
	Address        string
	Port           int
	WorkersCount   int
	MaxRetries     int
	RetryBackoff   time.Duration
	EndpointScheme string
	// contains filtered or unexported fields
}

func NewSignaller

func NewSignaller(
	address string,
	port int,
	workersCount int,
	maxRetries int,
	retryBackoff time.Duration,
) *Signaller

func (*Signaller) GetErrors

func (b *Signaller) GetErrors() chan error

func (*Signaller) ProcessSignalQueue

func (b *Signaller) ProcessSignalQueue()

func (*Signaller) Retry

func (b *Signaller) Retry(signal Signal)

func (*Signaller) Run

func (b *Signaller) Run() error

func (*Signaller) ServeHTTP

func (b *Signaller) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Signaller) SetEndpoints

func (b *Signaller) SetEndpoints(e *watcher.EndpointConfig)