bmmc

Documentation

Index

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

Constants

const (

	// NOCALLBACK is callback type for messages without callback
	NOCALLBACK = callback.NOCALLBACK
)

Functions

func RunWithSpec

func RunWithSpec(retries int,
	noPeers int,
	loss float64,
	beta float64,
	cbRegistry map[string]func(interface{}, *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 interface{}, callbackType string) error

func (*Bmmc) AddPeer

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

func (*Bmmc) GetMessages

func (b *Bmmc) GetMessages() []interface{}

func (*Bmmc) RemovePeer

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

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
	Addr string
	// Port is HTTP port for node which runs gossip  and http servers
	// Required
	Port string
	// Beta is the expected fanout for gossip rounds
	// Optional
	Beta float64
	// Logger
	// Optional
	Logger *log.Logger
	// Callbacks funtions
	// Optional
	Callbacks map[string]func(interface{}, *log.Logger) (bool, error)
}