connector

Documentation

Overview

Package connector : Main function for connector

Index

• func CreateDirectory(path string) error
• func DirectoryExist(path string) bool
• func SaveConfiguration(offset int)
• type ConnectorMember
  • func ConnectorMemberInit(configurationConnector *cmodels.ConfigurationConnector) (*ConnectorMember, error)
  • func NewConnectorMember(configurationConnector *cmodels.ConfigurationConnector) *ConnectorMember
  • func (m *ConnectorMember) Bind(addr string) error
  • func (m *ConnectorMember) GetChaussette() *net.Shoset
  • func (m *ConnectorMember) GetConnectorGrpc() grpc.ConnectorGrpc
  • func (m *ConnectorMember) GetLogicalConfiguration(nshoset *net.Shoset) (*models.LogicalComponent, error)
  • func (m *ConnectorMember) GetPivotConfiguration(nshoset *net.Shoset) (*models.Pivot, error)
  • func (m *ConnectorMember) GetTimeoutMax() int64
  • func (m *ConnectorMember) GrpcBind(grpcBindAddress string) (err error)
  • func (m *ConnectorMember) Join(addr string) (*net.ShosetConn, error)
  • func (m *ConnectorMember) Link(addr string) (*net.ShosetConn, error)
  • func (m *ConnectorMember) StartHeartbeat(nshoset *net.Shoset)
  • func (m *ConnectorMember) StartWorkerAdmin(chaussette *net.Shoset)
  • func (m *ConnectorMember) 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(offset int)

Types

type ConnectorMember

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

ConnectorMember : Connector struct.

func ConnectorMemberInit

func ConnectorMemberInit(configurationConnector *cmodels.ConfigurationConnector) (*ConnectorMember, error)

ConnectorMemberInit : Connector init function.

func NewConnectorMember

func NewConnectorMember(configurationConnector *cmodels.ConfigurationConnector) *ConnectorMember

NewConnectorMember : Connector struct constructor.

func (*ConnectorMember) Bind

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

Bind : Connector bind function.

func (*ConnectorMember) GetChaussette

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

GetChaussette : Connector chaussette getter.

func (*ConnectorMember) GetConnectorGrpc

func (m *ConnectorMember) GetConnectorGrpc() grpc.ConnectorGrpc

GetConnectorGrpc : Connector grpc getter.

func (*ConnectorMember) GetLogicalConfiguration

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

func (*ConnectorMember) GetPivotConfiguration

func (m *ConnectorMember) GetPivotConfiguration(nshoset *net.Shoset) (*models.Pivot, error)

func (*ConnectorMember) GetTimeoutMax

func (m *ConnectorMember) GetTimeoutMax() int64

GetTimeoutMax : Connector timeoutmax getter.

func (*ConnectorMember) GrpcBind

func (m *ConnectorMember) GrpcBind(grpcBindAddress string) (err error)

GrpcBind : Connector grpcbind function.

func (*ConnectorMember) Join

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

Join : Connector join function.

func (*ConnectorMember) Link

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

Link : Connector link function.

func (*ConnectorMember) StartHeartbeat

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

StartHeartbeat :

func (*ConnectorMember) StartWorkerAdmin

func (m *ConnectorMember) StartWorkerAdmin(chaussette *net.Shoset)

ConfigurationValidation : Validation configuration

func (*ConnectorMember) ValidateSecret

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