semaphore

package

v0.1.249 Latest Latest Go to latest Published: May 14, 2025 License: Apache-2.0 Imports: 3 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Client interface {
	contract.SemaphoreOperator
}

func NewClient(opts ClientOptions) Client

type ClientOption func(*ClientOptions)

func WithConcurrency(x int) ClientOption

type ClientOptions struct {
	Concurrency int
}

func ApplyClientOptions(opts *ClientOptions, modifiers ...ClientOption) ClientOptions

type DefaultTool struct {
	T *contract.Tool[Client]
}

func NewTool(c Client, opts contract.ToolOptions[Client]) *DefaultTool

func (d *DefaultTool) Acquire(ctx context.Context) error

Acquire reserves a slot in the semaphore, ensuring controlled concurrency.

func (d *DefaultTool) GetConcurrency(ctx context.Context) (int, error)

GetConcurrency returns the configured concurrency limit.

func (d *DefaultTool) Release(ctx context.Context) error

Release frees a previously acquired semaphore slot.

func (d *DefaultTool) WaitAll(ctx context.Context) error

WaitAll blocks until all acquired semaphore slots are released.

type Tool interface {
	Client
}