pulsar

Documentation

Index

• func NewPulse(previousPulseNumber uint32, entropyGenerator EntropyGenerator) *core.Pulse
• type EntropyGenerator
• type Pulsar
  • func NewPulsar(configuration configuration.Pulsar) *Pulsar
  • func (pulsar *Pulsar) Close()
  • func (pulsar *Pulsar) ConnectToNeighbour(address string, connectionType string) error
  • func (pulsar *Pulsar) Listen()
  • func (pulsar *Pulsar) Send(address string, data interface{})
• type StandardEntropyGenerator
  • func (generator *StandardEntropyGenerator) GenerateEntropy() core.Entropy

Functions

func NewPulse

func NewPulse(previousPulseNumber uint32, entropyGenerator EntropyGenerator) *core.Pulse

Create a new pulse with using of custom Entropy Generator

Types

type EntropyGenerator

type EntropyGenerator interface {
	GenerateEntropy() core.Entropy
}

type Pulsar

type Pulsar struct {
	Sock       net.Listener
	Neighbours map[string]net.Conn
}

func NewPulsar

func NewPulsar(configuration configuration.Pulsar) *Pulsar

func (*Pulsar) Close

func (pulsar *Pulsar) Close()

func (*Pulsar) ConnectToNeighbour

func (pulsar *Pulsar) ConnectToNeighbour(address string, connectionType string) error

func (*Pulsar) Listen

func (pulsar *Pulsar) Listen()

func (*Pulsar) Send

func (pulsar *Pulsar) Send(address string, data interface{})

type StandardEntropyGenerator

type StandardEntropyGenerator struct {
}

func (*StandardEntropyGenerator) GenerateEntropy

func (generator *StandardEntropyGenerator) GenerateEntropy() core.Entropy