list

type AppendProposal interface {
	Proposal
	Request() *list.AppendRequest
}

type AppendProposals interface {
	Get(ProposalID) (AppendProposal, bool)
	List() []AppendProposal
}

type ClearProposal interface {
	Proposal
	Request() *list.ClearRequest
}

type ClearProposals interface {
	Get(ProposalID) (ClearProposal, bool)
	List() []ClearProposal
}

type ElementsQuery interface {
	Query
	Request() *list.ElementsRequest
	Notify(*list.ElementsResponse)
	Close()
}

type EventsProposal interface {
	Proposal
	Request() *list.EventsRequest
	Notify(*list.EventsResponse)
	Close()
}

type EventsProposals interface {
	Get(ProposalID) (EventsProposal, bool)
	List() []EventsProposal
}

type GetQuery interface {
	Query
	Request() *list.GetRequest
}

type InsertProposal interface {
	Proposal
	Request() *list.InsertRequest
}

type InsertProposals interface {
	Get(ProposalID) (InsertProposal, bool)
	List() []InsertProposal
}

type ListState struct {
	Values []ListValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values"`
}

type ListValue 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"`
}

type NewServiceFunc func(ServiceContext) Service

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

type ProposalID uint64

type ProposalState int

type Proposals interface {
	Append() AppendProposals
	Insert() InsertProposals
	Set() SetProposals
	Remove() RemoveProposals
	Clear() ClearProposals
	Events() EventsProposals
}

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

type RemoveProposal interface {
	Proposal
	Request() *list.RemoveRequest
}

type RemoveProposals interface {
	Get(ProposalID) (RemoveProposal, bool)
	List() []RemoveProposal
}

type Service interface {
	ServiceContext
	Backup(SnapshotWriter) error
	Restore(SnapshotReader) error
	// Size gets the number of elements in the list
	Size(SizeQuery) (*list.SizeResponse, error)
	// Append appends a value to the list
	Append(AppendProposal) (*list.AppendResponse, error)
	// Insert inserts a value at a specific index in the list
	Insert(InsertProposal) (*list.InsertResponse, error)
	// Get gets the value at an index in the list
	Get(GetQuery) (*list.GetResponse, error)
	// Set sets the value at an index in the list
	Set(SetProposal) (*list.SetResponse, error)
	// Remove removes an element from the list
	Remove(RemoveProposal) (*list.RemoveResponse, error)
	// Clear removes all elements from the list
	Clear(ClearProposal) (*list.ClearResponse, error)
	// Events listens for change events
	Events(EventsProposal)
	// Elements streams all elements in the list
	Elements(ElementsQuery)
}

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

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

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

type SessionID uint64

type SessionState int

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

type SetProposal interface {
	Proposal
	Request() *list.SetRequest
}

type SetProposals interface {
	Get(ProposalID) (SetProposal, bool)
	List() []SetProposal
}

type SizeQuery interface {
	Query
	Request() *list.SizeRequest
}

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

type SnapshotWriter interface {
	WriteState(*ListState) error
}

type Watcher interface {
	Cancel()
}