Documentation
¶
Index ¶
Constants ¶
View Source
const (
ShardIdentity = "admiral.io/shardIdentity"
)
Variables ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.