Documentation
¶
Overview ¶
Code generated by atomix-go-framework. DO NOT EDIT.
Code generated by atomix-go-framework. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterService(node *rsm.Node)
- type AddProposal
- type AddProposals
- type ClearProposal
- type ClearProposals
- type ContainsProposal
- type ContainsProposals
- type ElementsProposal
- type ElementsProposals
- type EventsProposal
- type EventsProposals
- type NewServiceFunc
- type Proposal
- type ProposalID
- type Proposals
- type RemoveProposal
- type RemoveProposals
- type Service
- type ServiceAdaptor
- type ServiceContext
- type Session
- type SessionID
- type SessionState
- type Sessions
- type SetState
- func (*SetState) Descriptor() ([]byte, []int)
- func (m *SetState) GetValues() []SetValue
- func (m *SetState) Marshal() (dAtA []byte, err error)
- func (m *SetState) MarshalTo(dAtA []byte) (int, error)
- func (m *SetState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetState) ProtoMessage()
- func (m *SetState) Reset()
- func (m *SetState) Size() (n int)
- func (m *SetState) String() string
- func (m *SetState) Unmarshal(dAtA []byte) error
- func (m *SetState) XXX_DiscardUnknown()
- func (m *SetState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetState) XXX_Merge(src proto.Message)
- func (m *SetState) XXX_Size() int
- func (m *SetState) XXX_Unmarshal(b []byte) error
- type SetValue
- func (*SetValue) Descriptor() ([]byte, []int)
- func (m *SetValue) GetValue() string
- func (m *SetValue) Marshal() (dAtA []byte, err error)
- func (m *SetValue) MarshalTo(dAtA []byte) (int, error)
- func (m *SetValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetValue) ProtoMessage()
- func (m *SetValue) Reset()
- func (m *SetValue) Size() (n int)
- func (m *SetValue) String() string
- func (m *SetValue) Unmarshal(dAtA []byte) error
- func (m *SetValue) XXX_DiscardUnknown()
- func (m *SetValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetValue) XXX_Merge(src proto.Message)
- func (m *SetValue) XXX_Size() int
- func (m *SetValue) XXX_Unmarshal(b []byte) error
- type SizeProposal
- type SizeProposals
- type SnapshotReader
- type SnapshotWriter
- type Watcher
Constants ¶
View Source
const Type = "Set"
Variables ¶
Functions ¶
func RegisterService ¶
RegisterService registers the election primitive service on the given node
Types ¶
type AddProposal ¶
type AddProposal interface { Proposal Request() *set.AddRequest Reply(*set.AddResponse) error // contains filtered or unexported methods }
type AddProposals ¶
type AddProposals interface { Get(ProposalID) (AddProposal, bool) List() []AddProposal // contains filtered or unexported methods }
type ClearProposal ¶
type ClearProposal interface { Proposal Request() *set.ClearRequest Reply(*set.ClearResponse) error // contains filtered or unexported methods }
type ClearProposals ¶
type ClearProposals interface { Get(ProposalID) (ClearProposal, bool) List() []ClearProposal // contains filtered or unexported methods }
type ContainsProposal ¶
type ContainsProposal interface { Proposal Request() *set.ContainsRequest Reply(*set.ContainsResponse) error // contains filtered or unexported methods }
type ContainsProposals ¶
type ContainsProposals interface { Get(ProposalID) (ContainsProposal, bool) List() []ContainsProposal // contains filtered or unexported methods }
type ElementsProposal ¶
type ElementsProposal interface { Proposal Request() *set.ElementsRequest Notify(*set.ElementsResponse) error Close() error }
type ElementsProposals ¶
type ElementsProposals interface { Get(ProposalID) (ElementsProposal, bool) List() []ElementsProposal // contains filtered or unexported methods }
type EventsProposal ¶
type EventsProposal interface { Proposal Request() *set.EventsRequest Notify(*set.EventsResponse) error Close() error }
type EventsProposals ¶
type EventsProposals interface { Get(ProposalID) (EventsProposal, bool) List() []EventsProposal // contains filtered or unexported methods }
type NewServiceFunc ¶
type NewServiceFunc func(ServiceContext) Service
type ProposalID ¶
type ProposalID uint64
type Proposals ¶
type Proposals interface { Size() SizeProposals Contains() ContainsProposals Add() AddProposals Remove() RemoveProposals Clear() ClearProposals Events() EventsProposals Elements() ElementsProposals }
type RemoveProposal ¶
type RemoveProposal interface { Proposal Request() *set.RemoveRequest Reply(*set.RemoveResponse) error // contains filtered or unexported methods }
type RemoveProposals ¶
type RemoveProposals interface { Get(ProposalID) (RemoveProposal, bool) List() []RemoveProposal // contains filtered or unexported methods }
type Service ¶
type Service interface { ServiceContext Backup(SnapshotWriter) error Restore(SnapshotReader) error // Size gets the number of elements in the set Size(SizeProposal) error // Contains returns whether the set contains a value Contains(ContainsProposal) error // Add adds a value to the set Add(AddProposal) error // Remove removes a value from the set Remove(RemoveProposal) error // Clear removes all values from the set Clear(ClearProposal) error // Events listens for set change events Events(EventsProposal) error // Elements lists all elements in the set Elements(ElementsProposal) error }
type ServiceAdaptor ¶
func (*ServiceAdaptor) SessionClosed ¶
func (s *ServiceAdaptor) SessionClosed(session rsm.Session)
func (*ServiceAdaptor) SessionExpired ¶
func (s *ServiceAdaptor) SessionExpired(session rsm.Session)
func (*ServiceAdaptor) SessionOpen ¶
func (s *ServiceAdaptor) SessionOpen(rsmSession rsm.Session)
type ServiceContext ¶
type Session ¶
type Session interface { ID() SessionID State() SessionState Watch(func(SessionState)) Watcher Proposals() Proposals // contains filtered or unexported methods }
type SetState ¶
type SetState struct {
Values []SetValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values"`
}
func (*SetState) Descriptor ¶
func (*SetState) MarshalToSizedBuffer ¶
func (*SetState) ProtoMessage ¶
func (*SetState) ProtoMessage()
func (*SetState) XXX_DiscardUnknown ¶
func (m *SetState) XXX_DiscardUnknown()
func (*SetState) XXX_Marshal ¶
func (*SetState) XXX_Unmarshal ¶
type SetValue ¶
type SetValue struct { meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*SetValue) Descriptor ¶
func (*SetValue) MarshalToSizedBuffer ¶
func (*SetValue) ProtoMessage ¶
func (*SetValue) ProtoMessage()
func (*SetValue) XXX_DiscardUnknown ¶
func (m *SetValue) XXX_DiscardUnknown()
func (*SetValue) XXX_Marshal ¶
func (*SetValue) XXX_Unmarshal ¶
type SizeProposal ¶
type SizeProposal interface { Proposal Request() *set.SizeRequest Reply(*set.SizeResponse) error // contains filtered or unexported methods }
type SizeProposals ¶
type SizeProposals interface { Get(ProposalID) (SizeProposal, bool) List() []SizeProposal // contains filtered or unexported methods }
type SnapshotReader ¶
type SnapshotWriter ¶
Click to show internal directories.
Click to hide internal directories.