vault

type Mock struct {
	AcquireCount int
	ReleaseCount int
	CleanupCount int
	// contains filtered or unexported fields
}

type Opts struct {
	// Used for telemetry.
	Version string

	// Single queue mode should only be used for testing.
	QueueType

	// Only for multi-mode queues, determines the number of
	// supporting Go-routines able to handle work given to the
	// queueing layer.
	QueueConcurrency int

	// Sets the capacity of the underlying queue(s), the max amount
	// of buffered work for a queue. In a multi queue setting, the
	// capacity indicates the buffer size per queue.
	QueueCapacity int
}

type QueueType string

type Vault interface {
	// Lock tag is a string identifying the lock to acquire, client the requesting party,
	// and the callback a function which will be called to either confirm acquisition or
	// including an error in case the client is misbehaving. The callback may return an
	// error in case feedback handling encounters an error.
	Acquire(lockTag, client string, callback func(error) error)
	Release(lockTag, client string, callback func(error) error)
	Cleanup(locktag, client string)
}