Versions in this module Expand all Collapse all v0 v0.1.1 Oct 23, 2013 v0.1.0 Oct 23, 2013 Changes in this version + const UserEventSizeLimit + type Config struct + BroadcastTimeout time.Duration + CoalescePeriod time.Duration + EventBuffer int + EventCh chan<- Event + LogOutput io.Writer + MemberlistConfig *memberlist.Config + NodeName string + QueueDepthWarning int + QuiescentPeriod time.Duration + ReapInterval time.Duration + RecentIntentBuffer int + ReconnectInterval time.Duration + ReconnectTimeout time.Duration + Role string + TombstoneTimeout time.Duration + func DefaultConfig() *Config + type Event interface + EventType func() EventType + String func() string + type EventType int + const EventMemberFailed + const EventMemberJoin + const EventMemberLeave + const EventUser + func (t EventType) String() string + type LamportClock struct + func (l *LamportClock) Increment() LamportTime + func (l *LamportClock) Time() LamportTime + func (l *LamportClock) Witness(v LamportTime) + type LamportTime uint64 + type Member struct + Addr net.IP + Name string + Role string + Status MemberStatus + type MemberEvent struct + Members []Member + Type EventType + func (m MemberEvent) EventType() EventType + func (m MemberEvent) String() string + type MemberStatus int + const StatusAlive + const StatusFailed + const StatusLeaving + const StatusLeft + const StatusNone + func (s MemberStatus) String() string + type Serf struct + func Create(conf *Config) (*Serf, error) + func (s *Serf) Join(existing []string) (int, error) + func (s *Serf) Leave() error + func (s *Serf) Members() []Member + func (s *Serf) RemoveFailedNode(node string) error + func (s *Serf) Shutdown() error + func (s *Serf) State() SerfState + func (s *Serf) UserEvent(name string, payload []byte) error + type SerfState int + const SerfAlive + const SerfLeft + const SerfShutdown + type UserEvent struct + Name string + Payload []byte + func (u UserEvent) EventType() EventType + func (u UserEvent) String() string