memlistconf

package

v0.0.0-...-59b76e6 Latest Latest Go to latest Published: Sep 27, 2022 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/divilla/gossip-cluster

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewTLQ(ml *memberlist.Memberlist) *memberlist.TransmitLimitedQueue
type Broadcast
- func NewBroadcast(logger *zap.Logger, ml *memberlist.Memberlist, name string, msg []byte, ...) *Broadcast
- func (b *Broadcast) Finished()
- func (b *Broadcast) Invalidates(other memberlist.Broadcast) bool
- func (b *Broadcast) Message() []byte
- func (b *Broadcast) Name() string
type Delegate
- func NewDelegate(logger *zap.Logger, ml *memberlist.Memberlist, ...) *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(b []byte)
type EventName
type GlobalState
- func NewState(logger *zap.Logger, node *memberlist.Node) *GlobalState
- func (s *GlobalState) Event(name EventName, args ...interface{}) error
- func (s *GlobalState) LocalNode() NodeData
- func (s *GlobalState) LocalState() Nodes
- func (s *GlobalState) LogFullState()
- func (s *GlobalState) Merge(key string, data NodeData)
- func (s *GlobalState) Name() string
- func (s *GlobalState) Size() int
type KeyName
type Message
type Messenger
- func NewMessenger(logger *zap.Logger, ml *memberlist.Memberlist, ...) *Messenger
- func (m *Messenger) Broadcast(topic string, data []byte)
type NodeData
type Nodes
type StateName

Constants ¶

View Source

const (
	State KeyName = "state"

	Idle       StateName = "idle"
	Joining    StateName = "joining"
	Assembling StateName = "assembling"

	Join      EventName = "join"
	Joined    EventName = "joined"
	Assemble  EventName = "assemble"
	Assembled EventName = "assembled"
	Finish    EventName = "finish"
)

Variables ¶

This section is empty.

Functions ¶

func NewTLQ ¶

func NewTLQ(ml *memberlist.Memberlist) *memberlist.TransmitLimitedQueue

Types ¶

type Broadcast ¶

type Broadcast struct {
	memberlist.NamedBroadcast
	// contains filtered or unexported fields
}

func NewBroadcast ¶

func NewBroadcast(logger *zap.Logger, ml *memberlist.Memberlist, name string, msg []byte, notifyCh chan<- struct{}) *Broadcast

func (*Broadcast) Finished ¶

func (b *Broadcast) Finished()

func (*Broadcast) Invalidates ¶

func (b *Broadcast) Invalidates(other memberlist.Broadcast) bool

func (*Broadcast) Message ¶

func (b *Broadcast) Message() []byte

func (*Broadcast) Name ¶

func (b *Broadcast) Name() string

type Delegate ¶

type Delegate struct {
	// contains filtered or unexported fields
}

func NewDelegate ¶

func NewDelegate(logger *zap.Logger, ml *memberlist.Memberlist, tlq *memberlist.TransmitLimitedQueue, gs *GlobalState) *Delegate

func (*Delegate) GetBroadcasts ¶

func (d *Delegate) GetBroadcasts(overhead, limit int) [][]byte

func (*Delegate) LocalState ¶

func (d *Delegate) LocalState(join bool) []byte

func (*Delegate) MergeRemoteState ¶

func (d *Delegate) MergeRemoteState(buf []byte, join bool)

func (*Delegate) NodeMeta ¶

func (d *Delegate) NodeMeta(limit int) []byte

func (*Delegate) NotifyMsg ¶

func (d *Delegate) NotifyMsg(b []byte)

type EventName ¶

type EventName = string

type GlobalState ¶

type GlobalState struct {
	// contains filtered or unexported fields
}

func NewState ¶

func NewState(logger *zap.Logger, node *memberlist.Node) *GlobalState

func (*GlobalState) Event ¶

func (s *GlobalState) Event(name EventName, args ...interface{}) error

func (*GlobalState) LocalNode ¶

func (s *GlobalState) LocalNode() NodeData

func (*GlobalState) LocalState ¶

func (s *GlobalState) LocalState() Nodes

func (*GlobalState) LogFullState ¶

func (s *GlobalState) LogFullState()

func (*GlobalState) Merge ¶

func (s *GlobalState) Merge(key string, data NodeData)

func (*GlobalState) Name ¶

func (s *GlobalState) Name() string

func (*GlobalState) Size ¶

func (s *GlobalState) Size() int

type KeyName ¶

type KeyName = string

type Message ¶

type Message struct {
	Topic string
	Data  map[string]string
}

type Messenger ¶

type Messenger struct {
	// contains filtered or unexported fields
}

func NewMessenger ¶

func NewMessenger(logger *zap.Logger, ml *memberlist.Memberlist, tlq *memberlist.TransmitLimitedQueue) *Messenger

func (*Messenger) Broadcast ¶

func (m *Messenger) Broadcast(topic string, data []byte)

type NodeData ¶

type NodeData = map[string]interface{}

type Nodes ¶

type Nodes = map[string]NodeData

type StateName ¶

type StateName = string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL