state

Documentation

Index

• type PSConstants
• type PipelineSelector
  • func NewPipelineSelector(lenPriority int, consts PSConstants) *PipelineSelector
  • func (p *PipelineSelector) ChannelIndex(ch chan bool) int
  • func (p *PipelineSelector) ListenToChannels(done chan struct{}, wg *sync.WaitGroup)
  • func (p *PipelineSelector) ResetRetryCount(idx int)
  • func (p *PipelineSelector) SelectedPipeline() (int, chan bool)
  • func (p *PipelineSelector) SetRetryCountToMax(idx int)
  • func (p *PipelineSelector) Start(done chan struct{}, wg *sync.WaitGroup)
  • func (p *PipelineSelector) TestCurrentIndex() int
  • func (p *PipelineSelector) TestRetryPipelines(ctx context.Context, retryInterval time.Duration, retryGap time.Duration)
  • func (p *PipelineSelector) TestSetStableIndex(idx int32)
  • func (p *PipelineSelector) TestStableIndex() int
• type RetryState
  • func (m *RetryState) InvokeCancel()
  • func (m *RetryState) UpdateCancelFunc(newCancelFunc context.CancelFunc)
• type TryLock
  • func NewTryLock() *TryLock
  • func (t *TryLock) TryExecute(fn func(int), arg int)

Types

type PSConstants

type PSConstants struct {
	RetryInterval time.Duration
	RetryGap      time.Duration
	MaxRetries    int
}

type PipelineSelector

type PipelineSelector struct {
	RS *RetryState
	// contains filtered or unexported fields
}

PipelineSelector is meant to serve as the source of truth for the target priority level

func NewPipelineSelector

func NewPipelineSelector(lenPriority int, consts PSConstants) *PipelineSelector

func (*PipelineSelector) ChannelIndex

func (p *PipelineSelector) ChannelIndex(ch chan bool) int

For Testing

func (*PipelineSelector) ListenToChannels

func (p *PipelineSelector) ListenToChannels(done chan struct{}, wg *sync.WaitGroup)

func (*PipelineSelector) ResetRetryCount

func (p *PipelineSelector) ResetRetryCount(idx int)

func (*PipelineSelector) SelectedPipeline

func (p *PipelineSelector) SelectedPipeline() (int, chan bool)

func (*PipelineSelector) SetRetryCountToMax

func (p *PipelineSelector) SetRetryCountToMax(idx int)

func (*PipelineSelector) Start

func (p *PipelineSelector) Start(done chan struct{}, wg *sync.WaitGroup)

func (*PipelineSelector) TestCurrentIndex

func (p *PipelineSelector) TestCurrentIndex() int

func (*PipelineSelector) TestRetryPipelines

func (p *PipelineSelector) TestRetryPipelines(ctx context.Context, retryInterval time.Duration, retryGap time.Duration)

func (*PipelineSelector) TestSetStableIndex

func (p *PipelineSelector) TestSetStableIndex(idx int32)

func (*PipelineSelector) TestStableIndex

func (p *PipelineSelector) TestStableIndex() int

type RetryState

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

Manages cancel function for retry goroutine, ends up cleaner than using channels

func (*RetryState) InvokeCancel

func (m *RetryState) InvokeCancel()

func (*RetryState) UpdateCancelFunc

func (m *RetryState) UpdateCancelFunc(newCancelFunc context.CancelFunc)

type TryLock

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

func NewTryLock

func NewTryLock() *TryLock

func (*TryLock) TryExecute

func (t *TryLock) TryExecute(fn func(int), arg int)