connector

package
v0.0.0-...-8fb0621 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 17, 2021 License: MPL-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package connector : Main function for connector

Index

Constants

This section is empty.

Variables

This section is empty.

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 (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)

Directories

Path Synopsis
Package grpc :
Package grpc :
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 utils :
Package utils :

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL