serf

Feb 12, 2015

Changes in this version

type Config

+ Merge MergeDelegate

+ type KeyManager struct

+ func (k *KeyManager) InstallKey(key string) (*KeyResponse, error)

+ func (k *KeyManager) ListKeys() (*KeyResponse, error)

+ func (k *KeyManager) RemoveKey(key string) (*KeyResponse, error)

+ func (k *KeyManager) UseKey(key string) (*KeyResponse, error)

+ type MergeDelegate interface

+ NotifyMerge func([]*Member) (cancel bool)

May 8, 2014

Changes in this version

type Config

+ KeyringFile string

+ RejoinAfterLeave bool

+ type KeyResponse struct

+ Keys map[string]int

+ Messages map[string]string

+ NumErr int

+ NumNodes int

+ NumResp int

type Serf

+ func (s *Serf) EncryptionEnabled() bool

+ func (s *Serf) KeyManager() *keyManager

Mar 12, 2014

Changes in this version

+ const InternalQueryPrefix

+ const QueryResponseSizeLimit

+ const QuerySizeLimit

+ var FeatureNotSupported = fmt.Errorf("Feature not supported")

type Config

+ EnableNameConflictResolution bool

+ QueryBuffer int

+ QueryTimeoutMult int

type EventType

+ const EventMemberReap

+ const EventQuery

+ type NodeResponse struct

+ From string

+ Payload []byte

+ type Query struct

+ LTime LamportTime

+ Name string

+ Payload []byte

+ func (q *Query) Deadline() time.Time

+ func (q *Query) EventType() EventType

+ func (q *Query) Respond(buf []byte) error

+ func (q *Query) String() string

+ type QueryParam struct

+ FilterNodes []string

+ FilterTags map[string]string

+ RequestAck bool

+ Timeout time.Duration

+ type QueryResponse struct

+ func (r *QueryResponse) AckCh() <-chan string

+ func (r *QueryResponse) Close()

+ func (r *QueryResponse) Deadline() time.Time

+ func (r *QueryResponse) Finished() bool

+ func (r *QueryResponse) ResponseCh() <-chan NodeResponse

type Serf

+ func (s *Serf) DefaultQueryParams() *QueryParam

+ func (s *Serf) DefaultQueryTimeout() time.Duration

+ func (s *Serf) LocalMember() Member

+ func (s *Serf) Query(name string, payload []byte, params *QueryParam) (*QueryResponse, error)

+ func (s *Serf) ShutdownCh() <-chan struct{}

type Snapshotter

+ func (s *Snapshotter) LastQueryClock() LamportTime

Feb 25, 2014

Changes in this version

type Serf

+ func (s *Serf) Stats() map[string]string

Feb 3, 2014

Changes in this version

type Serf

+ func (s *Serf) Memberlist() *memberlist.Memberlist

Jan 31, 2014

Changes in this version

type Config

+ Tags map[string]string

+ func (c *Config) Init()

type EventType

+ const EventMemberUpdate

type Member

+ Tags map[string]string

type Serf

+ func (s *Serf) SetTags(tags map[string]string) error

type SerfState

+ func (s SerfState) String() string

Dec 5, 2013

Changes in this version

type Config

+ MaxQueueDepth int

+ SnapshotPath string

type Member

+ Port uint16

+ type PreviousNode struct

+ Addr string

+ Name string

+ func (p PreviousNode) String() string

+ type Snapshotter struct

+ func NewSnapshotter(path string, maxSize int, logger *log.Logger, clock *LamportClock, ...) (chan<- Event, *Snapshotter, error)

+ func (s *Snapshotter) AliveNodes() []*PreviousNode

+ func (s *Snapshotter) LastClock() LamportTime

+ func (s *Snapshotter) LastEventClock() LamportTime

+ func (s *Snapshotter) Leave()

+ func (s *Snapshotter) Wait()

Nov 1, 2013

Changes in this version

+ const ProtocolVersionMax

+ const ProtocolVersionMin

+ var ProtocolVersionMap map[uint8]uint8

type Config

+ ProtocolVersion uint8

+ UserCoalescePeriod time.Duration

+ UserQuiescentPeriod time.Duration

type Member

+ DelegateCur uint8

+ DelegateMax uint8

+ DelegateMin uint8

+ ProtocolCur uint8

+ ProtocolMax uint8

+ ProtocolMin uint8

type Serf

+ func (s *Serf) ProtocolVersion() uint8

type SerfState

+ const SerfLeaving

type UserEvent

+ Coalesce bool

+ LTime LamportTime

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