brokerc

Documentation

Overview

Package brokerc provides functionality to create a Broker Client

Index

• type Client
  • func New(config Config, connectionHandler p2pc.NewConnectionHandler, ...) (c *Client, err error)
  • func (c *Client) Close()
  • func (c *Client) Connect() (err error)
• type Config

Types

type Client

type Client struct {

	// Connect to peer by ID
	ConnectPeerById func(peerId string, mode p2p.ConnectionMode) (conn *p2pc.Connection, err error)
	// Connect to peer by Tag
	ConnectPeerByTag func(tag string, mode p2p.ConnectionMode) (conn *p2pc.Connection, err error)

	// Client exit channel
	Exit chan bool
	// contains filtered or unexported fields
}

Broker Client

func New

func New(
	config Config,
	connectionHandler p2pc.NewConnectionHandler,
	streamHandler udp.StreamHandler,
) (c *Client, err error)

Create Client

func (*Client) Close

func (c *Client) Close()

Close Client

func (*Client) Connect

func (c *Client) Connect() (err error)

Connect to Broker Server

type Config

type Config struct {
	// Debug Mode
	Debug bool
	// UDP Client Config
	UdpcConfig udpc.Config
	// P2P Client Manager Config
	P2PConfig p2pc.Config
}

Broker Client Config