rpc

Documentation

Index

• func Broadcast(message BroadcastMessage) error
• func SyncNodesAndLinkStates(targets []Target) ([]router.Node, router.LinkStates, error)
• type BroadcastMessage
• type Target

Functions

func Broadcast

func Broadcast(message BroadcastMessage) error

Broadcast used for single shot broadcast

func SyncNodesAndLinkStates

func SyncNodesAndLinkStates(targets []Target) ([]router.Node, router.LinkStates, error)

SyncNodesAndLinkStates A node that is not starting the first time tries to load the current cluster information from one of its neighbors Called before the node connected to the cluster, thus should not use dqlite repo

Types

type BroadcastMessage

type BroadcastMessage = struct {
	Type    pb.BroadcastType
	Payload []byte
}

type Target

type Target struct {
	ServerId string
	AddrPort netip.AddrPort
}