cluster

package

v1.5.0 Latest Latest Go to latest Published: Mar 20, 2026 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func Config(port int, myIP string) *memberlist.Config

func DecodeNotifyMsg[T any](msg *NotifyMsg) (*T, error)

func SendBroadcastQueue[T any](msg *T)

type AuthMessage struct {
	NotifyMsg
	SessionID string `json:"session_id"`
	Token     string `json:"token"`
}

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

func SetUp(port int, myIP string, notifyMsgFn NotifyMsgFn) (*Memberlist, error)

func (m *Memberlist) ActiveNodes() []*memberlist.Node

func (m *Memberlist) ActiveNodesWithoutSelf() []*memberlist.Node

func (m *Memberlist) MyNodeName() string

func (m *Memberlist) Start(ctx context.Context, peerDomain string, tickTime time.Duration)

type NotifyMsg struct {
	MsgType NotifyMsgType   `json:"msg_type"`
	Raw     json.RawMessage `json:"-"`
}

func (m *NotifyMsg) UnmarshalJSON(data []byte) error

type NotifyMsgFn func(msg *NotifyMsg)

type NotifyMsgType string

const (
	NotifyMsgType_AuthMessage NotifyMsgType = "auth_message"
)