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 (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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateDirectory ¶
func DirectoryExist ¶
func SaveConfiguration ¶
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) 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)
Directories ¶
Path | Synopsis |
---|---|
* Swagger Gandalf * * This is a sample Petstore server.
|
* Swagger Gandalf * * This is a sample Petstore server. |
Package shoset : Package shoset : Package shoset : Package shoset : Package shoset : Package shoset : Package shoset :
|
Package shoset : Package shoset : Package shoset : Package shoset : Package shoset : Package shoset : Package shoset : |
Click to show internal directories.
Click to hide internal directories.