bmmc

Documentation

Index

• func RunWithSpec(retries int, noPeers int, loss float64, beta float64, ...) error
• type Bmmc
  • func New(cfg *Config) (*Bmmc, error)
  • func (b *Bmmc) AddMessage(msg, callbackType string)
  • func (b *Bmmc) AddPeer(addr, port string)
  • func (b *Bmmc) GetMessages() []string
  • func (b *Bmmc) RemovePeer(addr, port string)
  • func (b *Bmmc) Start() error
  • func (b *Bmmc) Stop()
• type Config
• type Peer

Functions

func RunWithSpec

func RunWithSpec(retries int,
	noPeers int,
	loss float64,
	beta float64,
	cbRegistry map[string]func(string, *log.Logger) (bool, error),
	cbType string,
	timeout time.Duration) error

Types

type Bmmc

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

func New

func New(cfg *Config) (*Bmmc, error)

New creates a new instance for the protocol

func (*Bmmc) AddMessage

func (b *Bmmc) AddMessage(msg, callbackType string)

func (*Bmmc) AddPeer

func (b *Bmmc) AddPeer(addr, port string)

func (*Bmmc) GetMessages

func (b *Bmmc) GetMessages() []string

func (*Bmmc) RemovePeer

func (b *Bmmc) RemovePeer(addr, port string)

func (*Bmmc) Start

func (b *Bmmc) Start() error

Start starts the gossip server and the http server

func (*Bmmc) Stop

func (b *Bmmc) Stop()

Stop stops the gossip server and the http server

type Config

type Config struct {
	// Addr is HTTP address for node which runs gossip and http servers
	// Required field
	Addr string
	// Port is HTTP port for node which runs gossip  and http servers
	// Required field
	Port string
	// PeerBuf is the list of peers
	// Optional field
	Peers []Peer
	// Beta is the expected fanout for gossip rounds
	// Optional field
	Beta float64
	// Logger
	// Optional field
	Logger *log.Logger
	// Callbacks funtions
	// Optional field
	Callbacks map[string]func(string, *log.Logger) (bool, error)
}

type Peer

type Peer struct {
	Addr string
	Port string
}