controller

Documentation

Index

• Constants
• func NewShardController(stopCh <-chan struct{}, crdClientSet clientset.Interface, ...) (*shardController, error)
• func NewShardHandler(clients model.Clients, smParams *model.ShardingManagerParams) *shardHandler
• type ShardInterface

Constants

const (
	ShardIdentity = "admiral.io/shardIdentity"
)

Functions

func NewShardController

func NewShardController(stopCh <-chan struct{}, crdClientSet clientset.Interface, kubernetesClientset kubernetes.Interface, resyncPeriod time.Duration) (*shardController, error)

initializes controller for shard resource

func NewShardHandler

func NewShardHandler(clients model.Clients, smParams *model.ShardingManagerParams) *shardHandler

initializes ShardHandler with sharding manager configuration and shard namespace

Types

type ShardInterface

type ShardInterface interface {
	// create shard resource on a kubernetes cluster
	Create(ctx context.Context, clusterConfiguration []registry.ClusterConfig, shardName string, operatorIdentity string) (*typeV1.Shard, error)
	// update shard resource on a kubernetes cluster
	Update(ctx context.Context, clusterConfiguration []registry.ClusterConfig, shardName string, operatorIdentity string) (*typeV1.Shard, error)
	// delete shard resource on a kubernetes cluster
	Delete(ctx context.Context, shard *typeV1.Shard) error
}

Interface to manage shards