json_store

type CollectionCursor interface {
	Next() (*pb.Collection, error)
	Close() error
}

type JSON string

type JSONCursor interface {
	Read() (JSON, error)
	Close() error
}

type JSONReader interface {
	Read(objectId string) (JSON, error)
}

type JSONReaderFunc func(objectId string) (JSON, error)

type JSONWriter interface {
	Write(data JSON) error
}

type JSONWriterFunc func(data JSON) error

type Repository interface {
	SaveCollection(collectionId *pb.Collection) error

	GetCollection(collectionId string) (*pb.Collection, error)

	GetCollectionList() (CollectionCursor, error)

	DeleteCollection(collectionId string) error

	SaveObject(collectionId string, id string, object JSON) error

	PatchObject(collectionId string, objectId string, path string, data JSON) error

	GetObject(collectionId string, objectID string) (JSON, error)

	GetObjectList(collectionId string, offset uint32, count uint32) ([]JSON, error)

	DeleteObject(collectionId string, objectID string) error
}

type Service interface {
	CreateCollection(collection *pb.Collection) error
	GetCollection(collectionId string) (*pb.Collection, error)
	ListCollections() (CollectionCursor, error)
	DeleteCollection(collectionId string) error

	PutObject(collectionId string, data JSON) (string, error)
	PatchObject(collectionId string, objectId string, path string, data JSON) error
	MoveObject(collectionId string, objectID string, targetCollectionId string) error
	GetObject(collectionId string, objectId string) (JSON, error)
	GetObjects(collectionId string, objectsIds StringCursor) (JSONCursor, error)
	DeleteObject(collectionId string, objectId string) error
}

type StringCursor interface {
	Next() (string, error)
	Close() error
}