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.RedisClient, slotId int, nodeId string, ...) (err error)
• func SyncFromLocalToEtcd(c *cli.Context, ctx context.Context, resourceKind string, watch bool, ...) 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.RedisClient, slotId int, nodeId string, retryCount int) (err error)

func SyncFromLocalToEtcd

func SyncFromLocalToEtcd(c *cli.Context, ctx context.Context, resourceKind string, watch bool, logger logr.Logger) error

func WatchAndSync

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