Documentation ¶
Index ¶
- func Expect(t *testing.T, got, want interface{})
- func GenerateUUID4() string
- func InArray(val interface{}, array interface{}) bool
- func Unset(a []string, i int) []string
- type Broadcast
- type Cluster
- type Delegate
- func (d *Delegate) GetBroadcasts(overhead, limit int) [][]byte
- func (d *Delegate) LocalState(join bool) []byte
- func (d *Delegate) MergeRemoteState(buf []byte, join bool)
- func (d *Delegate) NodeMeta(limit int) []byte
- func (d *Delegate) NotifyMsg(msg []byte)
- func (d *Delegate) SetCluster(cluster *Cluster)
- func (d *Delegate) UpdateState(data []byte)
- type Message
- type NodeEvents
- type RoundRobinBalancer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Broadcast ¶
type Broadcast struct {
// contains filtered or unexported fields
}
Broadcast struct
func (*Broadcast) Invalidates ¶ added in v0.0.8
func (b *Broadcast) Invalidates(other memberlist.Broadcast) bool
Invalidates ..
type Cluster ¶
type Cluster struct { // https://github.com/hashicorp/memberlist/blob/master/config.go#L350 Config *memberlist.Config Memlist *memberlist.Memberlist }
Cluster struct
func (*Cluster) AddLocalNode ¶
AddLocalNode
type Delegate ¶ added in v0.0.8
type Delegate struct { State []byte Broadcasts *memberlist.TransmitLimitedQueue Cluster *Cluster }
Delegate struct
func (*Delegate) GetBroadcasts ¶ added in v0.0.8
GetBroadcasts ..
func (*Delegate) LocalState ¶ added in v0.0.8
LocalState ..
func (*Delegate) MergeRemoteState ¶ added in v0.0.8
MergeRemoteState ..
func (*Delegate) SetCluster ¶ added in v0.0.8
SetCluster ..
func (*Delegate) UpdateState ¶ added in v0.0.8
UpdateState ..
type NodeEvents ¶
type NodeEvents struct{}
NodeEvents struct implements https://github.com/hashicorp/memberlist/blob/master/event_delegate.go#L7
func (*NodeEvents) NotifyLeave ¶
func (n *NodeEvents) NotifyLeave(node *memberlist.Node)
NotifyLeave
func (*NodeEvents) NotifyUpdate ¶
func (n *NodeEvents) NotifyUpdate(node *memberlist.Node)
NotifyUpdate
type RoundRobinBalancer ¶ added in v0.1.1
RoundRobinBalancer ...
func NewRoundRobinBalancer ¶ added in v0.1.1
func NewRoundRobinBalancer(clus *Cluster) *RoundRobinBalancer
NewRoundRobinBalancer ...
func (*RoundRobinBalancer) Get ¶ added in v0.1.1
func (r *RoundRobinBalancer) Get() *memberlist.Node
Get ...
Source Files ¶
Click to show internal directories.
Click to hide internal directories.