partition

Documentation

Index

• type ParallelPartitionLister
  • func (p *ParallelPartitionLister) Continue() string
  • func (p *ParallelPartitionLister) Err() error
  • func (p *ParallelPartitionLister) List(ctx context.Context, limit int, resume string) (<-chan []types.APIObject, error)
  • func (p *ParallelPartitionLister) Revision() string
• type Partition
• type PartitionLister
• type Partitioner
• type Store
  • func (s *Store) ByID(apiOp *types.APIRequest, schema *types.APISchema, id string) (types.APIObject, error)
  • func (s *Store) Create(apiOp *types.APIRequest, schema *types.APISchema, data types.APIObject) (types.APIObject, error)
  • func (s *Store) Delete(apiOp *types.APIRequest, schema *types.APISchema, id string) (types.APIObject, error)
  • func (s *Store) List(apiOp *types.APIRequest, schema *types.APISchema) (types.APIObjectList, error)
  • func (s *Store) Update(apiOp *types.APIRequest, schema *types.APISchema, data types.APIObject, ...) (types.APIObject, error)
  • func (s *Store) Watch(apiOp *types.APIRequest, schema *types.APISchema, wr types.WatchRequest) (chan types.APIEvent, error)

Types

type ParallelPartitionLister

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

func (*ParallelPartitionLister) Continue

func (p *ParallelPartitionLister) Continue() string

func (*ParallelPartitionLister) Err

func (p *ParallelPartitionLister) Err() error

func (*ParallelPartitionLister) List

func (p *ParallelPartitionLister) List(ctx context.Context, limit int, resume string) (<-chan []types.APIObject, error)

func (*ParallelPartitionLister) Revision

func (p *ParallelPartitionLister) Revision() string

type Partition

type Partition interface {
	Name() string
}

type PartitionLister

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

type Partitioner

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

type Store

type Store struct {
	Partitioner Partitioner
}

func (*Store) ByID

func (s *Store) ByID(apiOp *types.APIRequest, schema *types.APISchema, id string) (types.APIObject, error)

func (*Store) Create

func (s *Store) Create(apiOp *types.APIRequest, schema *types.APISchema, data types.APIObject) (types.APIObject, error)

func (*Store) Delete

func (s *Store) Delete(apiOp *types.APIRequest, schema *types.APISchema, id string) (types.APIObject, error)

func (*Store) List

func (s *Store) List(apiOp *types.APIRequest, schema *types.APISchema) (types.APIObjectList, error)

func (*Store) Update

func (s *Store) Update(apiOp *types.APIRequest, schema *types.APISchema, data types.APIObject, id string) (types.APIObject, error)

func (*Store) Watch

func (s *Store) Watch(apiOp *types.APIRequest, schema *types.APISchema, wr types.WatchRequest) (chan types.APIEvent, error)