opqueue

type Config struct {
	// PoolSize is the number of AMQP subscribers that are listening for operation messages.
	PoolSize int
	// TaskMonitorInterval is the interval (period) in which operation queue tasks from other server instances
	// are monitored.
	TaskMonitorInterval time.Duration
	// TaskExpiration is the maximum time that an operation queue task can exist in the database before it is
	// considered to have expired. At which point, any other server instance may delete the task and take over
	// processing of all operations associated with the task.
	TaskExpiration time.Duration
	// MaxRetries is the maximum number of retries for a failed operation in a batch.
	MaxRetries int
	// RetriesInitialDelay is the delay for the initial retry attempt.
	RetriesInitialDelay time.Duration
	// RetriesMaxDelay is the maximum delay for a retry attempt.
	RetriesMaxDelay time.Duration
	// RetriesMultiplier is the multiplier for a retry attempt. For example, if set to 1.5 and
	// the previous retry interval was 2s then the next retry interval is set 3s.
	RetriesMultiplier float64
	// MaxOperationsToRepost is the maximum number of operations to repost to the queue after
	// an instance dies.
	MaxOperationsToRepost int
	// OperationLifespan is the maximum time that an operation can exist in the database before
	// it is deleted
	OperationLifeSpan time.Duration
	// BatchWriterTimeout specifies the timeout for when a batch of operations is cut.
	BatchWriterTimeout time.Duration
	// MaxContiguousWithError specifies the maximum number of previously failed operations to rearrange contiguously.
	MaxContiguousWithError int
	// MaxContiguousWithoutError specifies the maximum number of operations (with no error) to rearrange contiguously.
	MaxContiguousWithoutError int
}

type OperationMessage struct {
	ID        string                           `json:"id"`
	Operation *operation.QueuedOperationAtTime `json:"operation"`
	Retries   int                              `json:"retries"`
	HasError  bool                             `json:"hasError,omitempty"`
}

type Queue struct {
	*lifecycle.Lifecycle
	// contains filtered or unexported fields
}