cluster

package

v0.2.26 Latest Latest Go to latest Published: Jun 14, 2024 License: MIT Imports: 17 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(logger *logrus.Logger, serviceDiscovery ServiceDiscovery, namespace, ServiceName, 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(logger *logrus.Logger, 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)