cluster

package

v0.12.2 Latest Latest Go to latest Published: Oct 20, 2025 License: MIT Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewCluster(
	serviceDiscovery ServiceDiscovery,
	namespace, ServiceName,
	raftAddr string,
	httpAddr string,
) *Cluster

func (c *Cluster) Hosts() []string

func (c *Cluster) Init() error

func (c *Cluster) InitKubeClient() error

func (c *Cluster) LeaderChanged(isLeader bool)

func (c *Cluster) NodeID() string

func (c *Cluster) RaftAddr() string

func (c *Cluster) UpdateServiceEndpointSlice() error

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

func NewJoiner(nodeID, raftAddr string, hosts []string) *Joiner

func (j *Joiner) Join() error

type ServiceDiscovery interface {
	Lookup() ([]string, error)
	IP() (string, error)
	Hostname() (string, error)
}

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

func NewServiceDiscoverySRV(namespace, serviceName string) *ServiceDiscoverySRV

func (s *ServiceDiscoverySRV) Hostname() (string, error)

func (s *ServiceDiscoverySRV) IP() (string, error)

func (s *ServiceDiscoverySRV) Lookup() ([]string, error)