_map

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

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

type EntriesQuery interface {
	Query
	Request() *_map.EntriesRequest
	Notify(*_map.EntriesResponse)
	Close()
}

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

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

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

type MapState struct {
	Listeners []MapStateListener `protobuf:"bytes,1,rep,name=listeners,proto3" json:"listeners"`
	Entries   []MapStateEntry    `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries"`
}

type MapStateEntry struct {
	Key   MapStateKey    `protobuf:"bytes,1,opt,name=key,proto3" json:"key"`
	Value *MapStateValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

type MapStateKey struct {
	meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Key             string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

type MapStateListener struct {
	ProposalID ProposalID `protobuf:"varint,1,opt,name=proposal_id,json=proposalId,proto3,casttype=ProposalID" json:"proposal_id,omitempty"`
	Key        string     `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

type MapStateValue struct {
	Value  []byte     `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Expire *time.Time `protobuf:"bytes,2,opt,name=expire,proto3,stdtime" json:"expire,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 {
	Put() PutProposals
	Remove() RemoveProposals
	Clear() ClearProposals
	Events() EventsProposals
}

type PutProposal interface {
	Proposal
	Request() *_map.PutRequest
}

type PutProposals interface {
	Get(ProposalID) (PutProposal, bool)
	List() []PutProposal
}

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

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

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

type Service interface {
	ServiceContext
	Backup(SnapshotWriter) error
	Restore(SnapshotReader) error
	// Size returns the size of the map
	Size(SizeQuery) (*_map.SizeResponse, error)
	// Put puts an entry into the map
	Put(PutProposal) (*_map.PutResponse, error)
	// Get gets the entry for a key
	Get(GetQuery) (*_map.GetResponse, error)
	// Remove removes an entry from the map
	Remove(RemoveProposal) (*_map.RemoveResponse, error)
	// Clear removes all entries from the map
	Clear(ClearProposal) (*_map.ClearResponse, error)
	// Events listens for change events
	Events(EventsProposal)
	// Entries lists all entries in the map
	Entries(EntriesQuery)
}

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 SizeQuery interface {
	Query
	Request() *_map.SizeRequest
}

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

type SnapshotWriter interface {
	WriteState(*MapState) error
}

type Watcher interface {
	Cancel()
}