core

Documentation

Overview

Package core maintains common configuration values used in the network it also encodes and decodes internal and external messages and queries

Index

• Constants
• type Config
  • func DefaultConfig() *Config
  • func (c *Config) AgentHelloEvent(address string) (*sentry.SignedMessage, error)
  • func (c *Config) Init()
  • func (c *Config) Sentry() *sentry.Sentry
• type Event
• type EventType
  • func (e EventType) String() string
• type GossipEvent
• type HelloEvent
  • func (u HelloEvent) EventType() EventType
  • func (u HelloEvent) String() string
• type HelloPayload
• type LeaveEvent
  • func (u LeaveEvent) EventType() EventType
  • func (u LeaveEvent) String() string
• type State
  • func (s State) String() string
• type UpdateEvent
  • func (u UpdateEvent) EventType() EventType
  • func (u UpdateEvent) String() string

Constants

const (
	// DefaultEventChannelSize ...
	DefaultEventChannelSize = 64
)

Types

type Config

type Config struct {
	sync.Once
	Initialized     bool
	LogOutput       io.Writer
	Logger          *log.Logger
	ShutdownCh      chan struct{}
	DevelopmentMode bool
	NodeName        string
	ExternalEventCh chan Event
	InrernalEventCh chan Event
	// contains filtered or unexported fields
}

Config ...

func DefaultConfig

func DefaultConfig() *Config

DefaultConfig ...

func (*Config) AgentHelloEvent

func (c *Config) AgentHelloEvent(address string) (*sentry.SignedMessage, error)

AgentHelloEvent ...

func (*Config) Init

func (c *Config) Init()

Init ...

func (*Config) Sentry

func (c *Config) Sentry() *sentry.Sentry

Sentry ...

type Event

type Event interface {
	EventType() EventType
	String() string
}

Event ...

type EventType

type EventType int

EventType ...

const (
	// EventPeerAdded ...
	EventHello EventType = iota
	// Update ...
	EventUpdate
	// Leave ...
	EventLeave
)

func (EventType) String

func (e EventType) String() string

String ...

type GossipEvent

type GossipEvent struct {
	LTime   lamportclock.LamportTime
	Name    string
	Payload []byte
}

GossipEvent ...

type HelloEvent

type HelloEvent GossipEvent

HelloEvent ...

func (HelloEvent) EventType

func (u HelloEvent) EventType() EventType

EventType ...

func (HelloEvent) String

func (u HelloEvent) String() string

String ...

type HelloPayload

type HelloPayload struct {
	YourAddr string
}

HelloPayload ...

type LeaveEvent

type LeaveEvent GossipEvent

LeaveEvent ...

func (LeaveEvent) EventType

func (u LeaveEvent) EventType() EventType

EventType ...

func (LeaveEvent) String

func (u LeaveEvent) String() string

String ...

type State

type State uint32

State ...

const (
	// Initialized ...
	Initialized State = iota
	// Running ...
	Running
	// Shutdown ...
	Shutdown
)

func (State) String

func (s State) String() string

String ...

type UpdateEvent

type UpdateEvent GossipEvent

UpdateEvent ...

func (UpdateEvent) EventType

func (u UpdateEvent) EventType() EventType

EventType ...

func (UpdateEvent) String

func (u UpdateEvent) String() string

String ...