set

type AddProposal interface {
	Proposal
	Request() *set.AddRequest
}

type AddProposals interface {
	Get(ProposalID) (AddProposal, bool)
	List() []AddProposal
}

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

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

type ContainsQuery interface {
	Query
	Request() *set.ContainsRequest
}

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

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

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

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 {
	Add() AddProposals
	Remove() RemoveProposals
	Clear() ClearProposals
	Events() EventsProposals
}

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

type RemoveProposal interface {
	Proposal
	Request() *set.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 set
	Size(SizeQuery) (*set.SizeResponse, error)
	// Contains returns whether the set contains a value
	Contains(ContainsQuery) (*set.ContainsResponse, error)
	// Add adds a value to the set
	Add(AddProposal) (*set.AddResponse, error)
	// Remove removes a value from the set
	Remove(RemoveProposal) (*set.RemoveResponse, error)
	// Clear removes all values from the set
	Clear(ClearProposal) (*set.ClearResponse, error)
	// Events listens for set change events
	Events(EventsProposal)
	// Elements lists all elements in the set
	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 SetState struct {
	Values []SetValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values"`
}

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

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

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

type SnapshotWriter interface {
	WriteState(*SetState) error
}

type Watcher interface {
	Cancel()
}