replicas

Documentation

Index

• func ChunkSlice(slice []uint64, numChunks int) [][]uint64
• func Specific(replicasWanted uint64, existingIndexes []uint64, nodes []uint64, member uint64) ([]uint64, []uint64)
• func Uniform(replicasWanted uint64, existingIndexes []uint64, cluster []uint64, ...) ([]uint64, []uint64)
• type Distributed
• type Replicas
  • func New(nodeID uint64, nodes []*node.Node) *Replicas
  • func (replicas *Replicas) GenerateContainers(registry *registry.Registry, definition *v1.ContainerDefinition, ...) ([]platforms.IContainer, []platforms.IContainer, error)
  • func (replicas *Replicas) GetContainersIndexes(registry *registry.Registry, definition *v1.ContainerDefinition) ([]uint64, []uint64)
  • func (replicas *Replicas) GetReplicaNumbers(spread v1.ContainerSpread, replicasDefined uint64, existingIndexes []uint64) ([]uint64, []uint64)
  • func (replicas *Replicas) Recalculate(spread v1.ContainerSpread, replicasDefined uint64, existingIndexes []uint64)
  • func (replicas *Replicas) RemoveContainers(registry *registry.Registry, definition *v1.ContainerDefinition) ([]platforms.IContainer, error)

Functions

func ChunkSlice

func ChunkSlice(slice []uint64, numChunks int) [][]uint64

func Specific

func Specific(replicasWanted uint64, existingIndexes []uint64, nodes []uint64, member uint64) ([]uint64, []uint64)

func Uniform

func Uniform(replicasWanted uint64, existingIndexes []uint64, cluster []uint64, member uint64) ([]uint64, []uint64)

Types

type Distributed

type Distributed struct {
	Group    string
	Name     string
	Spread   string
	Replicas map[uint64]*Replicas
}

type Replicas

type Replicas struct {
	NodeID  uint64
	Create  []uint64
	Destroy []uint64
	Cluster []uint64
}

func New

func New(nodeID uint64, nodes []*node.Node) *Replicas

func (*Replicas) GenerateContainers

func (replicas *Replicas) GenerateContainers(registry *registry.Registry, definition *v1.ContainerDefinition, config *configuration.Configuration) ([]platforms.IContainer, []platforms.IContainer, error)

func (*Replicas) GetContainersIndexes

func (replicas *Replicas) GetContainersIndexes(registry *registry.Registry, definition *v1.ContainerDefinition) ([]uint64, []uint64)

func (*Replicas) GetReplicaNumbers

func (replicas *Replicas) GetReplicaNumbers(spread v1.ContainerSpread, replicasDefined uint64, existingIndexes []uint64) ([]uint64, []uint64)

func (*Replicas) Recalculate

func (replicas *Replicas) Recalculate(spread v1.ContainerSpread, replicasDefined uint64, existingIndexes []uint64)

func (*Replicas) RemoveContainers

func (replicas *Replicas) RemoveContainers(registry *registry.Registry, definition *v1.ContainerDefinition) ([]platforms.IContainer, error)