kubernetes

Documentation

Index

• type ShardManager
  • func New(cli kubernetes.Interface, stsNamespace string, stsSelector string, port int, ...) *ShardManager
  • func (s *ShardManager) ChangeScale(expect int32) error
  • func (s *ShardManager) Shards() ([]*shard.Group, error)

Types

type ShardManager

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

ShardManager manager shards use kubernetes ShardManager

func New

func New(cli kubernetes.Interface,
	stsNamespace string,
	stsSelector string,
	port int,
	log logrus.FieldLogger) *ShardManager

New create a new StatefulSet shards manager

func (*ShardManager) ChangeScale

func (s *ShardManager) ChangeScale(expect int32) error

ChangeScale create or delete Shards according to "expReplicate"

func (*ShardManager) Shards

func (s *ShardManager) Shards() ([]*shard.Group, error)

Shards return current Shards in the cluster