value

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

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

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

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 {
	Set() SetProposals
	Events() EventsProposals
}

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

type Service interface {
	ServiceContext
	Backup(SnapshotWriter) error
	Restore(SnapshotReader) error
	// Set sets the value
	Set(SetProposal) (*value.SetResponse, error)
	// Get gets the value
	Get(GetQuery) (*value.GetResponse, error)
	// Events listens for value change events
	Events(EventsProposal)
}

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() *value.SetRequest
}

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

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

type SnapshotWriter interface {
	WriteState(*ValueState) error
}

type ValueState struct {
	meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Value           []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

type Watcher interface {
	Cancel()
}