arbiter

package

v0.1.791 Latest Latest Go to latest Published: Oct 10, 2025 License: Apache-2.0 Imports: 8 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Client interface {
	contract.ArbiterOperator
}

func NewClient(d Dependencies, opts ClientOptions) (Client, error)

type ClientOption func(*ClientOptions)

func WithTimeout(x time.Duration) ClientOption

type ClientOptions struct {
	Timeout time.Duration
}

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) AbsorbLoad(ctx context.Context, c fmt.Stringer, ttl time.Duration) (bool, error)

AbsorbLoad sets a unique key with the given TTL, returns true if load is absorbed (key already present), or false if key was just created.

func (d *DefaultTool) Claim(ctx context.Context, key fmt.Stringer, owner string) (bool, error)

Claim attempts to acquire ownership of a key with a TTL.

func (d *DefaultTool) ClaimRun(ctx context.Context, opts contract.ClaimRunOptions) (bool, error)

ClaimRun attempts to claim a generic run.

func (d *DefaultTool) ClaimRunReembed(ctx context.Context, opts contract.ClaimRunReembedOptions) (bool, error)

ClaimRunReembed attempts to claim a reembedding run.

func (d *DefaultTool) ClaimRunStatsPop(ctx context.Context, opts contract.ClaimRunStatsPopOptions) (bool, error)

ClaimRunStatsPop attempts to claim a feed statistics population run.

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

Close closes the underlying client.

func (d *DefaultTool) Extend(ctx context.Context, key fmt.Stringer, owner string) (bool, error)

Extend refreshes the TTL of an owned key.

func (d *DefaultTool) Release(ctx context.Context, key fmt.Stringer, owner string) error

Release relinquishes ownership of a key.

type Dependencies struct {
	C contract.ArbiterOperator
}

type Tool interface {
	Client
}