aggregator

Documentation

Overview

Package aggregator : Main function for aggregator

Index

• func CreateDirectory(path string) error
• func DirectoryExist(path string) bool
• func SaveConfiguration(configPath string, offset int)
• type AggregatorMember
  • func AggregatorMemberInit(configurationAggregator *cmodels.ConfigurationAggregator) *AggregatorMember
  • func NewAggregatorMember(configurationAggregator *cmodels.ConfigurationAggregator) *AggregatorMember
  • func (m *AggregatorMember) Bind(addr string) error
  • func (m *AggregatorMember) GetChaussette() *net.Shoset
  • func (m *AggregatorMember) GetConfigurationDatabase(nshoset *net.Shoset) (*models.ConfigurationDatabaseAggregator, error)
  • func (m *AggregatorMember) GetLogicalConfiguration(nshoset *net.Shoset) (*models.LogicalComponent, error)
  • func (m *AggregatorMember) GetPivot(nshoset *net.Shoset) (*models.Pivot, error)
  • func (m *AggregatorMember) Join(addr string) (*net.ShosetConn, error)
  • func (m *AggregatorMember) Link(addr string) (*net.ShosetConn, error)
  • func (m *AggregatorMember) StartAPI(bindAdress string, databaseConnection *database.DatabaseConnection, ...)
  • func (m *AggregatorMember) StartHeartbeat(nshoset *net.Shoset)
  • func (m *AggregatorMember) ValidateSecret(nshoset *net.Shoset) (bool, error)

Functions

func CreateDirectory

func CreateDirectory(path string) error

func DirectoryExist

func DirectoryExist(path string) bool

func SaveConfiguration

func SaveConfiguration(configPath string, offset int)

Types

type AggregatorMember

type AggregatorMember struct {
	// contains filtered or unexported fields
}

AggregatorMember : Aggregator struct.

func AggregatorMemberInit

func AggregatorMemberInit(configurationAggregator *cmodels.ConfigurationAggregator) *AggregatorMember

AggregatorMemberInit : Aggregator init function.

func NewAggregatorMember

func NewAggregatorMember(configurationAggregator *cmodels.ConfigurationAggregator) *AggregatorMember

NewAggregatorMember :

func (*AggregatorMember) Bind

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

Bind : Aggregator bind function.

func (*AggregatorMember) GetChaussette

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

GetChaussette : Aggregator chaussette getter.

func (*AggregatorMember) GetConfigurationDatabase

func (m *AggregatorMember) GetConfigurationDatabase(nshoset *net.Shoset) (*models.ConfigurationDatabaseAggregator, error)

func (*AggregatorMember) GetLogicalConfiguration

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

func (*AggregatorMember) GetPivot

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

func (*AggregatorMember) Join

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

Join : Aggregator join function.

func (*AggregatorMember) Link

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

Link : Aggregator link function.

func (*AggregatorMember) StartAPI

func (m *AggregatorMember) StartAPI(bindAdress string, databaseConnection *database.DatabaseConnection, shoset *net.Shoset)

StartAPI :

func (*AggregatorMember) StartHeartbeat

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

StartHeartbeat :

func (*AggregatorMember) ValidateSecret

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