cluster

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Jan 15, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterConfig

type ClusterConfig struct {
	ClusterIO            string
	NodePrefix           string
	SD                   bool
	SV                   bool
	LogTime              bool
	DataPath             string
	NodesPorts           []uint16
	NodesMonitoringPorts []uint16
	NodesClusterPorts    []uint16
}

func (*ClusterConfig) GenerateConfigFiles

func (c *ClusterConfig) GenerateConfigFiles() ([]string, error)

GenerateConfigFiles генерирует и сохраняет конфиги для натсов, возвращает пути до файлов

type ConfiguredCluster

type ConfiguredCluster struct {
	StanCluster
	// contains filtered or unexported fields
}

func NewConfiguredCluster

func NewConfiguredCluster(cfg ClusterConfig, autoClean bool) (*ConfiguredCluster, error)

func (*ConfiguredCluster) Shutdown

func (c *ConfiguredCluster) Shutdown()

type StanCluster

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

func NewCluster

func NewCluster(configPaths []string) StanCluster

func (*StanCluster) GetLeaderID

func (c *StanCluster) GetLeaderID() raft.ServerID

func (*StanCluster) RaftStepDown

func (c *StanCluster) RaftStepDown() error

func (*StanCluster) Shutdown

func (c *StanCluster) Shutdown()

type StanServer

type StanServer struct {
	*stand.StanServer
	// contains filtered or unexported fields
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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