replicas

Documentation

Index

• func Default(replicasNumber uint64, existingIndexes []uint64) ([]uint64, []uint64, []uint64)
• func Empty() ([]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 Distributed
  • func NewDistributed(nodeID uint64, group string, name string) *Distributed
  • 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 Numbers
• type R
• type Replicas
  • func NewReplica(shared *shared.Shared, agent string, definition *v1.ContainerDefinition, ...) *Replicas
  • func (replicas *Replicas) GetReplica(user *authentication.User, clstr []string) (*Distributed, error)
  • func (replicas *Replicas) GetReplicaNumbers(dr *Distributed, spread v1.ContainerSpread, replicasNumber uint64, ...) ([]uint64, []uint64, []uint64)
  • func (replicas *Replicas) HandleReplica(user *authentication.User, clstr []string) (*Distributed, error)
• type ScopedReplicas
  • func NewScoped() *ScopedReplicas
  • func (sr *ScopedReplicas) Add(group string, name string)
  • func (sr *ScopedReplicas) AddExisting(group string, name string)
  • func (sr *ScopedReplicas) Delete(group string, name string)

Functions

func Default

func Default(replicasNumber uint64, existingIndexes []uint64) ([]uint64, []uint64, []uint64)

func Empty

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

func Specific

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

func Uniform

func Uniform(replicasNumber uint64, existingIndexes []uint64, clusterSize uint64, member uint64) ([]uint64, []uint64, []uint64)

Types

type Distributed

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

func NewDistributed

func NewDistributed(nodeID uint64, group string, name string) *Distributed

func (*Distributed) Clear

func (dr *Distributed) Clear(node uint64)

func (*Distributed) FromJson

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

func (*Distributed) Load

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

func (*Distributed) Remove

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

func (*Distributed) Save

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

func (*Distributed) ToJson

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

type Numbers

type Numbers struct {
	Create   []uint64
	Destroy  []uint64
	Existing []uint64
}

type R

type R struct {
	Group string
	Name  string
}

type Replicas

type Replicas struct {
	NodeID          uint64
	Definition      *v1.ContainerDefinition
	Shared          *shared.Shared
	Distributed     *Distributed
	Agent           string
	ChangeLog       diff.Changelog
	Spread          v1.ContainerSpread
	ExistingIndexes []uint64
}

func NewReplica

func NewReplica(shared *shared.Shared, agent string, definition *v1.ContainerDefinition, changelog diff.Changelog) *Replicas

func (*Replicas) GetReplica

func (replicas *Replicas) GetReplica(user *authentication.User, clstr []string) (*Distributed, error)

func (*Replicas) GetReplicaNumbers

func (replicas *Replicas) GetReplicaNumbers(dr *Distributed, spread v1.ContainerSpread, replicasNumber uint64, existingIndexes []uint64, clusterSize uint64) ([]uint64, []uint64, []uint64)

func (*Replicas) HandleReplica

func (replicas *Replicas) HandleReplica(user *authentication.User, clstr []string) (*Distributed, error)

type ScopedReplicas

type ScopedReplicas struct {
	Create   []R
	Remove   []R
	Existing []R
	Numbers  Numbers
}

func NewScoped

func NewScoped() *ScopedReplicas

func (*ScopedReplicas) Add

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

func (*ScopedReplicas) AddExisting

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

func (*ScopedReplicas) Delete

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