v1

type LeaderCallback interface {
	OnStartedLeading(ctx context.Context, clusterCode, namespace, labelSelector string, kubeClientSet clientset.Interface) error
	OnStoppedLeading(ctx context.Context)
}

type LeaderElectionOptions struct {
	LeaderElect                 bool
	LeaderElectionNamespace     string
	LeaderElectionLeaseDuration time.Duration
	LeaderElectionRenewDeadline time.Duration
	LeaderElectionRetryPeriod   time.Duration
	LeaderElectionLeaseLockName string
	ClusterCode                 string
	Namespace                   string
	LabelSelector               string
}

type LeaderElector struct {
	KubeClientSet clientset.Interface
}

type Pod interface {
}

type PodClient struct {
	coreclientv1.PodInterface
	WatchEventHandler
	Namespace     string
	ClusterCode   string
	LabelSelector string
}

type ReplicaSet interface {
	CreateOrReplace(ctx context.Context, rs *appsv1.ReplicaSet) (*appsv1.ReplicaSet, error)
}

type ReplicaSetClient struct {
	appclientv1.ReplicaSetInterface
	WatchEventHandler
	Namespace     string
	ClusterCode   string
	LabelSelector string
}

type WatchEventHandler interface {
	Handle(ctx context.Context, clusterCode string, event watch.Event) error
}

type Watcher interface {
	DoWatch(ctx context.Context) error
}