runner

Documentation

Index

• Constants
• func NewCommand(ctx context.Context) *cli.Command
• func RebalanceSlots(ctx context.Context, authInfo redis.AuthInfo, address string, ...) error
• func RetrySetSlotStatus(ctx context.Context, client redis.Client, slotId int, nodeId string, ...) (err error)
• func SyncFromLocalToConfigMap(c *cli.Context, ctx context.Context, logger logr.Logger) error
• func WatchAndSync(ctx context.Context, client *kubernetes.Clientset, ...) error

Constants

const (
	SlaveWaitInterval  = time.Second * 60
	MasterWaitInterval = time.Second * 2

	DefaultRedisServerPort = "6379"
)

Functions

func NewCommand

func NewCommand(ctx context.Context) *cli.Command

func RebalanceSlots

func RebalanceSlots(ctx context.Context, authInfo redis.AuthInfo, address string, logger logr.Logger) error

RebalanceSlots

func RetrySetSlotStatus

func RetrySetSlotStatus(ctx context.Context, client redis.Client, slotId int, nodeId string, retryCount int) (err error)

func SyncFromLocalToConfigMap

func SyncFromLocalToConfigMap(c *cli.Context, ctx context.Context, logger logr.Logger) error

func WatchAndSync

func WatchAndSync(ctx context.Context, client *kubernetes.Clientset, namespace, name, workspace, target string,
	syncInterval int64, ownerRefs []v1.OwnerReference, logger logr.Logger) error