service

type ClusterBootstrapAnnounce struct {
	SenderName string
	Bootstrap  string
	Secret     string
}

type ClusterBootstrapProtocol struct {
	*onet.TreeNodeInstance

	Ready      chan bool
	Info       ClusterInfo
	GetService FnService
	// contains filtered or unexported fields
}

type ClusterBootstrapReply struct {
	Cluster *[]ClusterInstance
}

type ClusterInfo struct {
	Leader    string
	Secret    string
	Size      int
	Instances []ClusterInstance
}

type ClusterInstance struct {
	HostName      string
	IP            string
	IPFSAPIAddr   string
	RestAPIPort   int
	IPFSProxyPort int
	ClusterPort   int
}

type FnService func() *Service

type IPFSInformation struct {
	Name        string
	IP          string
	SwarmPort   int
	APIPort     int
	GatewayPort int
}

type InitRequest struct {
	Nodes                []*gentree.LocalityNode
	ServerIdentityToName map[*network.ServerIdentity]string
	OnetTree             *onet.Tree
	Roster               *onet.Roster
	Cruxified            bool
	ComputePings         bool
	Mode                 string
}

type InitResponse struct {
}

type NodeInfo struct {
	IPFS     IPFSInformation
	Clusters []ClusterInfo
}

type ReplyPings struct {
	Pings      string
	SenderName string
}

type ReqPings struct {
	SenderName string
}

type Service struct {
	// We need to embed the ServiceProcessor, so that incoming messages
	// are correctly handled.
	*onet.ServiceProcessor

	Nodes        gentree.LocalityNodes
	LocalityTree *onet.Tree
	Parents      []*onet.TreeNode
	GraphTree    map[string][]gentree.GraphTree
	BinaryTree   map[string][]*onet.Tree

	Distances map[*gentree.LocalityNode]map[*gentree.LocalityNode]float64

	PortMutex *sync.Mutex
	W         *bufio.Writer
	File      *os.File

	BandwidthRx uint64
	BandwidthTx uint64
	NrMsgRx     uint64
	NrMsgTx     uint64

	NrProtocolsStarted uint64

	OwnPings      map[string]float64
	DonePing      bool
	PingDistances map[string]map[string]float64
	NrPingAnswers int
	PingAnswerMtx sync.Mutex
	PingMapMtx    sync.Mutex

	Name       string // name of the service (node_2)
	MyIP       string // IP address
	ConfigPath string // path to home config folder
	MyIPFSPath string // path to ipfs config folder of that service
	MinPort    int    // port range allocated to this node
	MaxPort    int
	MyIPFS     []IPFSInformation          // own ipfs information
	OtherIPFS  map[string]IPFSInformation // node_x -> IP, ports etc.

	OnetTree      *onet.Tree
	StartIPFSProt onet.ProtocolInstance
	// contains filtered or unexported fields
}

type StartARAAnnounce struct {
	SenderName string
	Bootstrap  string
	Secret     string
}

type StartARAProtocol struct {
	*onet.TreeNodeInstance

	Ready      chan bool
	Info       ClusterInfo
	GetService FnService
	// contains filtered or unexported fields
}

type StartARAReply struct {
	Cluster *[]ClusterInstance
}

type StartIPFSAnnounce struct {
	Message string
}

type StartIPFSProtocol struct {
	*onet.TreeNodeInstance

	Ready      chan bool
	GetService FnService
	Nodes      map[string]*NodeInfo
	// contains filtered or unexported fields
}

type StartIPFSReply struct {
	IPFS     *IPFSInformation
	Clusters *[]ClusterInfo
}

type StartInstancesAnnounce struct{}

type StartInstancesProtocol struct {
	*onet.TreeNodeInstance

	Ready      chan bool
	GetService FnService
	Nodes      map[string]*NodeInfo
	// contains filtered or unexported fields
}

type StartInstancesReply struct {
	Node *NodeInfo
}