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) (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(nodeID uint64) error
	HandoffChFunc func() <-chan uint64
	CloseFunc     func() error
}

type Leaser struct {
	CloseFunc           func() error
	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 Stream struct {
	io.ReadCloser
	ClusterIDFunc func() string
}