racing

Documentation

Index

• func Sleep(ctx context.Context, d time.Duration) error
• type LockTimeoutError
  • func (l LockTimeoutError) Error() string
• type Mutex
  • func NewMutex() Mutex
• type RacingReader
  • func NewRacingReader(reader io.Reader) RacingReader
• type RacingWriter
  • func NewRacingWriter(writer io.Writer) RacingWriter

Functions

func Sleep

func Sleep(ctx context.Context, d time.Duration) error

Types

type LockTimeoutError

type LockTimeoutError string

func (LockTimeoutError) Error

func (l LockTimeoutError) Error() string

type Mutex

type Mutex interface {
	// TryLock attempts to acquire the lock before the deadline set by the provided context
	// If the context does not define a deadline, TryLock will block until the lock is acquired
	// Returns true if the lock is acquired, false otherwise
	TryLock(ctx context.Context) bool
	// Unlock frees this lock, if locked
	// It is a run-time error if the lock is not locked on entry to Unlock.
	Unlock()
}

func NewMutex

func NewMutex() Mutex

type RacingReader

type RacingReader interface {
	Read(ctx context.Context, bytes []byte) (int, error)
	ReadFull(ctx context.Context, bytes []byte) (int, error)
}

func NewRacingReader

func NewRacingReader(reader io.Reader) RacingReader

type RacingWriter

type RacingWriter interface {
	Write(ctx context.Context, bytes []byte) (int, error)
}

func NewRacingWriter

func NewRacingWriter(writer io.Writer) RacingWriter