Documentation ¶
Index ¶
- Variables
- func RegisterRaftServiceServer(s *grpc.Server, srv RaftServiceServer)
- type AppendRequest
- func (*AppendRequest) Descriptor() ([]byte, []int)
- func (this *AppendRequest) Equal(that interface{}) bool
- func (m *AppendRequest) GetCommitIndex() Index
- func (m *AppendRequest) GetEntries() []*LogEntry
- func (m *AppendRequest) GetLeader() MemberID
- func (m *AppendRequest) GetPrevLogIndex() Index
- func (m *AppendRequest) GetPrevLogTerm() Term
- func (m *AppendRequest) GetTerm() Term
- func (m *AppendRequest) Marshal() (dAtA []byte, err error)
- func (m *AppendRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AppendRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AppendRequest) ProtoMessage()
- func (m *AppendRequest) Reset()
- func (m *AppendRequest) Size() (n int)
- func (m *AppendRequest) String() string
- func (m *AppendRequest) Unmarshal(dAtA []byte) error
- func (m *AppendRequest) XXX_DiscardUnknown()
- func (m *AppendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AppendRequest) XXX_Merge(src proto.Message)
- func (m *AppendRequest) XXX_Size() int
- func (m *AppendRequest) XXX_Unmarshal(b []byte) error
- type AppendResponse
- func (*AppendResponse) Descriptor() ([]byte, []int)
- func (this *AppendResponse) Equal(that interface{}) bool
- func (m *AppendResponse) GetError() ResponseError
- func (m *AppendResponse) GetLastLogIndex() Index
- func (m *AppendResponse) GetStatus() ResponseStatus
- func (m *AppendResponse) GetSucceeded() bool
- func (m *AppendResponse) GetTerm() Term
- func (m *AppendResponse) Marshal() (dAtA []byte, err error)
- func (m *AppendResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AppendResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AppendResponse) ProtoMessage()
- func (m *AppendResponse) Reset()
- func (m *AppendResponse) Size() (n int)
- func (m *AppendResponse) String() string
- func (m *AppendResponse) Unmarshal(dAtA []byte) error
- func (m *AppendResponse) XXX_DiscardUnknown()
- func (m *AppendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AppendResponse) XXX_Merge(src proto.Message)
- func (m *AppendResponse) XXX_Size() int
- func (m *AppendResponse) XXX_Unmarshal(b []byte) error
- type Client
- type Cluster
- type CommandEntry
- func (*CommandEntry) Descriptor() ([]byte, []int)
- func (this *CommandEntry) Equal(that interface{}) bool
- func (m *CommandEntry) GetValue() []byte
- func (m *CommandEntry) Marshal() (dAtA []byte, err error)
- func (m *CommandEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *CommandEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommandEntry) ProtoMessage()
- func (m *CommandEntry) Reset()
- func (m *CommandEntry) Size() (n int)
- func (m *CommandEntry) String() string
- func (m *CommandEntry) Unmarshal(dAtA []byte) error
- func (m *CommandEntry) XXX_DiscardUnknown()
- func (m *CommandEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandEntry) XXX_Merge(src proto.Message)
- func (m *CommandEntry) XXX_Size() int
- func (m *CommandEntry) XXX_Unmarshal(b []byte) error
- type CommandRequest
- func (*CommandRequest) Descriptor() ([]byte, []int)
- func (this *CommandRequest) Equal(that interface{}) bool
- func (m *CommandRequest) GetValue() []byte
- func (m *CommandRequest) Marshal() (dAtA []byte, err error)
- func (m *CommandRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommandRequest) ProtoMessage()
- func (m *CommandRequest) Reset()
- func (m *CommandRequest) Size() (n int)
- func (m *CommandRequest) String() string
- func (m *CommandRequest) Unmarshal(dAtA []byte) error
- func (m *CommandRequest) XXX_DiscardUnknown()
- func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandRequest) XXX_Merge(src proto.Message)
- func (m *CommandRequest) XXX_Size() int
- func (m *CommandRequest) XXX_Unmarshal(b []byte) error
- type CommandResponse
- func (*CommandResponse) Descriptor() ([]byte, []int)
- func (this *CommandResponse) Equal(that interface{}) bool
- func (m *CommandResponse) GetError() ResponseError
- func (m *CommandResponse) GetLeader() MemberID
- func (m *CommandResponse) GetMembers() []MemberID
- func (m *CommandResponse) GetMessage() string
- func (m *CommandResponse) GetOutput() []byte
- func (m *CommandResponse) GetStatus() ResponseStatus
- func (m *CommandResponse) GetTerm() Term
- func (m *CommandResponse) Marshal() (dAtA []byte, err error)
- func (m *CommandResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommandResponse) ProtoMessage()
- func (m *CommandResponse) Reset()
- func (m *CommandResponse) Size() (n int)
- func (m *CommandResponse) String() string
- func (m *CommandResponse) Unmarshal(dAtA []byte) error
- func (m *CommandResponse) XXX_DiscardUnknown()
- func (m *CommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandResponse) XXX_Merge(src proto.Message)
- func (m *CommandResponse) XXX_Size() int
- func (m *CommandResponse) XXX_Unmarshal(b []byte) error
- type CommandStreamResponse
- type Configuration
- func (*Configuration) Descriptor() ([]byte, []int)
- func (this *Configuration) Equal(that interface{}) bool
- func (m *Configuration) GetIndex() Index
- func (m *Configuration) GetMembers() []*Member
- func (m *Configuration) GetTerm() Term
- func (m *Configuration) GetTimestamp() *time.Time
- func (m *Configuration) Marshal() (dAtA []byte, err error)
- func (m *Configuration) MarshalTo(dAtA []byte) (int, error)
- func (m *Configuration) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Configuration) ProtoMessage()
- func (m *Configuration) Reset()
- func (m *Configuration) Size() (n int)
- func (m *Configuration) String() string
- func (m *Configuration) Unmarshal(dAtA []byte) error
- func (m *Configuration) XXX_DiscardUnknown()
- func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Configuration) XXX_Merge(src proto.Message)
- func (m *Configuration) XXX_Size() int
- func (m *Configuration) XXX_Unmarshal(b []byte) error
- type ConfigurationEntry
- func (*ConfigurationEntry) Descriptor() ([]byte, []int)
- func (this *ConfigurationEntry) Equal(that interface{}) bool
- func (m *ConfigurationEntry) GetMembers() []*Member
- func (m *ConfigurationEntry) Marshal() (dAtA []byte, err error)
- func (m *ConfigurationEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *ConfigurationEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConfigurationEntry) ProtoMessage()
- func (m *ConfigurationEntry) Reset()
- func (m *ConfigurationEntry) Size() (n int)
- func (m *ConfigurationEntry) String() string
- func (m *ConfigurationEntry) Unmarshal(dAtA []byte) error
- func (m *ConfigurationEntry) XXX_DiscardUnknown()
- func (m *ConfigurationEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfigurationEntry) XXX_Merge(src proto.Message)
- func (m *ConfigurationEntry) XXX_Size() int
- func (m *ConfigurationEntry) XXX_Unmarshal(b []byte) error
- type ConfigureRequest
- func (*ConfigureRequest) Descriptor() ([]byte, []int)
- func (this *ConfigureRequest) Equal(that interface{}) bool
- func (m *ConfigureRequest) GetIndex() Index
- func (m *ConfigureRequest) GetLeader() MemberID
- func (m *ConfigureRequest) GetMembers() []*Member
- func (m *ConfigureRequest) GetTerm() Term
- func (m *ConfigureRequest) GetTimestamp() time.Time
- func (m *ConfigureRequest) Marshal() (dAtA []byte, err error)
- func (m *ConfigureRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ConfigureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConfigureRequest) ProtoMessage()
- func (m *ConfigureRequest) Reset()
- func (m *ConfigureRequest) Size() (n int)
- func (m *ConfigureRequest) String() string
- func (m *ConfigureRequest) Unmarshal(dAtA []byte) error
- func (m *ConfigureRequest) XXX_DiscardUnknown()
- func (m *ConfigureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfigureRequest) XXX_Merge(src proto.Message)
- func (m *ConfigureRequest) XXX_Size() int
- func (m *ConfigureRequest) XXX_Unmarshal(b []byte) error
- type ConfigureResponse
- func (*ConfigureResponse) Descriptor() ([]byte, []int)
- func (this *ConfigureResponse) Equal(that interface{}) bool
- func (m *ConfigureResponse) GetError() ResponseError
- func (m *ConfigureResponse) GetStatus() ResponseStatus
- func (m *ConfigureResponse) Marshal() (dAtA []byte, err error)
- func (m *ConfigureResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ConfigureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConfigureResponse) ProtoMessage()
- func (m *ConfigureResponse) Reset()
- func (m *ConfigureResponse) Size() (n int)
- func (m *ConfigureResponse) String() string
- func (m *ConfigureResponse) Unmarshal(dAtA []byte) error
- func (m *ConfigureResponse) XXX_DiscardUnknown()
- func (m *ConfigureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfigureResponse) XXX_Merge(src proto.Message)
- func (m *ConfigureResponse) XXX_Size() int
- func (m *ConfigureResponse) XXX_Unmarshal(b []byte) error
- type Event
- type EventType
- type Index
- type InitializeEntry
- func (*InitializeEntry) Descriptor() ([]byte, []int)
- func (this *InitializeEntry) Equal(that interface{}) bool
- func (m *InitializeEntry) Marshal() (dAtA []byte, err error)
- func (m *InitializeEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *InitializeEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InitializeEntry) ProtoMessage()
- func (m *InitializeEntry) Reset()
- func (m *InitializeEntry) Size() (n int)
- func (m *InitializeEntry) String() string
- func (m *InitializeEntry) Unmarshal(dAtA []byte) error
- func (m *InitializeEntry) XXX_DiscardUnknown()
- func (m *InitializeEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitializeEntry) XXX_Merge(src proto.Message)
- func (m *InitializeEntry) XXX_Size() int
- func (m *InitializeEntry) XXX_Unmarshal(b []byte) error
- type InstallRequest
- func (*InstallRequest) Descriptor() ([]byte, []int)
- func (this *InstallRequest) Equal(that interface{}) bool
- func (m *InstallRequest) GetData() []byte
- func (m *InstallRequest) GetIndex() Index
- func (m *InstallRequest) GetLeader() MemberID
- func (m *InstallRequest) GetTerm() Term
- func (m *InstallRequest) GetTimestamp() time.Time
- func (m *InstallRequest) Marshal() (dAtA []byte, err error)
- func (m *InstallRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *InstallRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InstallRequest) ProtoMessage()
- func (m *InstallRequest) Reset()
- func (m *InstallRequest) Size() (n int)
- func (m *InstallRequest) String() string
- func (m *InstallRequest) Unmarshal(dAtA []byte) error
- func (m *InstallRequest) XXX_DiscardUnknown()
- func (m *InstallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InstallRequest) XXX_Merge(src proto.Message)
- func (m *InstallRequest) XXX_Size() int
- func (m *InstallRequest) XXX_Unmarshal(b []byte) error
- type InstallResponse
- func (*InstallResponse) Descriptor() ([]byte, []int)
- func (this *InstallResponse) Equal(that interface{}) bool
- func (m *InstallResponse) GetError() ResponseError
- func (m *InstallResponse) GetStatus() ResponseStatus
- func (m *InstallResponse) Marshal() (dAtA []byte, err error)
- func (m *InstallResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *InstallResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InstallResponse) ProtoMessage()
- func (m *InstallResponse) Reset()
- func (m *InstallResponse) Size() (n int)
- func (m *InstallResponse) String() string
- func (m *InstallResponse) Unmarshal(dAtA []byte) error
- func (m *InstallResponse) XXX_DiscardUnknown()
- func (m *InstallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InstallResponse) XXX_Merge(src proto.Message)
- func (m *InstallResponse) XXX_Size() int
- func (m *InstallResponse) XXX_Unmarshal(b []byte) error
- type InstallStreamRequest
- type InstallStreamResponse
- type JoinRequest
- func (*JoinRequest) Descriptor() ([]byte, []int)
- func (this *JoinRequest) Equal(that interface{}) bool
- func (m *JoinRequest) GetMember() *Member
- func (m *JoinRequest) Marshal() (dAtA []byte, err error)
- func (m *JoinRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JoinRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JoinRequest) ProtoMessage()
- func (m *JoinRequest) Reset()
- func (m *JoinRequest) Size() (n int)
- func (m *JoinRequest) String() string
- func (m *JoinRequest) Unmarshal(dAtA []byte) error
- func (m *JoinRequest) XXX_DiscardUnknown()
- func (m *JoinRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JoinRequest) XXX_Merge(src proto.Message)
- func (m *JoinRequest) XXX_Size() int
- func (m *JoinRequest) XXX_Unmarshal(b []byte) error
- type JoinResponse
- func (*JoinResponse) Descriptor() ([]byte, []int)
- func (this *JoinResponse) Equal(that interface{}) bool
- func (m *JoinResponse) GetError() ResponseError
- func (m *JoinResponse) GetIndex() Index
- func (m *JoinResponse) GetMembers() []*Member
- func (m *JoinResponse) GetStatus() ResponseStatus
- func (m *JoinResponse) GetTerm() Term
- func (m *JoinResponse) GetTimestamp() time.Time
- func (m *JoinResponse) Marshal() (dAtA []byte, err error)
- func (m *JoinResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *JoinResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JoinResponse) ProtoMessage()
- func (m *JoinResponse) Reset()
- func (m *JoinResponse) Size() (n int)
- func (m *JoinResponse) String() string
- func (m *JoinResponse) Unmarshal(dAtA []byte) error
- func (m *JoinResponse) XXX_DiscardUnknown()
- func (m *JoinResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JoinResponse) XXX_Merge(src proto.Message)
- func (m *JoinResponse) XXX_Size() int
- func (m *JoinResponse) XXX_Unmarshal(b []byte) error
- type LeaveRequest
- func (*LeaveRequest) Descriptor() ([]byte, []int)
- func (this *LeaveRequest) Equal(that interface{}) bool
- func (m *LeaveRequest) GetMember() *Member
- func (m *LeaveRequest) Marshal() (dAtA []byte, err error)
- func (m *LeaveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LeaveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeaveRequest) ProtoMessage()
- func (m *LeaveRequest) Reset()
- func (m *LeaveRequest) Size() (n int)
- func (m *LeaveRequest) String() string
- func (m *LeaveRequest) Unmarshal(dAtA []byte) error
- func (m *LeaveRequest) XXX_DiscardUnknown()
- func (m *LeaveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LeaveRequest) XXX_Merge(src proto.Message)
- func (m *LeaveRequest) XXX_Size() int
- func (m *LeaveRequest) XXX_Unmarshal(b []byte) error
- type LeaveResponse
- func (*LeaveResponse) Descriptor() ([]byte, []int)
- func (this *LeaveResponse) Equal(that interface{}) bool
- func (m *LeaveResponse) GetError() ResponseError
- func (m *LeaveResponse) GetIndex() Index
- func (m *LeaveResponse) GetMembers() []*Member
- func (m *LeaveResponse) GetStatus() ResponseStatus
- func (m *LeaveResponse) GetTerm() Term
- func (m *LeaveResponse) GetTimestamp() time.Time
- func (m *LeaveResponse) Marshal() (dAtA []byte, err error)
- func (m *LeaveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *LeaveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeaveResponse) ProtoMessage()
- func (m *LeaveResponse) Reset()
- func (m *LeaveResponse) Size() (n int)
- func (m *LeaveResponse) String() string
- func (m *LeaveResponse) Unmarshal(dAtA []byte) error
- func (m *LeaveResponse) XXX_DiscardUnknown()
- func (m *LeaveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LeaveResponse) XXX_Merge(src proto.Message)
- func (m *LeaveResponse) XXX_Size() int
- func (m *LeaveResponse) XXX_Unmarshal(b []byte) error
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)
- func (this *LogEntry) Equal(that interface{}) bool
- func (m *LogEntry) GetCommand() *CommandEntry
- func (m *LogEntry) GetConfiguration() *ConfigurationEntry
- func (m *LogEntry) GetEntry() isLogEntry_Entry
- func (m *LogEntry) GetInitialize() *InitializeEntry
- func (m *LogEntry) GetQuery() *QueryEntry
- func (m *LogEntry) GetTerm() Term
- func (m *LogEntry) GetTimestamp() time.Time
- func (m *LogEntry) Marshal() (dAtA []byte, err error)
- func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogEntry) ProtoMessage()
- func (m *LogEntry) Reset()
- func (m *LogEntry) Size() (n int)
- func (m *LogEntry) String() string
- func (m *LogEntry) Unmarshal(dAtA []byte) error
- func (m *LogEntry) XXX_DiscardUnknown()
- func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogEntry) XXX_Merge(src proto.Message)
- func (*LogEntry) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *LogEntry) XXX_Size() int
- func (m *LogEntry) XXX_Unmarshal(b []byte) error
- type LogEntry_Command
- type LogEntry_Configuration
- type LogEntry_Initialize
- type LogEntry_Query
- type Member
- func (*Member) Descriptor() ([]byte, []int)
- func (this *Member) Equal(that interface{}) bool
- func (m *Member) GetMemberID() MemberID
- func (m *Member) GetType() Member_Type
- func (m *Member) GetUpdated() time.Time
- func (m *Member) Marshal() (dAtA []byte, err error)
- func (m *Member) MarshalTo(dAtA []byte) (int, error)
- func (m *Member) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Member) ProtoMessage()
- func (m *Member) Reset()
- func (m *Member) Size() (n int)
- func (m *Member) String() string
- func (m *Member) Unmarshal(dAtA []byte) error
- func (m *Member) XXX_DiscardUnknown()
- func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Member) XXX_Merge(src proto.Message)
- func (m *Member) XXX_Size() int
- func (m *Member) XXX_Unmarshal(b []byte) error
- type MemberID
- type Member_Type
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)
- func (this *Metadata) Equal(that interface{}) bool
- func (m *Metadata) GetTerm() Term
- func (m *Metadata) GetVote() MemberID
- func (m *Metadata) Marshal() (dAtA []byte, err error)
- func (m *Metadata) MarshalTo(dAtA []byte) (int, error)
- func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Metadata) ProtoMessage()
- func (m *Metadata) Reset()
- func (m *Metadata) Size() (n int)
- func (m *Metadata) String() string
- func (m *Metadata) Unmarshal(dAtA []byte) error
- func (m *Metadata) XXX_DiscardUnknown()
- func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Metadata) XXX_Merge(src proto.Message)
- func (m *Metadata) XXX_Size() int
- func (m *Metadata) XXX_Unmarshal(b []byte) error
- type MetadataStore
- type PollRequest
- func (*PollRequest) Descriptor() ([]byte, []int)
- func (this *PollRequest) Equal(that interface{}) bool
- func (m *PollRequest) GetCandidate() MemberID
- func (m *PollRequest) GetLastLogIndex() Index
- func (m *PollRequest) GetLastLogTerm() Term
- func (m *PollRequest) GetTerm() Term
- func (m *PollRequest) Marshal() (dAtA []byte, err error)
- func (m *PollRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PollRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PollRequest) ProtoMessage()
- func (m *PollRequest) Reset()
- func (m *PollRequest) Size() (n int)
- func (m *PollRequest) String() string
- func (m *PollRequest) Unmarshal(dAtA []byte) error
- func (m *PollRequest) XXX_DiscardUnknown()
- func (m *PollRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PollRequest) XXX_Merge(src proto.Message)
- func (m *PollRequest) XXX_Size() int
- func (m *PollRequest) XXX_Unmarshal(b []byte) error
- type PollResponse
- func (*PollResponse) Descriptor() ([]byte, []int)
- func (this *PollResponse) Equal(that interface{}) bool
- func (m *PollResponse) GetAccepted() bool
- func (m *PollResponse) GetError() ResponseError
- func (m *PollResponse) GetStatus() ResponseStatus
- func (m *PollResponse) GetTerm() Term
- func (m *PollResponse) Marshal() (dAtA []byte, err error)
- func (m *PollResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PollResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PollResponse) ProtoMessage()
- func (m *PollResponse) Reset()
- func (m *PollResponse) Size() (n int)
- func (m *PollResponse) String() string
- func (m *PollResponse) Unmarshal(dAtA []byte) error
- func (m *PollResponse) XXX_DiscardUnknown()
- func (m *PollResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PollResponse) XXX_Merge(src proto.Message)
- func (m *PollResponse) XXX_Size() int
- func (m *PollResponse) XXX_Unmarshal(b []byte) error
- type QueryEntry
- func (*QueryEntry) Descriptor() ([]byte, []int)
- func (this *QueryEntry) Equal(that interface{}) bool
- func (m *QueryEntry) GetValue() []byte
- func (m *QueryEntry) Marshal() (dAtA []byte, err error)
- func (m *QueryEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryEntry) ProtoMessage()
- func (m *QueryEntry) Reset()
- func (m *QueryEntry) Size() (n int)
- func (m *QueryEntry) String() string
- func (m *QueryEntry) Unmarshal(dAtA []byte) error
- func (m *QueryEntry) XXX_DiscardUnknown()
- func (m *QueryEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryEntry) XXX_Merge(src proto.Message)
- func (m *QueryEntry) XXX_Size() int
- func (m *QueryEntry) XXX_Unmarshal(b []byte) error
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)
- func (this *QueryRequest) Equal(that interface{}) bool
- func (m *QueryRequest) GetReadConsistency() ReadConsistency
- func (m *QueryRequest) GetValue() []byte
- func (m *QueryRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryRequest) ProtoMessage()
- func (m *QueryRequest) Reset()
- func (m *QueryRequest) Size() (n int)
- func (m *QueryRequest) String() string
- func (m *QueryRequest) Unmarshal(dAtA []byte) error
- func (m *QueryRequest) XXX_DiscardUnknown()
- func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryRequest) XXX_Merge(src proto.Message)
- func (m *QueryRequest) XXX_Size() int
- func (m *QueryRequest) XXX_Unmarshal(b []byte) error
- type QueryResponse
- func (*QueryResponse) Descriptor() ([]byte, []int)
- func (this *QueryResponse) Equal(that interface{}) bool
- func (m *QueryResponse) GetError() ResponseError
- func (m *QueryResponse) GetMessage() string
- func (m *QueryResponse) GetOutput() []byte
- func (m *QueryResponse) GetStatus() ResponseStatus
- func (m *QueryResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryResponse) ProtoMessage()
- func (m *QueryResponse) Reset()
- func (m *QueryResponse) Size() (n int)
- func (m *QueryResponse) String() string
- func (m *QueryResponse) Unmarshal(dAtA []byte) error
- func (m *QueryResponse) XXX_DiscardUnknown()
- func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryResponse) XXX_Merge(src proto.Message)
- func (m *QueryResponse) XXX_Size() int
- func (m *QueryResponse) XXX_Unmarshal(b []byte) error
- type QueryStreamResponse
- type Raft
- type RaftServiceClient
- type RaftServiceServer
- type RaftService_CommandClient
- type RaftService_CommandServer
- type RaftService_InstallClient
- type RaftService_InstallServer
- type RaftService_QueryClient
- type RaftService_QueryServer
- type ReadConsistency
- type ReconfigureRequest
- func (*ReconfigureRequest) Descriptor() ([]byte, []int)
- func (this *ReconfigureRequest) Equal(that interface{}) bool
- func (m *ReconfigureRequest) GetIndex() Index
- func (m *ReconfigureRequest) GetMember() *Member
- func (m *ReconfigureRequest) GetTerm() Term
- func (m *ReconfigureRequest) Marshal() (dAtA []byte, err error)
- func (m *ReconfigureRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReconfigureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReconfigureRequest) ProtoMessage()
- func (m *ReconfigureRequest) Reset()
- func (m *ReconfigureRequest) Size() (n int)
- func (m *ReconfigureRequest) String() string
- func (m *ReconfigureRequest) Unmarshal(dAtA []byte) error
- func (m *ReconfigureRequest) XXX_DiscardUnknown()
- func (m *ReconfigureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReconfigureRequest) XXX_Merge(src proto.Message)
- func (m *ReconfigureRequest) XXX_Size() int
- func (m *ReconfigureRequest) XXX_Unmarshal(b []byte) error
- type ReconfigureResponse
- func (*ReconfigureResponse) Descriptor() ([]byte, []int)
- func (this *ReconfigureResponse) Equal(that interface{}) bool
- func (m *ReconfigureResponse) GetError() ResponseError
- func (m *ReconfigureResponse) GetIndex() Index
- func (m *ReconfigureResponse) GetMembers() []*Member
- func (m *ReconfigureResponse) GetStatus() ResponseStatus
- func (m *ReconfigureResponse) GetTerm() Term
- func (m *ReconfigureResponse) GetTimestamp() time.Time
- func (m *ReconfigureResponse) Marshal() (dAtA []byte, err error)
- func (m *ReconfigureResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReconfigureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReconfigureResponse) ProtoMessage()
- func (m *ReconfigureResponse) Reset()
- func (m *ReconfigureResponse) Size() (n int)
- func (m *ReconfigureResponse) String() string
- func (m *ReconfigureResponse) Unmarshal(dAtA []byte) error
- func (m *ReconfigureResponse) XXX_DiscardUnknown()
- func (m *ReconfigureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReconfigureResponse) XXX_Merge(src proto.Message)
- func (m *ReconfigureResponse) XXX_Size() int
- func (m *ReconfigureResponse) XXX_Unmarshal(b []byte) error
- type ResponseError
- type ResponseStatus
- type Role
- type RoleType
- type Server
- type Status
- type StreamMessage
- type Term
- type TransferRequest
- func (*TransferRequest) Descriptor() ([]byte, []int)
- func (this *TransferRequest) Equal(that interface{}) bool
- func (m *TransferRequest) GetMember() MemberID
- func (m *TransferRequest) Marshal() (dAtA []byte, err error)
- func (m *TransferRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *TransferRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TransferRequest) ProtoMessage()
- func (m *TransferRequest) Reset()
- func (m *TransferRequest) Size() (n int)
- func (m *TransferRequest) String() string
- func (m *TransferRequest) Unmarshal(dAtA []byte) error
- func (m *TransferRequest) XXX_DiscardUnknown()
- func (m *TransferRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransferRequest) XXX_Merge(src proto.Message)
- func (m *TransferRequest) XXX_Size() int
- func (m *TransferRequest) XXX_Unmarshal(b []byte) error
- type TransferResponse
- func (*TransferResponse) Descriptor() ([]byte, []int)
- func (this *TransferResponse) Equal(that interface{}) bool
- func (m *TransferResponse) GetError() ResponseError
- func (m *TransferResponse) GetStatus() ResponseStatus
- func (m *TransferResponse) Marshal() (dAtA []byte, err error)
- func (m *TransferResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *TransferResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TransferResponse) ProtoMessage()
- func (m *TransferResponse) Reset()
- func (m *TransferResponse) Size() (n int)
- func (m *TransferResponse) String() string
- func (m *TransferResponse) Unmarshal(dAtA []byte) error
- func (m *TransferResponse) XXX_DiscardUnknown()
- func (m *TransferResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransferResponse) XXX_Merge(src proto.Message)
- func (m *TransferResponse) XXX_Size() int
- func (m *TransferResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedRaftServiceServer
- func (*UnimplementedRaftServiceServer) Append(ctx context.Context, req *AppendRequest) (*AppendResponse, error)
- func (*UnimplementedRaftServiceServer) Command(req *CommandRequest, srv RaftService_CommandServer) error
- func (*UnimplementedRaftServiceServer) Configure(ctx context.Context, req *ConfigureRequest) (*ConfigureResponse, error)
- func (*UnimplementedRaftServiceServer) Install(srv RaftService_InstallServer) error
- func (*UnimplementedRaftServiceServer) Join(ctx context.Context, req *JoinRequest) (*JoinResponse, error)
- func (*UnimplementedRaftServiceServer) Leave(ctx context.Context, req *LeaveRequest) (*LeaveResponse, error)
- func (*UnimplementedRaftServiceServer) Poll(ctx context.Context, req *PollRequest) (*PollResponse, error)
- func (*UnimplementedRaftServiceServer) Query(req *QueryRequest, srv RaftService_QueryServer) error
- func (*UnimplementedRaftServiceServer) Reconfigure(ctx context.Context, req *ReconfigureRequest) (*ReconfigureResponse, error)
- func (*UnimplementedRaftServiceServer) Transfer(ctx context.Context, req *TransferRequest) (*TransferResponse, error)
- func (*UnimplementedRaftServiceServer) Vote(ctx context.Context, req *VoteRequest) (*VoteResponse, error)
- type VoteRequest
- func (*VoteRequest) Descriptor() ([]byte, []int)
- func (this *VoteRequest) Equal(that interface{}) bool
- func (m *VoteRequest) GetCandidate() MemberID
- func (m *VoteRequest) GetLastLogIndex() Index
- func (m *VoteRequest) GetLastLogTerm() Term
- func (m *VoteRequest) GetTerm() Term
- func (m *VoteRequest) Marshal() (dAtA []byte, err error)
- func (m *VoteRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *VoteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VoteRequest) ProtoMessage()
- func (m *VoteRequest) Reset()
- func (m *VoteRequest) Size() (n int)
- func (m *VoteRequest) String() string
- func (m *VoteRequest) Unmarshal(dAtA []byte) error
- func (m *VoteRequest) XXX_DiscardUnknown()
- func (m *VoteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VoteRequest) XXX_Merge(src proto.Message)
- func (m *VoteRequest) XXX_Size() int
- func (m *VoteRequest) XXX_Unmarshal(b []byte) error
- type VoteResponse
- func (*VoteResponse) Descriptor() ([]byte, []int)
- func (this *VoteResponse) Equal(that interface{}) bool
- func (m *VoteResponse) GetError() ResponseError
- func (m *VoteResponse) GetStatus() ResponseStatus
- func (m *VoteResponse) GetTerm() Term
- func (m *VoteResponse) GetVoted() bool
- func (m *VoteResponse) Marshal() (dAtA []byte, err error)
- func (m *VoteResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *VoteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VoteResponse) ProtoMessage()
- func (m *VoteResponse) Reset()
- func (m *VoteResponse) Size() (n int)
- func (m *VoteResponse) String() string
- func (m *VoteResponse) Unmarshal(dAtA []byte) error
- func (m *VoteResponse) XXX_DiscardUnknown()
- func (m *VoteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VoteResponse) XXX_Merge(src proto.Message)
- func (m *VoteResponse) XXX_Size() int
- func (m *VoteResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthCluster = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCluster = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthLog = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowLog = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMetadata = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthProtocol = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowProtocol = fmt.Errorf("proto: integer overflow") )
var Member_Type_name = map[int32]string{
0: "INACTIVE",
1: "PASSIVE",
2: "PROMOTABLE",
3: "ACTIVE",
}
var Member_Type_value = map[string]int32{
"INACTIVE": 0,
"PASSIVE": 1,
"PROMOTABLE": 2,
"ACTIVE": 3,
}
var ReadConsistency_name = map[int32]string{
0: "SEQUENTIAL",
1: "LINEARIZABLE_LEASE",
2: "LINEARIZABLE",
}
var ReadConsistency_value = map[string]int32{
"SEQUENTIAL": 0,
"LINEARIZABLE_LEASE": 1,
"LINEARIZABLE": 2,
}
var ResponseError_name = map[int32]string{
0: "NO_LEADER",
1: "QUERY_FAILURE",
2: "COMMAND_FAILURE",
3: "APPLICATION_ERROR",
4: "ILLEGAL_MEMBER_STATE",
5: "UNKNOWN_CLIENT",
6: "UNKNOWN_SESSION",
7: "UNKNOWN_SERVICE",
8: "CLOSED_SESSION",
9: "PROTOCOL_ERROR",
10: "CONFIGURATION_ERROR",
11: "UNAVAILABLE",
}
var ResponseError_value = map[string]int32{
"NO_LEADER": 0,
"QUERY_FAILURE": 1,
"COMMAND_FAILURE": 2,
"APPLICATION_ERROR": 3,
"ILLEGAL_MEMBER_STATE": 4,
"UNKNOWN_CLIENT": 5,
"UNKNOWN_SESSION": 6,
"UNKNOWN_SERVICE": 7,
"CLOSED_SESSION": 8,
"PROTOCOL_ERROR": 9,
"CONFIGURATION_ERROR": 10,
"UNAVAILABLE": 11,
}
var ResponseStatus_name = map[int32]string{
0: "OK",
1: "ERROR",
}
var ResponseStatus_value = map[string]int32{
"OK": 0,
"ERROR": 1,
}
Functions ¶
func RegisterRaftServiceServer ¶
func RegisterRaftServiceServer(s *grpc.Server, srv RaftServiceServer)
Types ¶
type AppendRequest ¶
type AppendRequest struct { Term Term `protobuf:"varint,1,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Leader MemberID `protobuf:"bytes,2,opt,name=leader,proto3,casttype=MemberID" json:"leader,omitempty"` PrevLogIndex Index `protobuf:"varint,3,opt,name=prev_log_index,json=prevLogIndex,proto3,casttype=Index" json:"prev_log_index,omitempty"` PrevLogTerm Term `protobuf:"varint,4,opt,name=prev_log_term,json=prevLogTerm,proto3,casttype=Term" json:"prev_log_term,omitempty"` Entries []*LogEntry `protobuf:"bytes,5,rep,name=entries,proto3" json:"entries,omitempty"` CommitIndex Index `protobuf:"varint,6,opt,name=commit_index,json=commitIndex,proto3,casttype=Index" json:"commit_index,omitempty"` }
func NewPopulatedAppendRequest ¶
func NewPopulatedAppendRequest(r randyProtocol, easy bool) *AppendRequest
func (*AppendRequest) Descriptor ¶
func (*AppendRequest) Descriptor() ([]byte, []int)
func (*AppendRequest) Equal ¶
func (this *AppendRequest) Equal(that interface{}) bool
func (*AppendRequest) GetCommitIndex ¶
func (m *AppendRequest) GetCommitIndex() Index
func (*AppendRequest) GetEntries ¶
func (m *AppendRequest) GetEntries() []*LogEntry
func (*AppendRequest) GetLeader ¶
func (m *AppendRequest) GetLeader() MemberID
func (*AppendRequest) GetPrevLogIndex ¶
func (m *AppendRequest) GetPrevLogIndex() Index
func (*AppendRequest) GetPrevLogTerm ¶
func (m *AppendRequest) GetPrevLogTerm() Term
func (*AppendRequest) GetTerm ¶
func (m *AppendRequest) GetTerm() Term
func (*AppendRequest) Marshal ¶
func (m *AppendRequest) Marshal() (dAtA []byte, err error)
func (*AppendRequest) MarshalToSizedBuffer ¶
func (m *AppendRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AppendRequest) ProtoMessage ¶
func (*AppendRequest) ProtoMessage()
func (*AppendRequest) Reset ¶
func (m *AppendRequest) Reset()
func (*AppendRequest) Size ¶
func (m *AppendRequest) Size() (n int)
func (*AppendRequest) String ¶
func (m *AppendRequest) String() string
func (*AppendRequest) Unmarshal ¶
func (m *AppendRequest) Unmarshal(dAtA []byte) error
func (*AppendRequest) XXX_DiscardUnknown ¶
func (m *AppendRequest) XXX_DiscardUnknown()
func (*AppendRequest) XXX_Marshal ¶
func (m *AppendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AppendRequest) XXX_Merge ¶
func (m *AppendRequest) XXX_Merge(src proto.Message)
func (*AppendRequest) XXX_Size ¶
func (m *AppendRequest) XXX_Size() int
func (*AppendRequest) XXX_Unmarshal ¶
func (m *AppendRequest) XXX_Unmarshal(b []byte) error
type AppendResponse ¶
type AppendResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` Term Term `protobuf:"varint,3,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Succeeded bool `protobuf:"varint,4,opt,name=succeeded,proto3" json:"succeeded,omitempty"` LastLogIndex Index `protobuf:"varint,5,opt,name=last_log_index,json=lastLogIndex,proto3,casttype=Index" json:"last_log_index,omitempty"` }
func NewPopulatedAppendResponse ¶
func NewPopulatedAppendResponse(r randyProtocol, easy bool) *AppendResponse
func (*AppendResponse) Descriptor ¶
func (*AppendResponse) Descriptor() ([]byte, []int)
func (*AppendResponse) Equal ¶
func (this *AppendResponse) Equal(that interface{}) bool
func (*AppendResponse) GetError ¶
func (m *AppendResponse) GetError() ResponseError
func (*AppendResponse) GetLastLogIndex ¶
func (m *AppendResponse) GetLastLogIndex() Index
func (*AppendResponse) GetStatus ¶
func (m *AppendResponse) GetStatus() ResponseStatus
func (*AppendResponse) GetSucceeded ¶
func (m *AppendResponse) GetSucceeded() bool
func (*AppendResponse) GetTerm ¶
func (m *AppendResponse) GetTerm() Term
func (*AppendResponse) Marshal ¶
func (m *AppendResponse) Marshal() (dAtA []byte, err error)
func (*AppendResponse) MarshalToSizedBuffer ¶
func (m *AppendResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AppendResponse) ProtoMessage ¶
func (*AppendResponse) ProtoMessage()
func (*AppendResponse) Reset ¶
func (m *AppendResponse) Reset()
func (*AppendResponse) Size ¶
func (m *AppendResponse) Size() (n int)
func (*AppendResponse) String ¶
func (m *AppendResponse) String() string
func (*AppendResponse) Unmarshal ¶
func (m *AppendResponse) Unmarshal(dAtA []byte) error
func (*AppendResponse) XXX_DiscardUnknown ¶
func (m *AppendResponse) XXX_DiscardUnknown()
func (*AppendResponse) XXX_Marshal ¶
func (m *AppendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AppendResponse) XXX_Merge ¶
func (m *AppendResponse) XXX_Merge(src proto.Message)
func (*AppendResponse) XXX_Size ¶
func (m *AppendResponse) XXX_Size() int
func (*AppendResponse) XXX_Unmarshal ¶
func (m *AppendResponse) XXX_Unmarshal(b []byte) error
type Client ¶
type Client interface { // Join sends a join request Join(ctx context.Context, request *JoinRequest, member MemberID) (*JoinResponse, error) // Leave sends a leave request Leave(ctx context.Context, request *LeaveRequest, member MemberID) (*LeaveResponse, error) // Configure sends a configure request Configure(ctx context.Context, request *ConfigureRequest, member MemberID) (*ConfigureResponse, error) // Reconfigure sends a reconfigure request Reconfigure(ctx context.Context, request *ReconfigureRequest, member MemberID) (*ReconfigureResponse, error) // Poll sends a poll request Poll(ctx context.Context, request *PollRequest, member MemberID) (*PollResponse, error) // Vote sends a vote request Vote(ctx context.Context, request *VoteRequest, member MemberID) (*VoteResponse, error) // Transfer sends a leadership transfer request Transfer(ctx context.Context, request *TransferRequest, member MemberID) (*TransferResponse, error) // Append sends an append request Append(ctx context.Context, request *AppendRequest, member MemberID) (*AppendResponse, error) // Install sends a stream of install requests Install(ctx context.Context, member MemberID) (chan<- *InstallRequest, <-chan *InstallStreamResponse, error) // Command sends a command request Command(ctx context.Context, request *CommandRequest, member MemberID) (<-chan *CommandStreamResponse, error) // Query sends a query request Query(ctx context.Context, request *QueryRequest, member MemberID) (<-chan *QueryStreamResponse, error) }
Client is an interface for sending messages to Raft nodes
type Cluster ¶
type Cluster interface { // Member returns the local member ID Member() MemberID // Members returns a list of all members in the Raft cluster Members() []MemberID // GetMember returns a Member by ID GetMember(memberID MemberID) *Member // GetClient gets a RaftServiceClient connection for the given member GetClient(memberID MemberID) (RaftServiceClient, error) }
Cluster provides cluster information for the Raft protocol
func NewCluster ¶
NewCluster returns a new Cluster with the given configuration
type CommandEntry ¶
type CommandEntry struct {
Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
func NewPopulatedCommandEntry ¶
func NewPopulatedCommandEntry(r randyLog, easy bool) *CommandEntry
func (*CommandEntry) Descriptor ¶
func (*CommandEntry) Descriptor() ([]byte, []int)
func (*CommandEntry) Equal ¶
func (this *CommandEntry) Equal(that interface{}) bool
func (*CommandEntry) GetValue ¶
func (m *CommandEntry) GetValue() []byte
func (*CommandEntry) Marshal ¶
func (m *CommandEntry) Marshal() (dAtA []byte, err error)
func (*CommandEntry) MarshalToSizedBuffer ¶
func (m *CommandEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommandEntry) ProtoMessage ¶
func (*CommandEntry) ProtoMessage()
func (*CommandEntry) Reset ¶
func (m *CommandEntry) Reset()
func (*CommandEntry) Size ¶
func (m *CommandEntry) Size() (n int)
func (*CommandEntry) String ¶
func (m *CommandEntry) String() string
func (*CommandEntry) Unmarshal ¶
func (m *CommandEntry) Unmarshal(dAtA []byte) error
func (*CommandEntry) XXX_DiscardUnknown ¶
func (m *CommandEntry) XXX_DiscardUnknown()
func (*CommandEntry) XXX_Marshal ¶
func (m *CommandEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandEntry) XXX_Merge ¶
func (m *CommandEntry) XXX_Merge(src proto.Message)
func (*CommandEntry) XXX_Size ¶
func (m *CommandEntry) XXX_Size() int
func (*CommandEntry) XXX_Unmarshal ¶
func (m *CommandEntry) XXX_Unmarshal(b []byte) error
type CommandRequest ¶
type CommandRequest struct {
Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
func NewPopulatedCommandRequest ¶
func NewPopulatedCommandRequest(r randyProtocol, easy bool) *CommandRequest
func (*CommandRequest) Descriptor ¶
func (*CommandRequest) Descriptor() ([]byte, []int)
func (*CommandRequest) Equal ¶
func (this *CommandRequest) Equal(that interface{}) bool
func (*CommandRequest) GetValue ¶
func (m *CommandRequest) GetValue() []byte
func (*CommandRequest) Marshal ¶
func (m *CommandRequest) Marshal() (dAtA []byte, err error)
func (*CommandRequest) MarshalToSizedBuffer ¶
func (m *CommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommandRequest) ProtoMessage ¶
func (*CommandRequest) ProtoMessage()
func (*CommandRequest) Reset ¶
func (m *CommandRequest) Reset()
func (*CommandRequest) Size ¶
func (m *CommandRequest) Size() (n int)
func (*CommandRequest) String ¶
func (m *CommandRequest) String() string
func (*CommandRequest) Unmarshal ¶
func (m *CommandRequest) Unmarshal(dAtA []byte) error
func (*CommandRequest) XXX_DiscardUnknown ¶
func (m *CommandRequest) XXX_DiscardUnknown()
func (*CommandRequest) XXX_Marshal ¶
func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandRequest) XXX_Merge ¶
func (m *CommandRequest) XXX_Merge(src proto.Message)
func (*CommandRequest) XXX_Size ¶
func (m *CommandRequest) XXX_Size() int
func (*CommandRequest) XXX_Unmarshal ¶
func (m *CommandRequest) XXX_Unmarshal(b []byte) error
type CommandResponse ¶
type CommandResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` Leader MemberID `protobuf:"bytes,4,opt,name=leader,proto3,casttype=MemberID" json:"leader,omitempty"` Term Term `protobuf:"varint,5,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Members []MemberID `protobuf:"bytes,6,rep,name=members,proto3,casttype=MemberID" json:"members,omitempty"` Output []byte `protobuf:"bytes,7,opt,name=output,proto3" json:"output,omitempty"` }
func NewPopulatedCommandResponse ¶
func NewPopulatedCommandResponse(r randyProtocol, easy bool) *CommandResponse
func (*CommandResponse) Descriptor ¶
func (*CommandResponse) Descriptor() ([]byte, []int)
func (*CommandResponse) Equal ¶
func (this *CommandResponse) Equal(that interface{}) bool
func (*CommandResponse) GetError ¶
func (m *CommandResponse) GetError() ResponseError
func (*CommandResponse) GetLeader ¶
func (m *CommandResponse) GetLeader() MemberID
func (*CommandResponse) GetMembers ¶
func (m *CommandResponse) GetMembers() []MemberID
func (*CommandResponse) GetMessage ¶
func (m *CommandResponse) GetMessage() string
func (*CommandResponse) GetOutput ¶
func (m *CommandResponse) GetOutput() []byte
func (*CommandResponse) GetStatus ¶
func (m *CommandResponse) GetStatus() ResponseStatus
func (*CommandResponse) GetTerm ¶
func (m *CommandResponse) GetTerm() Term
func (*CommandResponse) Marshal ¶
func (m *CommandResponse) Marshal() (dAtA []byte, err error)
func (*CommandResponse) MarshalToSizedBuffer ¶
func (m *CommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommandResponse) ProtoMessage ¶
func (*CommandResponse) ProtoMessage()
func (*CommandResponse) Reset ¶
func (m *CommandResponse) Reset()
func (*CommandResponse) Size ¶
func (m *CommandResponse) Size() (n int)
func (*CommandResponse) String ¶
func (m *CommandResponse) String() string
func (*CommandResponse) Unmarshal ¶
func (m *CommandResponse) Unmarshal(dAtA []byte) error
func (*CommandResponse) XXX_DiscardUnknown ¶
func (m *CommandResponse) XXX_DiscardUnknown()
func (*CommandResponse) XXX_Marshal ¶
func (m *CommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandResponse) XXX_Merge ¶
func (m *CommandResponse) XXX_Merge(src proto.Message)
func (*CommandResponse) XXX_Size ¶
func (m *CommandResponse) XXX_Size() int
func (*CommandResponse) XXX_Unmarshal ¶
func (m *CommandResponse) XXX_Unmarshal(b []byte) error
type CommandStreamResponse ¶
type CommandStreamResponse struct { *StreamMessage Response *CommandResponse }
CommandStreamResponse is a stream response for CommandRequest
func NewCommandStreamResponse ¶
func NewCommandStreamResponse(response *CommandResponse, err error) *CommandStreamResponse
NewCommandStreamResponse returns a new CommandStreamResponse with the given response and error
type Configuration ¶
type Configuration struct { Index Index `protobuf:"varint,1,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Term Term `protobuf:"varint,2,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Timestamp *time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp,omitempty"` Members []*Member `protobuf:"bytes,4,rep,name=members,proto3" json:"members,omitempty"` }
Raft system configuration
func NewPopulatedConfiguration ¶
func NewPopulatedConfiguration(r randyMetadata, easy bool) *Configuration
func (*Configuration) Descriptor ¶
func (*Configuration) Descriptor() ([]byte, []int)
func (*Configuration) Equal ¶
func (this *Configuration) Equal(that interface{}) bool
func (*Configuration) GetIndex ¶
func (m *Configuration) GetIndex() Index
func (*Configuration) GetMembers ¶
func (m *Configuration) GetMembers() []*Member
func (*Configuration) GetTerm ¶
func (m *Configuration) GetTerm() Term
func (*Configuration) GetTimestamp ¶
func (m *Configuration) GetTimestamp() *time.Time
func (*Configuration) Marshal ¶
func (m *Configuration) Marshal() (dAtA []byte, err error)
func (*Configuration) MarshalToSizedBuffer ¶
func (m *Configuration) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Configuration) ProtoMessage ¶
func (*Configuration) ProtoMessage()
func (*Configuration) Reset ¶
func (m *Configuration) Reset()
func (*Configuration) Size ¶
func (m *Configuration) Size() (n int)
func (*Configuration) String ¶
func (m *Configuration) String() string
func (*Configuration) Unmarshal ¶
func (m *Configuration) Unmarshal(dAtA []byte) error
func (*Configuration) XXX_DiscardUnknown ¶
func (m *Configuration) XXX_DiscardUnknown()
func (*Configuration) XXX_Marshal ¶
func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Configuration) XXX_Merge ¶
func (m *Configuration) XXX_Merge(src proto.Message)
func (*Configuration) XXX_Size ¶
func (m *Configuration) XXX_Size() int
func (*Configuration) XXX_Unmarshal ¶
func (m *Configuration) XXX_Unmarshal(b []byte) error
type ConfigurationEntry ¶
type ConfigurationEntry struct {
Members []*Member `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
}
func NewPopulatedConfigurationEntry ¶
func NewPopulatedConfigurationEntry(r randyLog, easy bool) *ConfigurationEntry
func (*ConfigurationEntry) Descriptor ¶
func (*ConfigurationEntry) Descriptor() ([]byte, []int)
func (*ConfigurationEntry) Equal ¶
func (this *ConfigurationEntry) Equal(that interface{}) bool
func (*ConfigurationEntry) GetMembers ¶
func (m *ConfigurationEntry) GetMembers() []*Member
func (*ConfigurationEntry) Marshal ¶
func (m *ConfigurationEntry) Marshal() (dAtA []byte, err error)
func (*ConfigurationEntry) MarshalTo ¶
func (m *ConfigurationEntry) MarshalTo(dAtA []byte) (int, error)
func (*ConfigurationEntry) MarshalToSizedBuffer ¶
func (m *ConfigurationEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConfigurationEntry) ProtoMessage ¶
func (*ConfigurationEntry) ProtoMessage()
func (*ConfigurationEntry) Reset ¶
func (m *ConfigurationEntry) Reset()
func (*ConfigurationEntry) Size ¶
func (m *ConfigurationEntry) Size() (n int)
func (*ConfigurationEntry) String ¶
func (m *ConfigurationEntry) String() string
func (*ConfigurationEntry) Unmarshal ¶
func (m *ConfigurationEntry) Unmarshal(dAtA []byte) error
func (*ConfigurationEntry) XXX_DiscardUnknown ¶
func (m *ConfigurationEntry) XXX_DiscardUnknown()
func (*ConfigurationEntry) XXX_Marshal ¶
func (m *ConfigurationEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigurationEntry) XXX_Merge ¶
func (m *ConfigurationEntry) XXX_Merge(src proto.Message)
func (*ConfigurationEntry) XXX_Size ¶
func (m *ConfigurationEntry) XXX_Size() int
func (*ConfigurationEntry) XXX_Unmarshal ¶
func (m *ConfigurationEntry) XXX_Unmarshal(b []byte) error
type ConfigureRequest ¶
type ConfigureRequest struct { Term Term `protobuf:"varint,1,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Leader MemberID `protobuf:"bytes,2,opt,name=leader,proto3,casttype=MemberID" json:"leader,omitempty"` Index Index `protobuf:"varint,3,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Timestamp time.Time `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"` Members []*Member `protobuf:"bytes,5,rep,name=members,proto3" json:"members,omitempty"` }
func NewPopulatedConfigureRequest ¶
func NewPopulatedConfigureRequest(r randyProtocol, easy bool) *ConfigureRequest
func (*ConfigureRequest) Descriptor ¶
func (*ConfigureRequest) Descriptor() ([]byte, []int)
func (*ConfigureRequest) Equal ¶
func (this *ConfigureRequest) Equal(that interface{}) bool
func (*ConfigureRequest) GetIndex ¶
func (m *ConfigureRequest) GetIndex() Index
func (*ConfigureRequest) GetLeader ¶
func (m *ConfigureRequest) GetLeader() MemberID
func (*ConfigureRequest) GetMembers ¶
func (m *ConfigureRequest) GetMembers() []*Member
func (*ConfigureRequest) GetTerm ¶
func (m *ConfigureRequest) GetTerm() Term
func (*ConfigureRequest) GetTimestamp ¶
func (m *ConfigureRequest) GetTimestamp() time.Time
func (*ConfigureRequest) Marshal ¶
func (m *ConfigureRequest) Marshal() (dAtA []byte, err error)
func (*ConfigureRequest) MarshalToSizedBuffer ¶
func (m *ConfigureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConfigureRequest) ProtoMessage ¶
func (*ConfigureRequest) ProtoMessage()
func (*ConfigureRequest) Reset ¶
func (m *ConfigureRequest) Reset()
func (*ConfigureRequest) Size ¶
func (m *ConfigureRequest) Size() (n int)
func (*ConfigureRequest) String ¶
func (m *ConfigureRequest) String() string
func (*ConfigureRequest) Unmarshal ¶
func (m *ConfigureRequest) Unmarshal(dAtA []byte) error
func (*ConfigureRequest) XXX_DiscardUnknown ¶
func (m *ConfigureRequest) XXX_DiscardUnknown()
func (*ConfigureRequest) XXX_Marshal ¶
func (m *ConfigureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureRequest) XXX_Merge ¶
func (m *ConfigureRequest) XXX_Merge(src proto.Message)
func (*ConfigureRequest) XXX_Size ¶
func (m *ConfigureRequest) XXX_Size() int
func (*ConfigureRequest) XXX_Unmarshal ¶
func (m *ConfigureRequest) XXX_Unmarshal(b []byte) error
type ConfigureResponse ¶
type ConfigureResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` }
func NewPopulatedConfigureResponse ¶
func NewPopulatedConfigureResponse(r randyProtocol, easy bool) *ConfigureResponse
func (*ConfigureResponse) Descriptor ¶
func (*ConfigureResponse) Descriptor() ([]byte, []int)
func (*ConfigureResponse) Equal ¶
func (this *ConfigureResponse) Equal(that interface{}) bool
func (*ConfigureResponse) GetError ¶
func (m *ConfigureResponse) GetError() ResponseError
func (*ConfigureResponse) GetStatus ¶
func (m *ConfigureResponse) GetStatus() ResponseStatus
func (*ConfigureResponse) Marshal ¶
func (m *ConfigureResponse) Marshal() (dAtA []byte, err error)
func (*ConfigureResponse) MarshalTo ¶
func (m *ConfigureResponse) MarshalTo(dAtA []byte) (int, error)
func (*ConfigureResponse) MarshalToSizedBuffer ¶
func (m *ConfigureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConfigureResponse) ProtoMessage ¶
func (*ConfigureResponse) ProtoMessage()
func (*ConfigureResponse) Reset ¶
func (m *ConfigureResponse) Reset()
func (*ConfigureResponse) Size ¶
func (m *ConfigureResponse) Size() (n int)
func (*ConfigureResponse) String ¶
func (m *ConfigureResponse) String() string
func (*ConfigureResponse) Unmarshal ¶
func (m *ConfigureResponse) Unmarshal(dAtA []byte) error
func (*ConfigureResponse) XXX_DiscardUnknown ¶
func (m *ConfigureResponse) XXX_DiscardUnknown()
func (*ConfigureResponse) XXX_Marshal ¶
func (m *ConfigureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureResponse) XXX_Merge ¶
func (m *ConfigureResponse) XXX_Merge(src proto.Message)
func (*ConfigureResponse) XXX_Size ¶
func (m *ConfigureResponse) XXX_Size() int
func (*ConfigureResponse) XXX_Unmarshal ¶
func (m *ConfigureResponse) XXX_Unmarshal(b []byte) error
type EventType ¶
type EventType string
EventType is a Raft protocol state change event type
const ( // EventTypeStatus is a status change event EventTypeStatus EventType = "Status" // EventTypeRole is a role change event EventTypeRole EventType = "Role" // EventTypeTerm is a term change event EventTypeTerm EventType = "Term" // EventTypeLeader is a leader change event EventTypeLeader EventType = "Leader" )
type InitializeEntry ¶
type InitializeEntry struct { }
func NewPopulatedInitializeEntry ¶
func NewPopulatedInitializeEntry(r randyLog, easy bool) *InitializeEntry
func (*InitializeEntry) Descriptor ¶
func (*InitializeEntry) Descriptor() ([]byte, []int)
func (*InitializeEntry) Equal ¶
func (this *InitializeEntry) Equal(that interface{}) bool
func (*InitializeEntry) Marshal ¶
func (m *InitializeEntry) Marshal() (dAtA []byte, err error)
func (*InitializeEntry) MarshalToSizedBuffer ¶
func (m *InitializeEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InitializeEntry) ProtoMessage ¶
func (*InitializeEntry) ProtoMessage()
func (*InitializeEntry) Reset ¶
func (m *InitializeEntry) Reset()
func (*InitializeEntry) Size ¶
func (m *InitializeEntry) Size() (n int)
func (*InitializeEntry) String ¶
func (m *InitializeEntry) String() string
func (*InitializeEntry) Unmarshal ¶
func (m *InitializeEntry) Unmarshal(dAtA []byte) error
func (*InitializeEntry) XXX_DiscardUnknown ¶
func (m *InitializeEntry) XXX_DiscardUnknown()
func (*InitializeEntry) XXX_Marshal ¶
func (m *InitializeEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitializeEntry) XXX_Merge ¶
func (m *InitializeEntry) XXX_Merge(src proto.Message)
func (*InitializeEntry) XXX_Size ¶
func (m *InitializeEntry) XXX_Size() int
func (*InitializeEntry) XXX_Unmarshal ¶
func (m *InitializeEntry) XXX_Unmarshal(b []byte) error
type InstallRequest ¶
type InstallRequest struct { Term Term `protobuf:"varint,1,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Leader MemberID `protobuf:"bytes,2,opt,name=leader,proto3,casttype=MemberID" json:"leader,omitempty"` Index Index `protobuf:"varint,3,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Timestamp time.Time `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"` Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` }
func NewPopulatedInstallRequest ¶
func NewPopulatedInstallRequest(r randyProtocol, easy bool) *InstallRequest
func (*InstallRequest) Descriptor ¶
func (*InstallRequest) Descriptor() ([]byte, []int)
func (*InstallRequest) Equal ¶
func (this *InstallRequest) Equal(that interface{}) bool
func (*InstallRequest) GetData ¶
func (m *InstallRequest) GetData() []byte
func (*InstallRequest) GetIndex ¶
func (m *InstallRequest) GetIndex() Index
func (*InstallRequest) GetLeader ¶
func (m *InstallRequest) GetLeader() MemberID
func (*InstallRequest) GetTerm ¶
func (m *InstallRequest) GetTerm() Term
func (*InstallRequest) GetTimestamp ¶
func (m *InstallRequest) GetTimestamp() time.Time
func (*InstallRequest) Marshal ¶
func (m *InstallRequest) Marshal() (dAtA []byte, err error)
func (*InstallRequest) MarshalToSizedBuffer ¶
func (m *InstallRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InstallRequest) ProtoMessage ¶
func (*InstallRequest) ProtoMessage()
func (*InstallRequest) Reset ¶
func (m *InstallRequest) Reset()
func (*InstallRequest) Size ¶
func (m *InstallRequest) Size() (n int)
func (*InstallRequest) String ¶
func (m *InstallRequest) String() string
func (*InstallRequest) Unmarshal ¶
func (m *InstallRequest) Unmarshal(dAtA []byte) error
func (*InstallRequest) XXX_DiscardUnknown ¶
func (m *InstallRequest) XXX_DiscardUnknown()
func (*InstallRequest) XXX_Marshal ¶
func (m *InstallRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InstallRequest) XXX_Merge ¶
func (m *InstallRequest) XXX_Merge(src proto.Message)
func (*InstallRequest) XXX_Size ¶
func (m *InstallRequest) XXX_Size() int
func (*InstallRequest) XXX_Unmarshal ¶
func (m *InstallRequest) XXX_Unmarshal(b []byte) error
type InstallResponse ¶
type InstallResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` }
func NewPopulatedInstallResponse ¶
func NewPopulatedInstallResponse(r randyProtocol, easy bool) *InstallResponse
func (*InstallResponse) Descriptor ¶
func (*InstallResponse) Descriptor() ([]byte, []int)
func (*InstallResponse) Equal ¶
func (this *InstallResponse) Equal(that interface{}) bool
func (*InstallResponse) GetError ¶
func (m *InstallResponse) GetError() ResponseError
func (*InstallResponse) GetStatus ¶
func (m *InstallResponse) GetStatus() ResponseStatus
func (*InstallResponse) Marshal ¶
func (m *InstallResponse) Marshal() (dAtA []byte, err error)
func (*InstallResponse) MarshalToSizedBuffer ¶
func (m *InstallResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InstallResponse) ProtoMessage ¶
func (*InstallResponse) ProtoMessage()
func (*InstallResponse) Reset ¶
func (m *InstallResponse) Reset()
func (*InstallResponse) Size ¶
func (m *InstallResponse) Size() (n int)
func (*InstallResponse) String ¶
func (m *InstallResponse) String() string
func (*InstallResponse) Unmarshal ¶
func (m *InstallResponse) Unmarshal(dAtA []byte) error
func (*InstallResponse) XXX_DiscardUnknown ¶
func (m *InstallResponse) XXX_DiscardUnknown()
func (*InstallResponse) XXX_Marshal ¶
func (m *InstallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InstallResponse) XXX_Merge ¶
func (m *InstallResponse) XXX_Merge(src proto.Message)
func (*InstallResponse) XXX_Size ¶
func (m *InstallResponse) XXX_Size() int
func (*InstallResponse) XXX_Unmarshal ¶
func (m *InstallResponse) XXX_Unmarshal(b []byte) error
type InstallStreamRequest ¶
type InstallStreamRequest struct { *StreamMessage Request *InstallRequest }
InstallStreamRequest is a stream request for InstallRequest
func NewInstallStreamRequest ¶
func NewInstallStreamRequest(request *InstallRequest, err error) *InstallStreamRequest
NewInstallStreamRequest returns a new InstallStreamRequest with the given request and error
type InstallStreamResponse ¶
type InstallStreamResponse struct { *StreamMessage Response *InstallResponse }
InstallStreamResponse is a stream request for InstallResponse
func NewInstallStreamResponse ¶
func NewInstallStreamResponse(response *InstallResponse, err error) *InstallStreamResponse
NewInstallStreamResponse returns a new InstallStreamResponse with the given request and error
type JoinRequest ¶
type JoinRequest struct {
Member *Member `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
}
func NewPopulatedJoinRequest ¶
func NewPopulatedJoinRequest(r randyProtocol, easy bool) *JoinRequest
func (*JoinRequest) Descriptor ¶
func (*JoinRequest) Descriptor() ([]byte, []int)
func (*JoinRequest) Equal ¶
func (this *JoinRequest) Equal(that interface{}) bool
func (*JoinRequest) GetMember ¶
func (m *JoinRequest) GetMember() *Member
func (*JoinRequest) Marshal ¶
func (m *JoinRequest) Marshal() (dAtA []byte, err error)
func (*JoinRequest) MarshalToSizedBuffer ¶
func (m *JoinRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JoinRequest) ProtoMessage ¶
func (*JoinRequest) ProtoMessage()
func (*JoinRequest) Reset ¶
func (m *JoinRequest) Reset()
func (*JoinRequest) Size ¶
func (m *JoinRequest) Size() (n int)
func (*JoinRequest) String ¶
func (m *JoinRequest) String() string
func (*JoinRequest) Unmarshal ¶
func (m *JoinRequest) Unmarshal(dAtA []byte) error
func (*JoinRequest) XXX_DiscardUnknown ¶
func (m *JoinRequest) XXX_DiscardUnknown()
func (*JoinRequest) XXX_Marshal ¶
func (m *JoinRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JoinRequest) XXX_Merge ¶
func (m *JoinRequest) XXX_Merge(src proto.Message)
func (*JoinRequest) XXX_Size ¶
func (m *JoinRequest) XXX_Size() int
func (*JoinRequest) XXX_Unmarshal ¶
func (m *JoinRequest) XXX_Unmarshal(b []byte) error
type JoinResponse ¶
type JoinResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` Index Index `protobuf:"varint,3,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Term Term `protobuf:"varint,4,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Timestamp time.Time `protobuf:"bytes,5,opt,name=timestamp,proto3,stdtime" json:"timestamp"` Members []*Member `protobuf:"bytes,6,rep,name=members,proto3" json:"members,omitempty"` }
func NewPopulatedJoinResponse ¶
func NewPopulatedJoinResponse(r randyProtocol, easy bool) *JoinResponse
func (*JoinResponse) Descriptor ¶
func (*JoinResponse) Descriptor() ([]byte, []int)
func (*JoinResponse) Equal ¶
func (this *JoinResponse) Equal(that interface{}) bool
func (*JoinResponse) GetError ¶
func (m *JoinResponse) GetError() ResponseError
func (*JoinResponse) GetIndex ¶
func (m *JoinResponse) GetIndex() Index
func (*JoinResponse) GetMembers ¶
func (m *JoinResponse) GetMembers() []*Member
func (*JoinResponse) GetStatus ¶
func (m *JoinResponse) GetStatus() ResponseStatus
func (*JoinResponse) GetTerm ¶
func (m *JoinResponse) GetTerm() Term
func (*JoinResponse) GetTimestamp ¶
func (m *JoinResponse) GetTimestamp() time.Time
func (*JoinResponse) Marshal ¶
func (m *JoinResponse) Marshal() (dAtA []byte, err error)
func (*JoinResponse) MarshalToSizedBuffer ¶
func (m *JoinResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JoinResponse) ProtoMessage ¶
func (*JoinResponse) ProtoMessage()
func (*JoinResponse) Reset ¶
func (m *JoinResponse) Reset()
func (*JoinResponse) Size ¶
func (m *JoinResponse) Size() (n int)
func (*JoinResponse) String ¶
func (m *JoinResponse) String() string
func (*JoinResponse) Unmarshal ¶
func (m *JoinResponse) Unmarshal(dAtA []byte) error
func (*JoinResponse) XXX_DiscardUnknown ¶
func (m *JoinResponse) XXX_DiscardUnknown()
func (*JoinResponse) XXX_Marshal ¶
func (m *JoinResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JoinResponse) XXX_Merge ¶
func (m *JoinResponse) XXX_Merge(src proto.Message)
func (*JoinResponse) XXX_Size ¶
func (m *JoinResponse) XXX_Size() int
func (*JoinResponse) XXX_Unmarshal ¶
func (m *JoinResponse) XXX_Unmarshal(b []byte) error
type LeaveRequest ¶
type LeaveRequest struct {
Member *Member `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
}
func NewPopulatedLeaveRequest ¶
func NewPopulatedLeaveRequest(r randyProtocol, easy bool) *LeaveRequest
func (*LeaveRequest) Descriptor ¶
func (*LeaveRequest) Descriptor() ([]byte, []int)
func (*LeaveRequest) Equal ¶
func (this *LeaveRequest) Equal(that interface{}) bool
func (*LeaveRequest) GetMember ¶
func (m *LeaveRequest) GetMember() *Member
func (*LeaveRequest) Marshal ¶
func (m *LeaveRequest) Marshal() (dAtA []byte, err error)
func (*LeaveRequest) MarshalToSizedBuffer ¶
func (m *LeaveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaveRequest) ProtoMessage ¶
func (*LeaveRequest) ProtoMessage()
func (*LeaveRequest) Reset ¶
func (m *LeaveRequest) Reset()
func (*LeaveRequest) Size ¶
func (m *LeaveRequest) Size() (n int)
func (*LeaveRequest) String ¶
func (m *LeaveRequest) String() string
func (*LeaveRequest) Unmarshal ¶
func (m *LeaveRequest) Unmarshal(dAtA []byte) error
func (*LeaveRequest) XXX_DiscardUnknown ¶
func (m *LeaveRequest) XXX_DiscardUnknown()
func (*LeaveRequest) XXX_Marshal ¶
func (m *LeaveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaveRequest) XXX_Merge ¶
func (m *LeaveRequest) XXX_Merge(src proto.Message)
func (*LeaveRequest) XXX_Size ¶
func (m *LeaveRequest) XXX_Size() int
func (*LeaveRequest) XXX_Unmarshal ¶
func (m *LeaveRequest) XXX_Unmarshal(b []byte) error
type LeaveResponse ¶
type LeaveResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` Index Index `protobuf:"varint,3,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Term Term `protobuf:"varint,4,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Timestamp time.Time `protobuf:"bytes,5,opt,name=timestamp,proto3,stdtime" json:"timestamp"` Members []*Member `protobuf:"bytes,6,rep,name=members,proto3" json:"members,omitempty"` }
func NewPopulatedLeaveResponse ¶
func NewPopulatedLeaveResponse(r randyProtocol, easy bool) *LeaveResponse
func (*LeaveResponse) Descriptor ¶
func (*LeaveResponse) Descriptor() ([]byte, []int)
func (*LeaveResponse) Equal ¶
func (this *LeaveResponse) Equal(that interface{}) bool
func (*LeaveResponse) GetError ¶
func (m *LeaveResponse) GetError() ResponseError
func (*LeaveResponse) GetIndex ¶
func (m *LeaveResponse) GetIndex() Index
func (*LeaveResponse) GetMembers ¶
func (m *LeaveResponse) GetMembers() []*Member
func (*LeaveResponse) GetStatus ¶
func (m *LeaveResponse) GetStatus() ResponseStatus
func (*LeaveResponse) GetTerm ¶
func (m *LeaveResponse) GetTerm() Term
func (*LeaveResponse) GetTimestamp ¶
func (m *LeaveResponse) GetTimestamp() time.Time
func (*LeaveResponse) Marshal ¶
func (m *LeaveResponse) Marshal() (dAtA []byte, err error)
func (*LeaveResponse) MarshalToSizedBuffer ¶
func (m *LeaveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaveResponse) ProtoMessage ¶
func (*LeaveResponse) ProtoMessage()
func (*LeaveResponse) Reset ¶
func (m *LeaveResponse) Reset()
func (*LeaveResponse) Size ¶
func (m *LeaveResponse) Size() (n int)
func (*LeaveResponse) String ¶
func (m *LeaveResponse) String() string
func (*LeaveResponse) Unmarshal ¶
func (m *LeaveResponse) Unmarshal(dAtA []byte) error
func (*LeaveResponse) XXX_DiscardUnknown ¶
func (m *LeaveResponse) XXX_DiscardUnknown()
func (*LeaveResponse) XXX_Marshal ¶
func (m *LeaveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaveResponse) XXX_Merge ¶
func (m *LeaveResponse) XXX_Merge(src proto.Message)
func (*LeaveResponse) XXX_Size ¶
func (m *LeaveResponse) XXX_Size() int
func (*LeaveResponse) XXX_Unmarshal ¶
func (m *LeaveResponse) XXX_Unmarshal(b []byte) error
type LogEntry ¶
type LogEntry struct { Term Term `protobuf:"varint,1,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Timestamp time.Time `protobuf:"bytes,2,opt,name=timestamp,proto3,stdtime" json:"timestamp"` // Types that are valid to be assigned to Entry: // *LogEntry_Initialize // *LogEntry_Configuration // *LogEntry_Command // *LogEntry_Query Entry isLogEntry_Entry `protobuf_oneof:"entry"` }
Raft log entry
func NewPopulatedLogEntry ¶
func (*LogEntry) Descriptor ¶
func (*LogEntry) GetCommand ¶
func (m *LogEntry) GetCommand() *CommandEntry
func (*LogEntry) GetConfiguration ¶
func (m *LogEntry) GetConfiguration() *ConfigurationEntry
func (*LogEntry) GetInitialize ¶
func (m *LogEntry) GetInitialize() *InitializeEntry
func (*LogEntry) GetQuery ¶
func (m *LogEntry) GetQuery() *QueryEntry
func (*LogEntry) GetTimestamp ¶
func (*LogEntry) MarshalToSizedBuffer ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) XXX_DiscardUnknown ¶
func (m *LogEntry) XXX_DiscardUnknown()
func (*LogEntry) XXX_Marshal ¶
func (*LogEntry) XXX_OneofFuncs ¶
func (*LogEntry) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*LogEntry) XXX_Unmarshal ¶
type LogEntry_Command ¶
type LogEntry_Command struct {
Command *CommandEntry `protobuf:"bytes,5,opt,name=command,proto3,oneof"`
}
func NewPopulatedLogEntry_Command ¶
func NewPopulatedLogEntry_Command(r randyLog, easy bool) *LogEntry_Command
func (*LogEntry_Command) Equal ¶
func (this *LogEntry_Command) Equal(that interface{}) bool
func (*LogEntry_Command) MarshalToSizedBuffer ¶
func (m *LogEntry_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogEntry_Command) Size ¶
func (m *LogEntry_Command) Size() (n int)
type LogEntry_Configuration ¶
type LogEntry_Configuration struct {
Configuration *ConfigurationEntry `protobuf:"bytes,4,opt,name=configuration,proto3,oneof"`
}
func NewPopulatedLogEntry_Configuration ¶
func NewPopulatedLogEntry_Configuration(r randyLog, easy bool) *LogEntry_Configuration
func (*LogEntry_Configuration) Equal ¶
func (this *LogEntry_Configuration) Equal(that interface{}) bool
func (*LogEntry_Configuration) MarshalTo ¶
func (m *LogEntry_Configuration) MarshalTo(dAtA []byte) (int, error)
func (*LogEntry_Configuration) MarshalToSizedBuffer ¶
func (m *LogEntry_Configuration) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogEntry_Configuration) Size ¶
func (m *LogEntry_Configuration) Size() (n int)
type LogEntry_Initialize ¶
type LogEntry_Initialize struct {
Initialize *InitializeEntry `protobuf:"bytes,3,opt,name=initialize,proto3,oneof"`
}
func NewPopulatedLogEntry_Initialize ¶
func NewPopulatedLogEntry_Initialize(r randyLog, easy bool) *LogEntry_Initialize
func (*LogEntry_Initialize) Equal ¶
func (this *LogEntry_Initialize) Equal(that interface{}) bool
func (*LogEntry_Initialize) MarshalTo ¶
func (m *LogEntry_Initialize) MarshalTo(dAtA []byte) (int, error)
func (*LogEntry_Initialize) MarshalToSizedBuffer ¶
func (m *LogEntry_Initialize) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogEntry_Initialize) Size ¶
func (m *LogEntry_Initialize) Size() (n int)
type LogEntry_Query ¶
type LogEntry_Query struct {
Query *QueryEntry `protobuf:"bytes,6,opt,name=query,proto3,oneof"`
}
func NewPopulatedLogEntry_Query ¶
func NewPopulatedLogEntry_Query(r randyLog, easy bool) *LogEntry_Query
func (*LogEntry_Query) Equal ¶
func (this *LogEntry_Query) Equal(that interface{}) bool
func (*LogEntry_Query) MarshalToSizedBuffer ¶
func (m *LogEntry_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogEntry_Query) Size ¶
func (m *LogEntry_Query) Size() (n int)
type Member ¶
type Member struct { MemberID MemberID `protobuf:"bytes,1,opt,name=member_id,json=memberId,proto3,casttype=MemberID" json:"member_id,omitempty"` Type Member_Type `protobuf:"varint,2,opt,name=type,proto3,enum=atomix.raft.protocol.Member_Type" json:"type,omitempty"` Updated time.Time `protobuf:"bytes,3,opt,name=updated,proto3,stdtime" json:"updated"` }
func NewPopulatedMember ¶
func (*Member) Descriptor ¶
func (*Member) GetMemberID ¶
func (*Member) GetType ¶
func (m *Member) GetType() Member_Type
func (*Member) GetUpdated ¶
func (*Member) MarshalToSizedBuffer ¶
func (*Member) ProtoMessage ¶
func (*Member) ProtoMessage()
func (*Member) XXX_DiscardUnknown ¶
func (m *Member) XXX_DiscardUnknown()
func (*Member) XXX_Marshal ¶
func (*Member) XXX_Unmarshal ¶
type Member_Type ¶
type Member_Type int32
const ( Member_INACTIVE Member_Type = 0 Member_PASSIVE Member_Type = 1 Member_PROMOTABLE Member_Type = 2 Member_ACTIVE Member_Type = 3 )
func (Member_Type) EnumDescriptor ¶
func (Member_Type) EnumDescriptor() ([]byte, []int)
func (Member_Type) String ¶
func (x Member_Type) String() string
type Metadata ¶
type Metadata struct { Term Term `protobuf:"varint,1,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Vote MemberID `protobuf:"bytes,2,opt,name=vote,proto3,casttype=MemberID" json:"vote,omitempty"` }
Raft system metadata
func NewPopulatedMetadata ¶
func (*Metadata) Descriptor ¶
func (*Metadata) MarshalToSizedBuffer ¶
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) XXX_DiscardUnknown ¶
func (m *Metadata) XXX_DiscardUnknown()
func (*Metadata) XXX_Marshal ¶
func (*Metadata) XXX_Unmarshal ¶
type MetadataStore ¶
type MetadataStore interface { // StoreTerm stores the Raft term StoreTerm(term Term) // LoadTerm loads the Raft term LoadTerm() *Term // StoreVote stores the Raft vote StoreVote(vote *MemberID) // LoadVote loads the Raft vote LoadVote() *MemberID // Close closes the store Close() error }
MetadataStore stores metadata for a Raft server
type PollRequest ¶
type PollRequest struct { Term Term `protobuf:"varint,1,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Candidate MemberID `protobuf:"bytes,2,opt,name=candidate,proto3,casttype=MemberID" json:"candidate,omitempty"` LastLogIndex Index `protobuf:"varint,3,opt,name=last_log_index,json=lastLogIndex,proto3,casttype=Index" json:"last_log_index,omitempty"` LastLogTerm Term `protobuf:"varint,4,opt,name=last_log_term,json=lastLogTerm,proto3,casttype=Term" json:"last_log_term,omitempty"` }
func NewPopulatedPollRequest ¶
func NewPopulatedPollRequest(r randyProtocol, easy bool) *PollRequest
func (*PollRequest) Descriptor ¶
func (*PollRequest) Descriptor() ([]byte, []int)
func (*PollRequest) Equal ¶
func (this *PollRequest) Equal(that interface{}) bool
func (*PollRequest) GetCandidate ¶
func (m *PollRequest) GetCandidate() MemberID
func (*PollRequest) GetLastLogIndex ¶
func (m *PollRequest) GetLastLogIndex() Index
func (*PollRequest) GetLastLogTerm ¶
func (m *PollRequest) GetLastLogTerm() Term
func (*PollRequest) GetTerm ¶
func (m *PollRequest) GetTerm() Term
func (*PollRequest) Marshal ¶
func (m *PollRequest) Marshal() (dAtA []byte, err error)
func (*PollRequest) MarshalToSizedBuffer ¶
func (m *PollRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PollRequest) ProtoMessage ¶
func (*PollRequest) ProtoMessage()
func (*PollRequest) Reset ¶
func (m *PollRequest) Reset()
func (*PollRequest) Size ¶
func (m *PollRequest) Size() (n int)
func (*PollRequest) String ¶
func (m *PollRequest) String() string
func (*PollRequest) Unmarshal ¶
func (m *PollRequest) Unmarshal(dAtA []byte) error
func (*PollRequest) XXX_DiscardUnknown ¶
func (m *PollRequest) XXX_DiscardUnknown()
func (*PollRequest) XXX_Marshal ¶
func (m *PollRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PollRequest) XXX_Merge ¶
func (m *PollRequest) XXX_Merge(src proto.Message)
func (*PollRequest) XXX_Size ¶
func (m *PollRequest) XXX_Size() int
func (*PollRequest) XXX_Unmarshal ¶
func (m *PollRequest) XXX_Unmarshal(b []byte) error
type PollResponse ¶
type PollResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` Term Term `protobuf:"varint,3,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Accepted bool `protobuf:"varint,4,opt,name=accepted,proto3" json:"accepted,omitempty"` }
func NewPopulatedPollResponse ¶
func NewPopulatedPollResponse(r randyProtocol, easy bool) *PollResponse
func (*PollResponse) Descriptor ¶
func (*PollResponse) Descriptor() ([]byte, []int)
func (*PollResponse) Equal ¶
func (this *PollResponse) Equal(that interface{}) bool
func (*PollResponse) GetAccepted ¶
func (m *PollResponse) GetAccepted() bool
func (*PollResponse) GetError ¶
func (m *PollResponse) GetError() ResponseError
func (*PollResponse) GetStatus ¶
func (m *PollResponse) GetStatus() ResponseStatus
func (*PollResponse) GetTerm ¶
func (m *PollResponse) GetTerm() Term
func (*PollResponse) Marshal ¶
func (m *PollResponse) Marshal() (dAtA []byte, err error)
func (*PollResponse) MarshalToSizedBuffer ¶
func (m *PollResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PollResponse) ProtoMessage ¶
func (*PollResponse) ProtoMessage()
func (*PollResponse) Reset ¶
func (m *PollResponse) Reset()
func (*PollResponse) Size ¶
func (m *PollResponse) Size() (n int)
func (*PollResponse) String ¶
func (m *PollResponse) String() string
func (*PollResponse) Unmarshal ¶
func (m *PollResponse) Unmarshal(dAtA []byte) error
func (*PollResponse) XXX_DiscardUnknown ¶
func (m *PollResponse) XXX_DiscardUnknown()
func (*PollResponse) XXX_Marshal ¶
func (m *PollResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PollResponse) XXX_Merge ¶
func (m *PollResponse) XXX_Merge(src proto.Message)
func (*PollResponse) XXX_Size ¶
func (m *PollResponse) XXX_Size() int
func (*PollResponse) XXX_Unmarshal ¶
func (m *PollResponse) XXX_Unmarshal(b []byte) error
type QueryEntry ¶
type QueryEntry struct {
Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
func NewPopulatedQueryEntry ¶
func NewPopulatedQueryEntry(r randyLog, easy bool) *QueryEntry
func (*QueryEntry) Descriptor ¶
func (*QueryEntry) Descriptor() ([]byte, []int)
func (*QueryEntry) Equal ¶
func (this *QueryEntry) Equal(that interface{}) bool
func (*QueryEntry) GetValue ¶
func (m *QueryEntry) GetValue() []byte
func (*QueryEntry) Marshal ¶
func (m *QueryEntry) Marshal() (dAtA []byte, err error)
func (*QueryEntry) MarshalToSizedBuffer ¶
func (m *QueryEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryEntry) ProtoMessage ¶
func (*QueryEntry) ProtoMessage()
func (*QueryEntry) Reset ¶
func (m *QueryEntry) Reset()
func (*QueryEntry) Size ¶
func (m *QueryEntry) Size() (n int)
func (*QueryEntry) String ¶
func (m *QueryEntry) String() string
func (*QueryEntry) Unmarshal ¶
func (m *QueryEntry) Unmarshal(dAtA []byte) error
func (*QueryEntry) XXX_DiscardUnknown ¶
func (m *QueryEntry) XXX_DiscardUnknown()
func (*QueryEntry) XXX_Marshal ¶
func (m *QueryEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryEntry) XXX_Merge ¶
func (m *QueryEntry) XXX_Merge(src proto.Message)
func (*QueryEntry) XXX_Size ¶
func (m *QueryEntry) XXX_Size() int
func (*QueryEntry) XXX_Unmarshal ¶
func (m *QueryEntry) XXX_Unmarshal(b []byte) error
type QueryRequest ¶
type QueryRequest struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` ReadConsistency ReadConsistency `` /* 149-byte string literal not displayed */ }
func NewPopulatedQueryRequest ¶
func NewPopulatedQueryRequest(r randyProtocol, easy bool) *QueryRequest
func (*QueryRequest) Descriptor ¶
func (*QueryRequest) Descriptor() ([]byte, []int)
func (*QueryRequest) Equal ¶
func (this *QueryRequest) Equal(that interface{}) bool
func (*QueryRequest) GetReadConsistency ¶
func (m *QueryRequest) GetReadConsistency() ReadConsistency
func (*QueryRequest) GetValue ¶
func (m *QueryRequest) GetValue() []byte
func (*QueryRequest) Marshal ¶
func (m *QueryRequest) Marshal() (dAtA []byte, err error)
func (*QueryRequest) MarshalToSizedBuffer ¶
func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) Reset ¶
func (m *QueryRequest) Reset()
func (*QueryRequest) Size ¶
func (m *QueryRequest) Size() (n int)
func (*QueryRequest) String ¶
func (m *QueryRequest) String() string
func (*QueryRequest) Unmarshal ¶
func (m *QueryRequest) Unmarshal(dAtA []byte) error
func (*QueryRequest) XXX_DiscardUnknown ¶
func (m *QueryRequest) XXX_DiscardUnknown()
func (*QueryRequest) XXX_Marshal ¶
func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryRequest) XXX_Merge ¶
func (m *QueryRequest) XXX_Merge(src proto.Message)
func (*QueryRequest) XXX_Size ¶
func (m *QueryRequest) XXX_Size() int
func (*QueryRequest) XXX_Unmarshal ¶
func (m *QueryRequest) XXX_Unmarshal(b []byte) error
type QueryResponse ¶
type QueryResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` Output []byte `protobuf:"bytes,4,opt,name=output,proto3" json:"output,omitempty"` }
func NewPopulatedQueryResponse ¶
func NewPopulatedQueryResponse(r randyProtocol, easy bool) *QueryResponse
func (*QueryResponse) Descriptor ¶
func (*QueryResponse) Descriptor() ([]byte, []int)
func (*QueryResponse) Equal ¶
func (this *QueryResponse) Equal(that interface{}) bool
func (*QueryResponse) GetError ¶
func (m *QueryResponse) GetError() ResponseError
func (*QueryResponse) GetMessage ¶
func (m *QueryResponse) GetMessage() string
func (*QueryResponse) GetOutput ¶
func (m *QueryResponse) GetOutput() []byte
func (*QueryResponse) GetStatus ¶
func (m *QueryResponse) GetStatus() ResponseStatus
func (*QueryResponse) Marshal ¶
func (m *QueryResponse) Marshal() (dAtA []byte, err error)
func (*QueryResponse) MarshalToSizedBuffer ¶
func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryResponse) ProtoMessage ¶
func (*QueryResponse) ProtoMessage()
func (*QueryResponse) Reset ¶
func (m *QueryResponse) Reset()
func (*QueryResponse) Size ¶
func (m *QueryResponse) Size() (n int)
func (*QueryResponse) String ¶
func (m *QueryResponse) String() string
func (*QueryResponse) Unmarshal ¶
func (m *QueryResponse) Unmarshal(dAtA []byte) error
func (*QueryResponse) XXX_DiscardUnknown ¶
func (m *QueryResponse) XXX_DiscardUnknown()
func (*QueryResponse) XXX_Marshal ¶
func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryResponse) XXX_Merge ¶
func (m *QueryResponse) XXX_Merge(src proto.Message)
func (*QueryResponse) XXX_Size ¶
func (m *QueryResponse) XXX_Size() int
func (*QueryResponse) XXX_Unmarshal ¶
func (m *QueryResponse) XXX_Unmarshal(b []byte) error
type QueryStreamResponse ¶
type QueryStreamResponse struct { *StreamMessage Response *QueryResponse }
QueryStreamResponse is a stream response for QueryRequest
func NewQueryStreamResponse ¶
func NewQueryStreamResponse(response *QueryResponse, err error) *QueryStreamResponse
NewQueryStreamResponse returns a new CommandStreamResponse with the given response and error
type Raft ¶
type Raft interface { Server // Init initializes the Raft state Init() // Watch watches the Raft protocol state for changes Watch(func(Event)) // Role is the current role Role() RoleType // Status returns the Raft protocol status Status() Status // Config returns the Raft protocol configuration Config() *config.ProtocolConfig // Member returns the local member ID Member() MemberID // Members returns a list of all members in the Raft cluster Members() []MemberID // GetMember returns a RaftMember by ID GetMember(memberID MemberID) *Member // Client returns the Raft messaging protocol Protocol() Client // Term returns the current term Term() Term // SetTerm sets the current term SetTerm(term Term) error // Leader returns the current leader Leader() *MemberID // SetLeader sets the current leader SetLeader(leader *MemberID) error // LastVotedFor returns the last member voted for by this node LastVotedFor() *MemberID // SetLastVotedFor sets the last member voted for by this node SetLastVotedFor(memberID MemberID) error // CommitIndex returns the current commit index CommitIndex() Index // SetCommitIndex sets the highest known commit index SetCommitIndex(index Index) // Commit sets the persisted commit index Commit(index Index) Index // WriteLock acquires a write lock on the state WriteLock() // WriteUnlock releases a write lock on the state WriteUnlock() // ReadLock acquires a read lock on the state ReadLock() // ReadUnlock releases a read lock on the state ReadUnlock() // SetRole sets the protocol's current role SetRole(role RoleType) // Close closes the Raft state Close() error }
Raft is an interface for managing the state of the Raft consensus protocol
type RaftServiceClient ¶
type RaftServiceClient interface { Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error) Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*LeaveResponse, error) Configure(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error) Reconfigure(ctx context.Context, in *ReconfigureRequest, opts ...grpc.CallOption) (*ReconfigureResponse, error) Poll(ctx context.Context, in *PollRequest, opts ...grpc.CallOption) (*PollResponse, error) Vote(ctx context.Context, in *VoteRequest, opts ...grpc.CallOption) (*VoteResponse, error) Transfer(ctx context.Context, in *TransferRequest, opts ...grpc.CallOption) (*TransferResponse, error) Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error) Install(ctx context.Context, opts ...grpc.CallOption) (RaftService_InstallClient, error) Command(ctx context.Context, in *CommandRequest, opts ...grpc.CallOption) (RaftService_CommandClient, error) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (RaftService_QueryClient, error) }
RaftServiceClient is the client API for RaftService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRaftServiceClient ¶
func NewRaftServiceClient(cc *grpc.ClientConn) RaftServiceClient
type RaftServiceServer ¶
type RaftServiceServer interface { Join(context.Context, *JoinRequest) (*JoinResponse, error) Leave(context.Context, *LeaveRequest) (*LeaveResponse, error) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error) Reconfigure(context.Context, *ReconfigureRequest) (*ReconfigureResponse, error) Poll(context.Context, *PollRequest) (*PollResponse, error) Vote(context.Context, *VoteRequest) (*VoteResponse, error) Transfer(context.Context, *TransferRequest) (*TransferResponse, error) Append(context.Context, *AppendRequest) (*AppendResponse, error) Install(RaftService_InstallServer) error Command(*CommandRequest, RaftService_CommandServer) error Query(*QueryRequest, RaftService_QueryServer) error }
RaftServiceServer is the server API for RaftService service.
func NewServer ¶
func NewServer(server Server) RaftServiceServer
NewServer creates a new RaftServiceServer for the given Server
type RaftService_CommandClient ¶
type RaftService_CommandClient interface { Recv() (*CommandResponse, error) grpc.ClientStream }
type RaftService_CommandServer ¶
type RaftService_CommandServer interface { Send(*CommandResponse) error grpc.ServerStream }
type RaftService_InstallClient ¶
type RaftService_InstallClient interface { Send(*InstallRequest) error CloseAndRecv() (*InstallResponse, error) grpc.ClientStream }
type RaftService_InstallServer ¶
type RaftService_InstallServer interface { SendAndClose(*InstallResponse) error Recv() (*InstallRequest, error) grpc.ServerStream }
type RaftService_QueryClient ¶
type RaftService_QueryClient interface { Recv() (*QueryResponse, error) grpc.ClientStream }
type RaftService_QueryServer ¶
type RaftService_QueryServer interface { Send(*QueryResponse) error grpc.ServerStream }
type ReadConsistency ¶
type ReadConsistency int32
const ( ReadConsistency_SEQUENTIAL ReadConsistency = 0 ReadConsistency_LINEARIZABLE_LEASE ReadConsistency = 1 ReadConsistency_LINEARIZABLE ReadConsistency = 2 )
func (ReadConsistency) EnumDescriptor ¶
func (ReadConsistency) EnumDescriptor() ([]byte, []int)
func (ReadConsistency) String ¶
func (x ReadConsistency) String() string
type ReconfigureRequest ¶
type ReconfigureRequest struct { Member *Member `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"` Index Index `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Term Term `protobuf:"varint,3,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` }
func NewPopulatedReconfigureRequest ¶
func NewPopulatedReconfigureRequest(r randyProtocol, easy bool) *ReconfigureRequest
func (*ReconfigureRequest) Descriptor ¶
func (*ReconfigureRequest) Descriptor() ([]byte, []int)
func (*ReconfigureRequest) Equal ¶
func (this *ReconfigureRequest) Equal(that interface{}) bool
func (*ReconfigureRequest) GetIndex ¶
func (m *ReconfigureRequest) GetIndex() Index
func (*ReconfigureRequest) GetMember ¶
func (m *ReconfigureRequest) GetMember() *Member
func (*ReconfigureRequest) GetTerm ¶
func (m *ReconfigureRequest) GetTerm() Term
func (*ReconfigureRequest) Marshal ¶
func (m *ReconfigureRequest) Marshal() (dAtA []byte, err error)
func (*ReconfigureRequest) MarshalTo ¶
func (m *ReconfigureRequest) MarshalTo(dAtA []byte) (int, error)
func (*ReconfigureRequest) MarshalToSizedBuffer ¶
func (m *ReconfigureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReconfigureRequest) ProtoMessage ¶
func (*ReconfigureRequest) ProtoMessage()
func (*ReconfigureRequest) Reset ¶
func (m *ReconfigureRequest) Reset()
func (*ReconfigureRequest) Size ¶
func (m *ReconfigureRequest) Size() (n int)
func (*ReconfigureRequest) String ¶
func (m *ReconfigureRequest) String() string
func (*ReconfigureRequest) Unmarshal ¶
func (m *ReconfigureRequest) Unmarshal(dAtA []byte) error
func (*ReconfigureRequest) XXX_DiscardUnknown ¶
func (m *ReconfigureRequest) XXX_DiscardUnknown()
func (*ReconfigureRequest) XXX_Marshal ¶
func (m *ReconfigureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReconfigureRequest) XXX_Merge ¶
func (m *ReconfigureRequest) XXX_Merge(src proto.Message)
func (*ReconfigureRequest) XXX_Size ¶
func (m *ReconfigureRequest) XXX_Size() int
func (*ReconfigureRequest) XXX_Unmarshal ¶
func (m *ReconfigureRequest) XXX_Unmarshal(b []byte) error
type ReconfigureResponse ¶
type ReconfigureResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` Index Index `protobuf:"varint,3,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Term Term `protobuf:"varint,4,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Timestamp time.Time `protobuf:"bytes,5,opt,name=timestamp,proto3,stdtime" json:"timestamp"` Members []*Member `protobuf:"bytes,6,rep,name=members,proto3" json:"members,omitempty"` }
func NewPopulatedReconfigureResponse ¶
func NewPopulatedReconfigureResponse(r randyProtocol, easy bool) *ReconfigureResponse
func (*ReconfigureResponse) Descriptor ¶
func (*ReconfigureResponse) Descriptor() ([]byte, []int)
func (*ReconfigureResponse) Equal ¶
func (this *ReconfigureResponse) Equal(that interface{}) bool
func (*ReconfigureResponse) GetError ¶
func (m *ReconfigureResponse) GetError() ResponseError
func (*ReconfigureResponse) GetIndex ¶
func (m *ReconfigureResponse) GetIndex() Index
func (*ReconfigureResponse) GetMembers ¶
func (m *ReconfigureResponse) GetMembers() []*Member
func (*ReconfigureResponse) GetStatus ¶
func (m *ReconfigureResponse) GetStatus() ResponseStatus
func (*ReconfigureResponse) GetTerm ¶
func (m *ReconfigureResponse) GetTerm() Term
func (*ReconfigureResponse) GetTimestamp ¶
func (m *ReconfigureResponse) GetTimestamp() time.Time
func (*ReconfigureResponse) Marshal ¶
func (m *ReconfigureResponse) Marshal() (dAtA []byte, err error)
func (*ReconfigureResponse) MarshalTo ¶
func (m *ReconfigureResponse) MarshalTo(dAtA []byte) (int, error)
func (*ReconfigureResponse) MarshalToSizedBuffer ¶
func (m *ReconfigureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReconfigureResponse) ProtoMessage ¶
func (*ReconfigureResponse) ProtoMessage()
func (*ReconfigureResponse) Reset ¶
func (m *ReconfigureResponse) Reset()
func (*ReconfigureResponse) Size ¶
func (m *ReconfigureResponse) Size() (n int)
func (*ReconfigureResponse) String ¶
func (m *ReconfigureResponse) String() string
func (*ReconfigureResponse) Unmarshal ¶
func (m *ReconfigureResponse) Unmarshal(dAtA []byte) error
func (*ReconfigureResponse) XXX_DiscardUnknown ¶
func (m *ReconfigureResponse) XXX_DiscardUnknown()
func (*ReconfigureResponse) XXX_Marshal ¶
func (m *ReconfigureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReconfigureResponse) XXX_Merge ¶
func (m *ReconfigureResponse) XXX_Merge(src proto.Message)
func (*ReconfigureResponse) XXX_Size ¶
func (m *ReconfigureResponse) XXX_Size() int
func (*ReconfigureResponse) XXX_Unmarshal ¶
func (m *ReconfigureResponse) XXX_Unmarshal(b []byte) error
type ResponseError ¶
type ResponseError int32
const ( ResponseError_NO_LEADER ResponseError = 0 ResponseError_QUERY_FAILURE ResponseError = 1 ResponseError_COMMAND_FAILURE ResponseError = 2 ResponseError_APPLICATION_ERROR ResponseError = 3 ResponseError_ILLEGAL_MEMBER_STATE ResponseError = 4 ResponseError_UNKNOWN_CLIENT ResponseError = 5 ResponseError_UNKNOWN_SESSION ResponseError = 6 ResponseError_UNKNOWN_SERVICE ResponseError = 7 ResponseError_CLOSED_SESSION ResponseError = 8 ResponseError_PROTOCOL_ERROR ResponseError = 9 ResponseError_CONFIGURATION_ERROR ResponseError = 10 ResponseError_UNAVAILABLE ResponseError = 11 )
func (ResponseError) EnumDescriptor ¶
func (ResponseError) EnumDescriptor() ([]byte, []int)
func (ResponseError) String ¶
func (x ResponseError) String() string
type ResponseStatus ¶
type ResponseStatus int32
const ( ResponseStatus_OK ResponseStatus = 0 ResponseStatus_ERROR ResponseStatus = 1 )
func (ResponseStatus) EnumDescriptor ¶
func (ResponseStatus) EnumDescriptor() ([]byte, []int)
func (ResponseStatus) String ¶
func (x ResponseStatus) String() string
type Role ¶
type Role interface { Server // Type is the type of the role Type() RoleType // Start initializes the role // The Start method will always be called with a write lock on the Raft object Start() error // Stop stops the role // The Stop method will always be called with a write lock on the Raft object Stop() error }
Role is implemented by server roles to support protocol requests
type Server ¶
type Server interface { // Join handles a join request Join(ctx context.Context, request *JoinRequest) (*JoinResponse, error) // Leave handles a leave request Leave(ctx context.Context, request *LeaveRequest) (*LeaveResponse, error) // Configure handles a configure request Configure(ctx context.Context, request *ConfigureRequest) (*ConfigureResponse, error) // Reconfigure handles a reconfigure request Reconfigure(ctx context.Context, request *ReconfigureRequest) (*ReconfigureResponse, error) // Poll handles a poll request Poll(ctx context.Context, request *PollRequest) (*PollResponse, error) // Vote handles a vote request Vote(ctx context.Context, request *VoteRequest) (*VoteResponse, error) // Transfer handles a leadership transfer request Transfer(ctx context.Context, request *TransferRequest) (*TransferResponse, error) // Append handles an append request Append(ctx context.Context, request *AppendRequest) (*AppendResponse, error) // Install handles an install request Install(ch <-chan *InstallStreamRequest) (*InstallResponse, error) // Command handles a command request Command(request *CommandRequest, ch chan<- *CommandStreamResponse) error // Query handles a query request Query(request *QueryRequest, ch chan<- *QueryStreamResponse) error }
Server is an interface for receiving Raft messages
type Status ¶
type Status string
Status represents the status of a Raft server
const ( // StatusStopped indicates the server is not running StatusStopped Status = "stopped" // StatusRunning indicates the server is running but has not found a leader StatusRunning Status = "running" // StatusReady indicates the server is running, has found a leader, and has applied committed entries to its state machine StatusReady Status = "ready" )
type StreamMessage ¶
type StreamMessage struct {
Error error
}
StreamMessage is a stream message/error pair
func (*StreamMessage) Failed ¶
func (r *StreamMessage) Failed() bool
Failed returns a bool indicating whether the request failed
func (*StreamMessage) Succeeded ¶
func (r *StreamMessage) Succeeded() bool
Succeeded returns a bool indicating whether the request succeeded
type TransferRequest ¶
type TransferRequest struct {
Member MemberID `protobuf:"bytes,1,opt,name=member,proto3,casttype=MemberID" json:"member,omitempty"`
}
func NewPopulatedTransferRequest ¶
func NewPopulatedTransferRequest(r randyProtocol, easy bool) *TransferRequest
func (*TransferRequest) Descriptor ¶
func (*TransferRequest) Descriptor() ([]byte, []int)
func (*TransferRequest) Equal ¶
func (this *TransferRequest) Equal(that interface{}) bool
func (*TransferRequest) GetMember ¶
func (m *TransferRequest) GetMember() MemberID
func (*TransferRequest) Marshal ¶
func (m *TransferRequest) Marshal() (dAtA []byte, err error)
func (*TransferRequest) MarshalToSizedBuffer ¶
func (m *TransferRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TransferRequest) ProtoMessage ¶
func (*TransferRequest) ProtoMessage()
func (*TransferRequest) Reset ¶
func (m *TransferRequest) Reset()
func (*TransferRequest) Size ¶
func (m *TransferRequest) Size() (n int)
func (*TransferRequest) String ¶
func (m *TransferRequest) String() string
func (*TransferRequest) Unmarshal ¶
func (m *TransferRequest) Unmarshal(dAtA []byte) error
func (*TransferRequest) XXX_DiscardUnknown ¶
func (m *TransferRequest) XXX_DiscardUnknown()
func (*TransferRequest) XXX_Marshal ¶
func (m *TransferRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransferRequest) XXX_Merge ¶
func (m *TransferRequest) XXX_Merge(src proto.Message)
func (*TransferRequest) XXX_Size ¶
func (m *TransferRequest) XXX_Size() int
func (*TransferRequest) XXX_Unmarshal ¶
func (m *TransferRequest) XXX_Unmarshal(b []byte) error
type TransferResponse ¶
type TransferResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` }
func NewPopulatedTransferResponse ¶
func NewPopulatedTransferResponse(r randyProtocol, easy bool) *TransferResponse
func (*TransferResponse) Descriptor ¶
func (*TransferResponse) Descriptor() ([]byte, []int)
func (*TransferResponse) Equal ¶
func (this *TransferResponse) Equal(that interface{}) bool
func (*TransferResponse) GetError ¶
func (m *TransferResponse) GetError() ResponseError
func (*TransferResponse) GetStatus ¶
func (m *TransferResponse) GetStatus() ResponseStatus
func (*TransferResponse) Marshal ¶
func (m *TransferResponse) Marshal() (dAtA []byte, err error)
func (*TransferResponse) MarshalToSizedBuffer ¶
func (m *TransferResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TransferResponse) ProtoMessage ¶
func (*TransferResponse) ProtoMessage()
func (*TransferResponse) Reset ¶
func (m *TransferResponse) Reset()
func (*TransferResponse) Size ¶
func (m *TransferResponse) Size() (n int)
func (*TransferResponse) String ¶
func (m *TransferResponse) String() string
func (*TransferResponse) Unmarshal ¶
func (m *TransferResponse) Unmarshal(dAtA []byte) error
func (*TransferResponse) XXX_DiscardUnknown ¶
func (m *TransferResponse) XXX_DiscardUnknown()
func (*TransferResponse) XXX_Marshal ¶
func (m *TransferResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransferResponse) XXX_Merge ¶
func (m *TransferResponse) XXX_Merge(src proto.Message)
func (*TransferResponse) XXX_Size ¶
func (m *TransferResponse) XXX_Size() int
func (*TransferResponse) XXX_Unmarshal ¶
func (m *TransferResponse) XXX_Unmarshal(b []byte) error
type UnimplementedRaftServiceServer ¶
type UnimplementedRaftServiceServer struct { }
UnimplementedRaftServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedRaftServiceServer) Append ¶
func (*UnimplementedRaftServiceServer) Append(ctx context.Context, req *AppendRequest) (*AppendResponse, error)
func (*UnimplementedRaftServiceServer) Command ¶
func (*UnimplementedRaftServiceServer) Command(req *CommandRequest, srv RaftService_CommandServer) error
func (*UnimplementedRaftServiceServer) Configure ¶
func (*UnimplementedRaftServiceServer) Configure(ctx context.Context, req *ConfigureRequest) (*ConfigureResponse, error)
func (*UnimplementedRaftServiceServer) Install ¶
func (*UnimplementedRaftServiceServer) Install(srv RaftService_InstallServer) error
func (*UnimplementedRaftServiceServer) Join ¶
func (*UnimplementedRaftServiceServer) Join(ctx context.Context, req *JoinRequest) (*JoinResponse, error)
func (*UnimplementedRaftServiceServer) Leave ¶
func (*UnimplementedRaftServiceServer) Leave(ctx context.Context, req *LeaveRequest) (*LeaveResponse, error)
func (*UnimplementedRaftServiceServer) Poll ¶
func (*UnimplementedRaftServiceServer) Poll(ctx context.Context, req *PollRequest) (*PollResponse, error)
func (*UnimplementedRaftServiceServer) Query ¶
func (*UnimplementedRaftServiceServer) Query(req *QueryRequest, srv RaftService_QueryServer) error
func (*UnimplementedRaftServiceServer) Reconfigure ¶
func (*UnimplementedRaftServiceServer) Reconfigure(ctx context.Context, req *ReconfigureRequest) (*ReconfigureResponse, error)
func (*UnimplementedRaftServiceServer) Transfer ¶
func (*UnimplementedRaftServiceServer) Transfer(ctx context.Context, req *TransferRequest) (*TransferResponse, error)
func (*UnimplementedRaftServiceServer) Vote ¶
func (*UnimplementedRaftServiceServer) Vote(ctx context.Context, req *VoteRequest) (*VoteResponse, error)
type VoteRequest ¶
type VoteRequest struct { Term Term `protobuf:"varint,1,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Candidate MemberID `protobuf:"bytes,2,opt,name=candidate,proto3,casttype=MemberID" json:"candidate,omitempty"` LastLogIndex Index `protobuf:"varint,3,opt,name=last_log_index,json=lastLogIndex,proto3,casttype=Index" json:"last_log_index,omitempty"` LastLogTerm Term `protobuf:"varint,4,opt,name=last_log_term,json=lastLogTerm,proto3,casttype=Term" json:"last_log_term,omitempty"` }
func NewPopulatedVoteRequest ¶
func NewPopulatedVoteRequest(r randyProtocol, easy bool) *VoteRequest
func (*VoteRequest) Descriptor ¶
func (*VoteRequest) Descriptor() ([]byte, []int)
func (*VoteRequest) Equal ¶
func (this *VoteRequest) Equal(that interface{}) bool
func (*VoteRequest) GetCandidate ¶
func (m *VoteRequest) GetCandidate() MemberID
func (*VoteRequest) GetLastLogIndex ¶
func (m *VoteRequest) GetLastLogIndex() Index
func (*VoteRequest) GetLastLogTerm ¶
func (m *VoteRequest) GetLastLogTerm() Term
func (*VoteRequest) GetTerm ¶
func (m *VoteRequest) GetTerm() Term
func (*VoteRequest) Marshal ¶
func (m *VoteRequest) Marshal() (dAtA []byte, err error)
func (*VoteRequest) MarshalToSizedBuffer ¶
func (m *VoteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VoteRequest) ProtoMessage ¶
func (*VoteRequest) ProtoMessage()
func (*VoteRequest) Reset ¶
func (m *VoteRequest) Reset()
func (*VoteRequest) Size ¶
func (m *VoteRequest) Size() (n int)
func (*VoteRequest) String ¶
func (m *VoteRequest) String() string
func (*VoteRequest) Unmarshal ¶
func (m *VoteRequest) Unmarshal(dAtA []byte) error
func (*VoteRequest) XXX_DiscardUnknown ¶
func (m *VoteRequest) XXX_DiscardUnknown()
func (*VoteRequest) XXX_Marshal ¶
func (m *VoteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VoteRequest) XXX_Merge ¶
func (m *VoteRequest) XXX_Merge(src proto.Message)
func (*VoteRequest) XXX_Size ¶
func (m *VoteRequest) XXX_Size() int
func (*VoteRequest) XXX_Unmarshal ¶
func (m *VoteRequest) XXX_Unmarshal(b []byte) error
type VoteResponse ¶
type VoteResponse struct { Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.raft.protocol.ResponseStatus" json:"status,omitempty"` Error ResponseError `protobuf:"varint,2,opt,name=error,proto3,enum=atomix.raft.protocol.ResponseError" json:"error,omitempty"` Term Term `protobuf:"varint,3,opt,name=term,proto3,casttype=Term" json:"term,omitempty"` Voted bool `protobuf:"varint,4,opt,name=voted,proto3" json:"voted,omitempty"` }
func NewPopulatedVoteResponse ¶
func NewPopulatedVoteResponse(r randyProtocol, easy bool) *VoteResponse
func (*VoteResponse) Descriptor ¶
func (*VoteResponse) Descriptor() ([]byte, []int)
func (*VoteResponse) Equal ¶
func (this *VoteResponse) Equal(that interface{}) bool
func (*VoteResponse) GetError ¶
func (m *VoteResponse) GetError() ResponseError
func (*VoteResponse) GetStatus ¶
func (m *VoteResponse) GetStatus() ResponseStatus
func (*VoteResponse) GetTerm ¶
func (m *VoteResponse) GetTerm() Term
func (*VoteResponse) GetVoted ¶
func (m *VoteResponse) GetVoted() bool
func (*VoteResponse) Marshal ¶
func (m *VoteResponse) Marshal() (dAtA []byte, err error)
func (*VoteResponse) MarshalToSizedBuffer ¶
func (m *VoteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VoteResponse) ProtoMessage ¶
func (*VoteResponse) ProtoMessage()
func (*VoteResponse) Reset ¶
func (m *VoteResponse) Reset()
func (*VoteResponse) Size ¶
func (m *VoteResponse) Size() (n int)
func (*VoteResponse) String ¶
func (m *VoteResponse) String() string
func (*VoteResponse) Unmarshal ¶
func (m *VoteResponse) Unmarshal(dAtA []byte) error
func (*VoteResponse) XXX_DiscardUnknown ¶
func (m *VoteResponse) XXX_DiscardUnknown()
func (*VoteResponse) XXX_Marshal ¶
func (m *VoteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VoteResponse) XXX_Merge ¶
func (m *VoteResponse) XXX_Merge(src proto.Message)
func (*VoteResponse) XXX_Size ¶
func (m *VoteResponse) XXX_Size() int
func (*VoteResponse) XXX_Unmarshal ¶
func (m *VoteResponse) XXX_Unmarshal(b []byte) error