race

package

v3.4.7 Latest Latest Go to latest Published: Mar 21, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

SyncedReadCloser is compatible with io.ReadSeeker and performs gate-based synced writes to enable race condition testing.

func NewOpenGateWithTimeout(r io.ReadCloser, d time.Duration) *SyncedReadCloser

NewOpenGateWithTimeout creates a new open gate with a timeout

func NewSyncedReadCloser(r io.ReadCloser) *SyncedReadCloser

NewSyncedReadCloser creates a new SyncedReadCloser instance.

func (s *SyncedReadCloser) Close() error

Close closes an io.ReadSeeker

func (s *SyncedReadCloser) Len() int

Len returns the length of data in reader

func (s *SyncedReadCloser) OpenGate()

OpenGate opens the gate allowing all requests to be completed

func (s *SyncedReadCloser) OpenGateAfter(d time.Duration)

OpenGateAfter schedules gate to be opened after a duration

func (s *SyncedReadCloser) Read(p []byte) (n int, err error)

Read implements read method for io.ReadSeeker

func (s *SyncedReadCloser) Seek(offset int64, whence int) (int64, error)

Seek implements seek method for io.ReadSeeker

func (s *SyncedReadCloser) SetOpenGate(status bool)

SetOpenGate sets the status of the blocking gate