synch

Documentation

Overview

Package synch provides synchronization primitives.

This file defines a distributed Lock interface for acquiring and releasing locks with context support and timeouts.

Index

• type Executor
  • func Runner(repeat int, fn any) *Executor
  • func (o *Executor) Run(argv ...reflect.Value) []reflect.Value
• type Lock

Types

type Executor

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

func Runner

func Runner(repeat int, fn any) *Executor

func (*Executor) Run

func (o *Executor) Run(argv ...reflect.Value) []reflect.Value

type Lock

type Lock interface {
	Lock(ctx context.Context, source, owner string, timeout time.Duration) (bool, error)
	Unlock(ctx context.Context, source, owner string) (bool, error)
}