communication

package
v0.0.0-...-52bbd4c Latest Latest
Warning

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

Go to latest
Published: Mar 31, 2019 License: GPL-3.0 Imports: 17 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GroupConnection

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

GroupConnection is responsible for handling the group's IPFS pubsub subscription

func NewGroupConnection

func NewGroupConnection(
	group interfaces.IGroup,
	repo *fs.GroupRepo,
	user interfaces.IAccount,
	addressBook *common.AddressBook,
	sessionClosed sesscommon.SessionClosedCallback,
	p2p *P2PManager,
	ipfs ipfsapi.IIpfs,
) *GroupConnection

NewGroupConnection creates a new GroupConnection

func (*GroupConnection) Broadcast

func (conn *GroupConnection) Broadcast(msg []byte) error

Broadcast publishes a message to the group topic

func (*GroupConnection) Kill

func (conn *GroupConnection) Kill()

Kill kills the group connection listener

type P2PManager

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

P2PManager is responsible for managing all the incoming libp2p connections

func NewP2PManager

func NewP2PManager(
	port string,
	account interfaces.IAccount,
	signer common.Signer,
	addressBook *common.AddressBook,
	ctxCallback sesscommon.CtxCallback,
	ipfs ipfsapi.IIpfs,
) (*P2PManager, error)

NewP2PManager creates a new P2PManager

func (*P2PManager) AddSession

func (p2p *P2PManager) AddSession(session sesscommon.ISession)

AddSession adds a session to the managers session list

func (*P2PManager) StartGetGroupKeySession

func (p2p *P2PManager) StartGetGroupKeySession(
	group ethcommon.Address,
	receiver *common.Contact,
	sender ethcommon.Address,
	onSuccess sesscommon.OnGetGroupKeySuccessCallback,
) error

StartGetGroupKeySession start a new session for retrieving a group's current key

func (*P2PManager) StartGetProposedGroupKeySession

func (p2p *P2PManager) StartGetProposedGroupKeySession(
	group ethcommon.Address,
	proposer ethcommon.Address,
	receiver *common.Contact,
	sender ethcommon.Address,
	onSuccess sesscommon.OnGetGroupKeySuccessCallback,
) error

StartGetProposedGroupKeySession starts a new session to get a specific proposed key of the group

func (*P2PManager) Stop

func (p2p *P2PManager) Stop()

Stop gracefully kills all threads and processes

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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