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
}
Click to show internal directories.
Click to hide internal directories.