mock

type Client struct {
	AcquireHaltLockFunc func(ctx context.Context, primaryURL string, nodeID uint64, name string, lockID int64) (*litefs.HaltLock, error)
	ReleaseHaltLockFunc func(ctx context.Context, primaryURL string, nodeID uint64, name string, lockID int64) error
	CommitFunc          func(ctx context.Context, primaryURL string, nodeID uint64, name string, lockID int64, r io.Reader) error
	StreamFunc          func(ctx context.Context, primaryURL string, nodeID uint64, posMap map[string]ltx.Pos, filter []string) (litefs.Stream, error)
}

type Lease struct {
	IDFunc        func() string
	RenewedAtFunc func() time.Time
	TTLFunc       func() time.Duration
	RenewFunc     func(ctx context.Context) error
	HandoffFunc   func(ctx context.Context, nodeID uint64) error
	HandoffChFunc func() <-chan uint64
	CloseFunc     func() error
}

type Leaser struct {
	CloseFunc           func() error
	HostnameFunc        func() string
	AdvertiseURLFunc    func() string
	AcquireFunc         func(ctx context.Context) (litefs.Lease, error)
	AcquireExistingFunc func(ctx context.Context, leaseID string) (litefs.Lease, error)
	PrimaryInfoFunc     func(ctx context.Context) (litefs.PrimaryInfo, error)
	ClusterIDFunc       func(ctx context.Context) (string, error)
	SetClusterIDFunc    func(ctx context.Context, clusterID string) error
}

type OS struct {
	Underlying litefs.OS

	CreateFunc    func(op, name string) (*os.File, error)
	MkdirFunc     func(op, path string, perm os.FileMode) error
	MkdirAllFunc  func(op, path string, perm os.FileMode) error
	OpenFunc      func(op, name string) (*os.File, error)
	OpenFileFunc  func(op, name string, flag int, perm os.FileMode) (*os.File, error)
	ReadDirFunc   func(op, name string) ([]os.DirEntry, error)
	ReadFileFunc  func(op, name string) ([]byte, error)
	RemoveFunc    func(op, name string) error
	RemoveAllFunc func(op, name string) error
	RenameFunc    func(op, oldpath, newpath string) error
	StatFunc      func(op, name string) (os.FileInfo, error)
	TruncateFunc  func(op, name string, size int64) error
	WriteFileFunc func(op, name string, data []byte, perm os.FileMode) error
}

type Stream struct {
	io.ReadCloser
	ClusterIDFunc func() string
}