cluster

Documentation

Overview

Package cluster : Main function for cluster

Index

• func ChangePort(addr string, port int) (string, bool)
• func ChangePortOffSet(addr string, delta int) (string, bool)
• func CreateDirectory(path string) error
• func CreateStore(bros []string, port int) string
• func CreateStoreOffSet(bros []string, delta int) string
• func DirectoryExist(path string) bool
• func SaveConfiguration(offset int)
• type ClusterMember
  • func ClusterMemberInit(configurationCluster *cmodels.ConfigurationCluster) *ClusterMember
  • func ClusterMemberJoin(configurationCluster *cmodels.ConfigurationCluster) *ClusterMember
  • func NewClusterMember(configurationCluster *cmodels.ConfigurationCluster) *ClusterMember
  • func (m *ClusterMember) Bind(addr string) error
  • func (m *ClusterMember) DownloadPivot(nshoset *net.Shoset, client *gorm.DB, baseurl, componentType string, ...) (*models.Pivot, error)
  • func (m *ClusterMember) GetChaussette() *net.Shoset
  • func (m *ClusterMember) GetInitLogicalConfiguration(client *gorm.DB, logicalName string) (*models.LogicalComponent, error)
  • func (m *ClusterMember) GetInitPivot(client *gorm.DB, componentType string, version models.Version) (*models.Pivot, error)
  • func (m *ClusterMember) GetLogicalConfiguration(nshoset *net.Shoset) (*models.LogicalComponent, error)
  • func (m *ClusterMember) GetPivot(nshoset *net.Shoset) (*models.Pivot, error)
  • func (m *ClusterMember) Join(addr string) (*net.ShosetConn, error)
  • func (m *ClusterMember) Link(addr string) (*net.ShosetConn, error)
  • func (m *ClusterMember) SaveLogicalComponent(client *gorm.DB, configurationCluster *cmodels.ConfigurationCluster) (*models.LogicalComponent, error)
  • func (m *ClusterMember) StartHeartbeat(nshoset *net.Shoset)
  • func (m *ClusterMember) ValidateSecret(nshoset *net.Shoset) (bool, error)

Functions

func ChangePort

func ChangePort(addr string, port int) (string, bool)

func ChangePortOffSet

func ChangePortOffSet(addr string, delta int) (string, bool)

func CreateDirectory

func CreateDirectory(path string) error

func CreateStore

func CreateStore(bros []string, port int) string

CreateStore : Cluster create store function.

func CreateStoreOffSet

func CreateStoreOffSet(bros []string, delta int) string

CreateStore : Cluster create store function.

func DirectoryExist

func DirectoryExist(path string) bool

func SaveConfiguration

func SaveConfiguration(offset int)

Types

type ClusterMember

type ClusterMember struct {
	Store              *[]string
	DatabaseConnection *database.DatabaseConnection
	// contains filtered or unexported fields
}

ClusterMember : Cluster struct.

func ClusterMemberInit

func ClusterMemberInit(configurationCluster *cmodels.ConfigurationCluster) *ClusterMember

TODO REVOIR ClusterMemberInit : Cluster init function.

func ClusterMemberJoin

func ClusterMemberJoin(configurationCluster *cmodels.ConfigurationCluster) *ClusterMember

ClusterMemberJoin : Cluster join function.

func NewClusterMember

func NewClusterMember(configurationCluster *cmodels.ConfigurationCluster) *ClusterMember

NewClusterMember : Cluster struct constructor.

func (*ClusterMember) Bind

func (m *ClusterMember) Bind(addr string) error

Bind : Cluster bind function.

func (*ClusterMember) DownloadPivot

func (m *ClusterMember) DownloadPivot(nshoset *net.Shoset, client *gorm.DB, baseurl, componentType string, version models.Version) (*models.Pivot, error)

TODO REVOIR ERROR

func (*ClusterMember) GetChaussette

func (m *ClusterMember) GetChaussette() *net.Shoset

GetChaussette : Cluster chaussette getter.

func (*ClusterMember) GetInitLogicalConfiguration

func (m *ClusterMember) GetInitLogicalConfiguration(client *gorm.DB, logicalName string) (*models.LogicalComponent, error)

func (*ClusterMember) GetInitPivot

func (m *ClusterMember) GetInitPivot(client *gorm.DB, componentType string, version models.Version) (*models.Pivot, error)

TODO REVOIR ERROR

func (*ClusterMember) GetLogicalConfiguration

func (m *ClusterMember) GetLogicalConfiguration(nshoset *net.Shoset) (*models.LogicalComponent, error)

func (*ClusterMember) GetPivot

func (m *ClusterMember) GetPivot(nshoset *net.Shoset) (*models.Pivot, error)

func (*ClusterMember) Join

func (m *ClusterMember) Join(addr string) (*net.ShosetConn, error)

Join : Cluster join function.

func (*ClusterMember) Link

func (m *ClusterMember) Link(addr string) (*net.ShosetConn, error)

Link : Cluster link function.

func (*ClusterMember) SaveLogicalComponent

func (m *ClusterMember) SaveLogicalComponent(client *gorm.DB, configurationCluster *cmodels.ConfigurationCluster) (*models.LogicalComponent, error)

func (*ClusterMember) StartHeartbeat

func (m *ClusterMember) StartHeartbeat(nshoset *net.Shoset)

StartHeartbeat :

func (*ClusterMember) ValidateSecret

func (m *ClusterMember) ValidateSecret(nshoset *net.Shoset) (bool, error)