partition

type ParallelPartitionLister struct {
	Lister      PartitionLister
	Concurrency int64
	Partitions  []Partition
	// contains filtered or unexported fields
}

type Partition interface {
	Name() string
}

type PartitionLister func(ctx context.Context, partition Partition, cont string, revision string, limit int) (types.APIObjectList, error)

type Partitioner interface {
	Lookup(apiOp *types2.APIRequest, schema *types2.APISchema, verb, id string) (Partition, error)
	All(apiOp *types2.APIRequest, schema *types2.APISchema, verb, id string) ([]Partition, error)
	Store(apiOp *types2.APIRequest, partition Partition) (types2.Store, error)
}

type Store struct {
	Partitioner Partitioner
}