kubernetes

Documentation

Index

• type ReplicasManager
  • func NewReplicasManager(cli kubernetes.Interface, stsNamespace string, stsSelector string, port int, ...) *ReplicasManager
  • func (g *ReplicasManager) Replicas() ([]shard.Manager, error)

Types

type ReplicasManager

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

ReplicasManager select Statefusets to get shard manager

func NewReplicasManager

func NewReplicasManager(
	cli kubernetes.Interface,
	stsNamespace string,
	stsSelector string,
	port int,
	deletePVC bool,
	lg logrus.FieldLogger,
) *ReplicasManager

NewReplicasManager create a ReplicasManager

func (*ReplicasManager) Replicas

func (g *ReplicasManager) Replicas() ([]shard.Manager, error)

Replicas return all shards manager