Documentation ¶
Overview ¶
Code generated by atomix-go-framework. DO NOT EDIT.
Code generated by atomix-go-framework. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterService(node *rsm.Node)
- type GetLockProposal
- type GetLockProposals
- type LockProposal
- type LockProposals
- type LockRequest
- func (*LockRequest) Descriptor() ([]byte, []int)
- func (m *LockRequest) GetExpire() *time.Time
- func (m *LockRequest) GetProposalID() ProposalID
- func (m *LockRequest) GetSessionID() SessionID
- func (m *LockRequest) Marshal() (dAtA []byte, err error)
- func (m *LockRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LockRequest) ProtoMessage()
- func (m *LockRequest) Reset()
- func (m *LockRequest) Size() (n int)
- func (m *LockRequest) String() string
- func (m *LockRequest) Unmarshal(dAtA []byte) error
- func (m *LockRequest) XXX_DiscardUnknown()
- func (m *LockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LockRequest) XXX_Merge(src proto.Message)
- func (m *LockRequest) XXX_Size() int
- func (m *LockRequest) XXX_Unmarshal(b []byte) error
- type LockState
- func (*LockState) Descriptor() ([]byte, []int)
- func (m *LockState) GetOwner() *LockRequest
- func (m *LockState) GetRequests() []LockRequest
- func (m *LockState) Marshal() (dAtA []byte, err error)
- func (m *LockState) MarshalTo(dAtA []byte) (int, error)
- func (m *LockState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LockState) ProtoMessage()
- func (m *LockState) Reset()
- func (m *LockState) Size() (n int)
- func (m *LockState) String() string
- func (m *LockState) Unmarshal(dAtA []byte) error
- func (m *LockState) XXX_DiscardUnknown()
- func (m *LockState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LockState) XXX_Merge(src proto.Message)
- func (m *LockState) XXX_Size() int
- func (m *LockState) XXX_Unmarshal(b []byte) error
- type NewServiceFunc
- type Proposal
- type ProposalID
- type Proposals
- type Service
- type ServiceAdaptor
- type ServiceContext
- type Session
- type SessionID
- type SessionState
- type Sessions
- type SnapshotReader
- type SnapshotWriter
- type UnlockProposal
- type UnlockProposals
- type Watcher
Constants ¶
View Source
const Type = "Lock"
Variables ¶
Functions ¶
func RegisterService ¶
RegisterService registers the election primitive service on the given node
Types ¶
type GetLockProposal ¶
type GetLockProposal interface { Proposal Request() *lock.GetLockRequest Reply(*lock.GetLockResponse) error // contains filtered or unexported methods }
type GetLockProposals ¶
type GetLockProposals interface { Get(ProposalID) (GetLockProposal, bool) List() []GetLockProposal // contains filtered or unexported methods }
type LockProposal ¶
type LockProposal interface { Proposal Request() *lock.LockRequest Reply(*lock.LockResponse) error Fail(error) error Close() error }
type LockProposals ¶
type LockProposals interface { Get(ProposalID) (LockProposal, bool) List() []LockProposal // contains filtered or unexported methods }
type LockRequest ¶
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"` }
func (*LockRequest) Descriptor ¶
func (*LockRequest) Descriptor() ([]byte, []int)
func (*LockRequest) GetExpire ¶
func (m *LockRequest) GetExpire() *time.Time
func (*LockRequest) GetProposalID ¶
func (m *LockRequest) GetProposalID() ProposalID
func (*LockRequest) GetSessionID ¶
func (m *LockRequest) GetSessionID() SessionID
func (*LockRequest) Marshal ¶
func (m *LockRequest) Marshal() (dAtA []byte, err error)
func (*LockRequest) MarshalToSizedBuffer ¶
func (m *LockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LockRequest) ProtoMessage ¶
func (*LockRequest) ProtoMessage()
func (*LockRequest) Reset ¶
func (m *LockRequest) Reset()
func (*LockRequest) Size ¶
func (m *LockRequest) Size() (n int)
func (*LockRequest) String ¶
func (m *LockRequest) String() string
func (*LockRequest) Unmarshal ¶
func (m *LockRequest) Unmarshal(dAtA []byte) error
func (*LockRequest) XXX_DiscardUnknown ¶
func (m *LockRequest) XXX_DiscardUnknown()
func (*LockRequest) XXX_Marshal ¶
func (m *LockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LockRequest) XXX_Merge ¶
func (m *LockRequest) XXX_Merge(src proto.Message)
func (*LockRequest) XXX_Size ¶
func (m *LockRequest) XXX_Size() int
func (*LockRequest) XXX_Unmarshal ¶
func (m *LockRequest) XXX_Unmarshal(b []byte) error
type LockState ¶
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"` }
func (*LockState) Descriptor ¶
func (*LockState) GetOwner ¶
func (m *LockState) GetOwner() *LockRequest
func (*LockState) GetRequests ¶
func (m *LockState) GetRequests() []LockRequest
func (*LockState) MarshalToSizedBuffer ¶
func (*LockState) ProtoMessage ¶
func (*LockState) ProtoMessage()
func (*LockState) XXX_DiscardUnknown ¶
func (m *LockState) XXX_DiscardUnknown()
func (*LockState) XXX_Marshal ¶
func (*LockState) XXX_Unmarshal ¶
type NewServiceFunc ¶
type NewServiceFunc func(ServiceContext) Service
type ProposalID ¶
type ProposalID uint64
type Proposals ¶
type Proposals interface { Lock() LockProposals Unlock() UnlockProposals GetLock() GetLockProposals }
type Service ¶
type Service interface { ServiceContext Backup(SnapshotWriter) error Restore(SnapshotReader) error // Lock attempts to acquire the lock Lock(LockProposal) error // Unlock releases the lock Unlock(UnlockProposal) error // GetLock gets the lock state GetLock(GetLockProposal) error }
type ServiceAdaptor ¶
func (*ServiceAdaptor) SessionClosed ¶
func (s *ServiceAdaptor) SessionClosed(session rsm.Session)
func (*ServiceAdaptor) SessionExpired ¶
func (s *ServiceAdaptor) SessionExpired(session rsm.Session)
func (*ServiceAdaptor) SessionOpen ¶
func (s *ServiceAdaptor) SessionOpen(rsmSession rsm.Session)
type ServiceContext ¶
type Session ¶
type Session interface { ID() SessionID State() SessionState Watch(func(SessionState)) Watcher Proposals() Proposals // contains filtered or unexported methods }
type SnapshotReader ¶
type SnapshotWriter ¶
type UnlockProposal ¶
type UnlockProposal interface { Proposal Request() *lock.UnlockRequest Reply(*lock.UnlockResponse) error // contains filtered or unexported methods }
type UnlockProposals ¶
type UnlockProposals interface { Get(ProposalID) (UnlockProposal, bool) List() []UnlockProposal // contains filtered or unexported methods }
Click to show internal directories.
Click to hide internal directories.