cluster

package
v1.9.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 2, 2026 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	Nodes  []Node `json:"nodes"`
	Leader Node   `json:"leader"`
}

func ConvertJSONToConfig 

func ConvertJSONToConfig(jsonString string) (*Config, error)

func (*Config) AddNode 

func (config *Config) AddNode(node Node)

func (*Config) Equals 

func (config *Config) Equals(config2 *Config) bool

func (*Config) ToJSON 

func (config *Config) ToJSON() (string, error)

type EtcdServer 

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

func CreateEtcdServer 

func CreateEtcdServer(thisNode Node, config Config, dataPath string) *EtcdServer

func (*EtcdServer) AreColonyAssignmentsPaused added in v1.8.19 

func (server *EtcdServer) AreColonyAssignmentsPaused(colonyName string) (bool, error)

func (*EtcdServer) CurrentCluster 

func (server *EtcdServer) CurrentCluster() Config

func (*EtcdServer) Leader 

func (server *EtcdServer) Leader() string

func (*EtcdServer) Members 

func (server *EtcdServer) Members() []Node

func (*EtcdServer) PauseColonyAssignments added in v1.8.19 

func (server *EtcdServer) PauseColonyAssignments(colonyName string) error

func (*EtcdServer) ResumeColonyAssignments added in v1.8.19 

func (server *EtcdServer) ResumeColonyAssignments(colonyName string) error

func (*EtcdServer) Start 

func (server *EtcdServer) Start()

func (*EtcdServer) Stop 

func (server *EtcdServer) Stop()

func (*EtcdServer) StorageDir 

func (server *EtcdServer) StorageDir() string

func (*EtcdServer) WaitToStart 

func (server *EtcdServer) WaitToStart()

func (*EtcdServer) WaitToStop 

func (server *EtcdServer) WaitToStop()

type MessageHandler added in v1.9.6 

type MessageHandler func(data []byte)

MessageHandler is a function that processes relay messages

type Node 

type Node struct {
	Name           string `json:"name"`
	Host           string `json:"host"`
	EtcdClientPort int    `json:"port"`     // Etcd default 2379
	EtcdPeerPort   int    `json:"peerport"` // Etcd default 2380
	RelayPort      int    `json:"relayport"`
	APIPort        int    `json:"apiport"`
}

func (*Node) Equals 

func (node *Node) Equals(node2 *Node) bool

type RelayMessage added in v1.9.6 

type RelayMessage struct {
	Data []byte
	Done chan struct{}
}

RelayMessage contains the message data and a channel to signal processing completion

type RelayServer 

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

func CreateRelayServer 

func CreateRelayServer(thisNode Node, clusterConfig Config) *RelayServer

func (*RelayServer) Broadcast 

func (server *RelayServer) Broadcast(msg []byte) error

Send a message to all ReplayServers in the Cluster

func (*RelayServer) Receive 

func (server *RelayServer) Receive() chan RelayMessage

Receive returns a channel for receiving relay messages (legacy interface) Messages are dispatched asynchronously to avoid blocking the HTTP handler

func (*RelayServer) Shutdown 

func (server *RelayServer) Shutdown()

func (*RelayServer) Subscribe added in v1.9.6 

func (server *RelayServer) Subscribe(handler MessageHandler)

Subscribe registers a handler to receive relay messages The handler is called synchronously for each incoming message

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.