replicas

Jan 14, 2025

Changes in this version

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

type Replicas

+ Cluster []uint64

+ Create []uint64

+ Destroy []uint64

+ 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) Recalculate(spread v1.ContainerSpread, replicasDefined uint64, existingIndexes []uint64)

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

Jan 7, 2025

Changes in this version

type Replicas

+ CreateScoped []platforms.IContainer

+ DeleteScoped []platforms.IContainer

Jan 5, 2025

Changes in this version

+ func Empty() ([]uint64, []uint64, []uint64)

Dec 17, 2024

Changes in this version

+ type Distributed struct

+ Group string

+ Name string

+ Replicas map[uint64]*ScopedReplicas

+ Spread string

+ func (dr *Distributed) Clear(node uint64)

+ func (dr *Distributed) FromJson(data []byte) error

+ func (dr *Distributed) Load(client *client.Client, user *authentication.User) error

+ func (dr *Distributed) Remove(client *client.Client, user *authentication.User) (bool, error)

+ func (dr *Distributed) Save(client *client.Client, user *authentication.User) error

+ func (dr *Distributed) ToJson() ([]byte, error)

type Replicas

+ Agent string

+ ChangeLog diff.Changelog

+ Definition *v1.ContainerDefinition

+ Distributed *Distributed

+ Shared *shared.Shared

+ func NewReplica(shared *shared.Shared, agent string, definition *v1.ContainerDefinition, ...) *Replicas

type ScopedReplicas

+ Existing []R

+ func (sr *ScopedReplicas) AddExisting(group string, name string)

Dec 10, 2024

Changes in this version

+ func Default(replicasNumber uint64, existingIndexes []uint64, clusterSize uint64, ...) ([]uint64, []uint64, []uint64)

+ func Specific(replicasNumber uint64, existingIndexes []uint64, nodes []uint64, member uint64) ([]uint64, []uint64, []uint64)

+ func Uniform(replicasNumber uint64, existingIndexes []uint64, clusterSize uint64, ...) ([]uint64, []uint64, []uint64)

+ type DistributedReplicas struct

+ Group string

+ Name string

+ Replicas map[uint64]*ScopedReplicas

+ func NewDistributed(nodeID uint64, group string, name string) *DistributedReplicas

+ func (dr *DistributedReplicas) Clear(node uint64)

+ func (dr *DistributedReplicas) FromJson(data []byte) error

+ func (dr *DistributedReplicas) Load(client *client.Client, user *authentication.User) error

+ func (dr *DistributedReplicas) Save(client *client.Client, user *authentication.User) error

+ func (dr *DistributedReplicas) ToJson() ([]byte, error)

+ type Numbers struct

+ Create []uint64

+ Destroy []uint64

+ Existing []uint64

+ type R struct

+ Group string

+ Name string

+ type Replicas struct

+ Changed bool

+ ExistingIndexes []uint64

+ GeneratedIndex uint64

+ Group string

+ NodeID uint64

+ Replicas uint64

+ Spread v1.ContainerSpread

+ func (replicas *Replicas) GetReplica(shared *shared.Shared, user *authentication.User, ...) ([]R, error)

+ func (replicas *Replicas) GetReplicaNumbers(dr *DistributedReplicas, spread v1.ContainerSpread, replicasNumber uint64, ...) ([]uint64, []uint64, []uint64)

+ func (replicas *Replicas) HandleReplica(shared *shared.Shared, user *authentication.User, clstr []string, ...) (*DistributedReplicas, error)

+ type ScopedReplicas struct

+ Create []R

+ Numbers Numbers

+ Remove []R

+ func NewScoped() *ScopedReplicas

+ func (sr *ScopedReplicas) Add(group string, name string)

+ func (sr *ScopedReplicas) Delete(group string, name string)