Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

smudge

package module

Go to main page

Versions in this module

v1

v1.0.1

Jul 6, 2020

v1.0.0

Jul 22, 2018

Changes in this version

+ const DefaultClusterName

+ const DefaultListenIP

+ const DefaultMinPingTime

+ const DefaultMulticastAddress

+ const DefaultMulticastAnnounceIntervalSeconds

+ const DefaultMulticastEnabled

+ const DefaultMulticastPort

+ const DefaultPingHistoryFrontload

+ const EnvVarClusterName

+ const EnvVarListenIP

+ const EnvVarMinPingTime

+ const EnvVarMulticastAddress

+ const EnvVarMulticastAnnounceIntervalSeconds

+ const EnvVarMulticastEnabled

+ const EnvVarMulticastPort

+ const EnvVarPingHistoryFrontload

+ const PingNoData

+ const PingTimedOut

+ func GetClusterName() string

+ func GetListenIP() net.IP

+ func GetMinPingTime() int

+ func GetMulticastAddress() string

+ func GetMulticastAnnounceIntervalSeconds() int

+ func GetMulticastEnabled() bool

+ func GetMulticastPort() int

+ func GetPingHistoryFrontload() int

+ func SetClusterName(val string)

+ func SetListenIP(val net.IP)

+ func SetLogger(l Logger)

+ func SetMinPingTime(val int)

+ func SetMulticastAddress(val string)

+ func SetMulticastAnnounceIntervalSeconds(val int)

+ func SetMulticastEnabled(val bool)

+ func SetMulticastPort(val int)

+ func SetPingHistoryFrontload(val int)

+ type DefaultLogger struct

+ func (d DefaultLogger) Log(level LogLevel, a ...interface{}) (n int, err error)

+ func (d DefaultLogger) Logf(level LogLevel, format string, a ...interface{}) (n int, err error)

+ type Logger interface

+ Log func(level LogLevel, a ...interface{}) (int, error)

+ Logf func(level LogLevel, format string, a ...interface{}) (int, error)

type Node

+ func (n *Node) PingMillis() int

+ func (n *Node) StatusSource() *Node

type NodeStatus

+ const StatusSuspected

v0

v0.2.0

Jan 8, 2017

v0.1.0

Jan 8, 2017

Changes in this version

+ const DefaultHeartbeatMillis

+ const DefaultInitialHosts

+ const DefaultListenPort

+ const DefaultMaxBroadcastBytes

+ const EnvVarHeartbeatMillis

+ const EnvVarInitialHosts

+ const EnvVarListenPort

+ const EnvVarMaxBroadcastBytes

+ func AddBroadcastListener(listener BroadcastListener)

+ func AddStatusListener(listener StatusListener)

+ func Begin()

+ func BroadcastBytes(bytes []byte) error

+ func BroadcastString(str string) error

+ func GetHeartbeatMillis() int

+ func GetInitialHosts() []string

+ func GetListenPort() int

+ func GetLocalIP() (net.IP, error)

+ func GetMaxBroadcastBytes() int

+ func GetNowInMillis() uint32

+ func PingNode(node *Node) error

+ func SetHeartbeatMillis(val int)

+ func SetListenPort(val int)

+ func SetLogThreshold(level LogLevel)

+ func SetMaxBroadcastBytes(val int)

+ func UpdateNodeStatus(node *Node, status NodeStatus)

+ type Broadcast struct

+ func (b *Broadcast) Bytes() []byte

+ func (b *Broadcast) Index() uint32

+ func (b *Broadcast) Label() string

+ func (b *Broadcast) Origin() *Node

+ type BroadcastListener interface

+ OnBroadcast func(broadcast *Broadcast)

+ type LogLevel byte

+ const LogAll

+ const LogDebug

+ const LogError

+ const LogFatal

+ const LogInfo

+ const LogOff

+ const LogTrace

+ const LogWarn

+ func (s LogLevel) String() string

+ type Node struct

+ func AddNode(node *Node) (*Node, error)

+ func AllNodes() []*Node

+ func CreateNodeByAddress(address string) (*Node, error)

+ func CreateNodeByIP(ip net.IP, port uint16) (*Node, error)

+ func HealthyNodes() []*Node

+ func RemoveNode(node *Node) (*Node, error)

+ func (n *Node) Address() string

+ func (n *Node) Age() uint32

+ func (n *Node) EmitCounter() int8

+ func (n *Node) IP() net.IP

+ func (n *Node) Port() uint16

+ func (n *Node) Status() NodeStatus

+ func (n *Node) Timestamp() uint32

+ func (n *Node) Touch()

+ type NodeStatus byte

+ const StatusAlive

+ const StatusDead

+ const StatusForwardTo

+ const StatusUnknown

+ func (s NodeStatus) String() string

+ type StatusListener interface

+ OnChange func(node *Node, status NodeStatus)