lock

type GetLockQuery interface {
	Query
	Request() *lock.GetLockRequest
}

type LockProposal interface {
	Proposal
	Request() *lock.LockRequest
	Reply(*lock.LockResponse)
	Fail(error)
}

type LockProposals interface {
	Get(ProposalID) (LockProposal, bool)
	List() []LockProposal
}

type LockRequest struct {
	ProposalID ProposalID `protobuf:"varint,1,opt,name=proposal_id,json=proposalId,proto3,casttype=ProposalID" json:"proposal_id,omitempty"`
	SessionID  SessionID  `protobuf:"varint,2,opt,name=session_id,json=sessionId,proto3,casttype=SessionID" json:"session_id,omitempty"`
	Expire     *time.Time `protobuf:"bytes,3,opt,name=expire,proto3,stdtime" json:"expire,omitempty"`
}

type LockState struct {
	Owner    *LockRequest  `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Requests []LockRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests"`
}

type NewServiceFunc func(ServiceContext) Service

type Proposal interface {
	fmt.Stringer
	ID() ProposalID
	Session() Session
	State() ProposalState
	Watch(func(ProposalState)) Watcher
}

type ProposalID uint64

type ProposalState int

type Proposals interface {
	Lock() LockProposals
	Unlock() UnlockProposals
}

type Query interface {
	fmt.Stringer
	Session() Session
}

type Service interface {
	ServiceContext
	Backup(SnapshotWriter) error
	Restore(SnapshotReader) error
	// Lock attempts to acquire the lock
	Lock(LockProposal)
	// Unlock releases the lock
	Unlock(UnlockProposal) (*lock.UnlockResponse, error)
	// GetLock gets the lock state
	GetLock(GetLockQuery) (*lock.GetLockResponse, error)
}

type ServiceAdaptor struct {
	rsm.ServiceContext
	// contains filtered or unexported fields
}

type ServiceContext interface {
	Scheduler() rsm.Scheduler
	Sessions() Sessions
	Proposals() Proposals
}

type Session interface {
	ID() SessionID
	State() SessionState
	Watch(func(SessionState)) Watcher
	Proposals() Proposals
}

type SessionID uint64

type SessionState int

type Sessions interface {
	Get(SessionID) (Session, bool)
	List() []Session
}

type SnapshotReader interface {
	ReadState() (*LockState, error)
}

type SnapshotWriter interface {
	WriteState(*LockState) error
}

type UnlockProposal interface {
	Proposal
	Request() *lock.UnlockRequest
}

type UnlockProposals interface {
	Get(ProposalID) (UnlockProposal, bool)
	List() []UnlockProposal
}

type Watcher interface {
	Cancel()
}