store

type Lease struct {
	ID        int64
	TTL       time.Duration
	Keys      []string
	ExpiresAt time.Time
}

type MemoryStore struct {
	// contains filtered or unexported fields
}

type SQLiteStore struct {
	// contains filtered or unexported fields
}

type Store interface {
	Get(key string) (*StoredObject, error)
	Put(key string, obj *StoredObject) error
	Delete(key string) error
	List(prefix string) ([]*StoredObject, error)
	Watch(prefix string, sinceRevision int64) (<-chan WatchEvent, error)
	Unwatch(ch <-chan WatchEvent)
	CurrentRevision() int64
	Compact(beforeRevision int64) error
	Close() error
}

type StoredObject struct {
	Key            string          `json:"key"`
	Value          json.RawMessage `json:"value"`
	Revision       int64           `json:"revision"`
	ModRevision    int64           `json:"mod_revision"`
	CreateRevision int64           `json:"create_revision"`
	Version        int64           `json:"version"`
	Lease          int64           `json:"lease,omitempty"`
	Deleted        bool            `json:"deleted,omitempty"`
}

type WatchEvent struct {
	Type   string        `json:"type"`
	Object *StoredObject `json:"object"`
}