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 AppendProposal
- type AppendProposals
- type ClearProposal
- type ClearProposals
- type EntriesProposal
- type EntriesProposals
- type EventsProposal
- type EventsProposals
- type FirstEntryProposal
- type FirstEntryProposals
- type GetProposal
- type GetProposals
- type LastEntryProposal
- type LastEntryProposals
- type LinkedEntry
- type LogState
- func (*LogState) Descriptor() ([]byte, []int)
- func (m *LogState) GetValue() int64
- func (m *LogState) Marshal() (dAtA []byte, err error)
- func (m *LogState) MarshalTo(dAtA []byte) (int, error)
- func (m *LogState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogState) ProtoMessage()
- func (m *LogState) Reset()
- func (m *LogState) Size() (n int)
- func (m *LogState) String() string
- func (m *LogState) Unmarshal(dAtA []byte) error
- func (m *LogState) XXX_DiscardUnknown()
- func (m *LogState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogState) XXX_Merge(src proto.Message)
- func (m *LogState) XXX_Size() int
- func (m *LogState) XXX_Unmarshal(b []byte) error
- type NewServiceFunc
- type NextEntryProposal
- type NextEntryProposals
- type PrevEntryProposal
- type PrevEntryProposals
- type Proposal
- type ProposalID
- type Proposals
- type RemoveProposal
- type RemoveProposals
- type Service
- type ServiceAdaptor
- type ServiceContext
- type Session
- type SessionID
- type SessionState
- type Sessions
- type SizeProposal
- type SizeProposals
- type SnapshotReader
- type SnapshotWriter
- type Watcher
Constants ¶
View Source
const Type = "Log"
Variables ¶
Functions ¶
func RegisterService ¶
RegisterService registers the election primitive service on the given node
Types ¶
type AppendProposal ¶
type AppendProposal interface { Proposal Request() *_log.AppendRequest Reply(*_log.AppendResponse) error // contains filtered or unexported methods }
type AppendProposals ¶
type AppendProposals interface { Get(ProposalID) (AppendProposal, bool) List() []AppendProposal // contains filtered or unexported methods }
type ClearProposal ¶
type ClearProposal interface { Proposal Request() *_log.ClearRequest Reply(*_log.ClearResponse) error // contains filtered or unexported methods }
type ClearProposals ¶
type ClearProposals interface { Get(ProposalID) (ClearProposal, bool) List() []ClearProposal // contains filtered or unexported methods }
type EntriesProposal ¶
type EntriesProposal interface { Proposal Request() *_log.EntriesRequest Notify(*_log.EntriesResponse) error Close() error }
type EntriesProposals ¶
type EntriesProposals interface { Get(ProposalID) (EntriesProposal, bool) List() []EntriesProposal // contains filtered or unexported methods }
type EventsProposal ¶
type EventsProposal interface { Proposal Request() *_log.EventsRequest Notify(*_log.EventsResponse) error Close() error }
type EventsProposals ¶
type EventsProposals interface { Get(ProposalID) (EventsProposal, bool) List() []EventsProposal // contains filtered or unexported methods }
type FirstEntryProposal ¶
type FirstEntryProposal interface { Proposal Request() *_log.FirstEntryRequest Reply(*_log.FirstEntryResponse) error // contains filtered or unexported methods }
type FirstEntryProposals ¶
type FirstEntryProposals interface { Get(ProposalID) (FirstEntryProposal, bool) List() []FirstEntryProposal // contains filtered or unexported methods }
type GetProposal ¶
type GetProposal interface { Proposal Request() *_log.GetRequest Reply(*_log.GetResponse) error // contains filtered or unexported methods }
type GetProposals ¶
type GetProposals interface { Get(ProposalID) (GetProposal, bool) List() []GetProposal // contains filtered or unexported methods }
type LastEntryProposal ¶
type LastEntryProposal interface { Proposal Request() *_log.LastEntryRequest Reply(*_log.LastEntryResponse) error // contains filtered or unexported methods }
type LastEntryProposals ¶
type LastEntryProposals interface { Get(ProposalID) (LastEntryProposal, bool) List() []LastEntryProposal // contains filtered or unexported methods }
type LinkedEntry ¶
type LinkedEntry struct { *logapi.Entry Prev *LinkedEntry Next *LinkedEntry }
LinkedEntry is a doubly linked Entry
type LogState ¶
type LogState struct { meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"` Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*LogState) Descriptor ¶
func (*LogState) MarshalToSizedBuffer ¶
func (*LogState) ProtoMessage ¶
func (*LogState) ProtoMessage()
func (*LogState) XXX_DiscardUnknown ¶
func (m *LogState) XXX_DiscardUnknown()
func (*LogState) XXX_Marshal ¶
func (*LogState) XXX_Unmarshal ¶
type NewServiceFunc ¶
type NewServiceFunc func(ServiceContext) Service
type NextEntryProposal ¶
type NextEntryProposal interface { Proposal Request() *_log.NextEntryRequest Reply(*_log.NextEntryResponse) error // contains filtered or unexported methods }
type NextEntryProposals ¶
type NextEntryProposals interface { Get(ProposalID) (NextEntryProposal, bool) List() []NextEntryProposal // contains filtered or unexported methods }
type PrevEntryProposal ¶
type PrevEntryProposal interface { Proposal Request() *_log.PrevEntryRequest Reply(*_log.PrevEntryResponse) error // contains filtered or unexported methods }
type PrevEntryProposals ¶
type PrevEntryProposals interface { Get(ProposalID) (PrevEntryProposal, bool) List() []PrevEntryProposal // contains filtered or unexported methods }
type ProposalID ¶
type ProposalID uint64
type Proposals ¶
type Proposals interface { Size() SizeProposals Append() AppendProposals Get() GetProposals FirstEntry() FirstEntryProposals LastEntry() LastEntryProposals PrevEntry() PrevEntryProposals NextEntry() NextEntryProposals Remove() RemoveProposals Clear() ClearProposals Events() EventsProposals Entries() EntriesProposals }
type RemoveProposal ¶
type RemoveProposal interface { Proposal Request() *_log.RemoveRequest Reply(*_log.RemoveResponse) error // contains filtered or unexported methods }
type RemoveProposals ¶
type RemoveProposals interface { Get(ProposalID) (RemoveProposal, bool) List() []RemoveProposal // contains filtered or unexported methods }
type Service ¶
type Service interface { ServiceContext Backup(SnapshotWriter) error Restore(SnapshotReader) error // Size returns the size of the log Size(SizeProposal) error // Appends appends an entry into the log Append(AppendProposal) error // Get gets the entry for an index Get(GetProposal) error // FirstEntry gets the first entry in the log FirstEntry(FirstEntryProposal) error // LastEntry gets the last entry in the log LastEntry(LastEntryProposal) error // PrevEntry gets the previous entry in the log PrevEntry(PrevEntryProposal) error // NextEntry gets the next entry in the log NextEntry(NextEntryProposal) error // Remove removes an entry from the log Remove(RemoveProposal) error // Clear removes all entries from the log Clear(ClearProposal) error // Events listens for change events Events(EventsProposal) error // Entries lists all entries in the log Entries(EntriesProposal) 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 SizeProposal ¶
type SizeProposal interface { Proposal Request() *_log.SizeRequest Reply(*_log.SizeResponse) error // contains filtered or unexported methods }
type SizeProposals ¶
type SizeProposals interface { Get(ProposalID) (SizeProposal, bool) List() []SizeProposal // contains filtered or unexported methods }
type SnapshotReader ¶
type SnapshotWriter ¶
Click to show internal directories.
Click to hide internal directories.