Method GetBroadcasts

kv/memberlist/memberlist_client.go:1547–1564

GetBroadcasts is method from Memberlist Delegate interface It returns all pending broadcasts (within the size limit)

(overhead, limit int)

// GetBroadcasts is method from Memberlist Delegate interface
// It returns all pending broadcasts (within the size limit)
func (m *KV) GetBroadcasts(overhead, limit int) [][]byte {
	if !m.delegateReady.Load() {
		return nil
	}

	// Prioritize locally-generated messages
	msgs := m.localBroadcasts.GetBroadcasts(overhead, limit)

	// Decrease limit for each message we got from locally-generated broadcasts.
	for _, m := range msgs {
		limit -= overhead + len(m)
	}

	if limit > 0 {
		msgs = append(msgs, m.gossipBroadcasts.GetBroadcasts(overhead, limit)...)
	}
	return msgs
}

// LocalState is method from Memberlist Delegate interface
//