Documentation
¶
Index ¶
- type Etcd
- func (e *Etcd) Allocate(offset int) (bool, error)
- func (e *Etcd) AllocateNext() (int, bool, error)
- func (e *Etcd) CreateOrUpdate(snapshot *api.RangeAllocation) error
- func (e *Etcd) Free() int
- func (e *Etcd) Get() (*api.RangeAllocation, error)
- func (e *Etcd) Has(item int) bool
- func (e *Etcd) Refresh() (*api.RangeAllocation, error)
- func (e *Etcd) Release(item int) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Etcd ¶
type Etcd struct {
// contains filtered or unexported fields
}
Etcd exposes a service.Allocator that is backed by etcd. TODO: allow multiple allocations to be tried at once TODO: subdivide the keyspace to reduce conflicts TODO: investigate issuing a CAS without reading first
func NewEtcd ¶
func NewEtcd(alloc allocator.Snapshottable, baseKey string, resource unversioned.GroupResource, storage storage.Interface) *Etcd
NewEtcd returns an allocator that is backed by Etcd and can manage persisting the snapshot state of allocation after each allocation is made.
func (*Etcd) AllocateNext ¶
AllocateNext attempts to allocate the next item locally and then in etcd.
func (*Etcd) CreateOrUpdate ¶
func (e *Etcd) CreateOrUpdate(snapshot *api.RangeAllocation) error
CreateOrUpdate attempts to update the current etcd state with the provided allocation.
func (*Etcd) Get ¶
func (e *Etcd) Get() (*api.RangeAllocation, error)
Get returns an api.RangeAllocation that represents the current state in etcd. If the key does not exist, the object will have an empty ResourceVersion.
Source Files
Click to show internal directories.
Click to hide internal directories.