Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlphaManager ¶
type AlphaManager struct {
// contains filtered or unexported fields
}
AlphaManager manages alpha members in a dgraph cluster. It's main function is to sync the alphas in the clsuter with the required configuration in the DgraphCluster object.
func NewAlphaManager ¶
func NewAlphaManager( k8sClient kubernetes.Interface, podLister klisters.PodLister, svcLister klisters.ServiceLister, statefulSetLister v1.StatefulSetLister, ) *AlphaManager
NewAlphaManager creates a new manager for dgraph alpha components.
func (*AlphaManager) Sync ¶
func (am *AlphaManager) Sync(dc *v1alpha1.DgraphCluster) error
Sync syncs the alpha cluster for the provided DgraphCluster configuration.
type Manager ¶
type Manager interface {
// Sync performs the operation of syncing DgraphCluster corresponding to the
// manager.
Sync(*v1alpha1.DgraphCluster) error
}
Manager is a general interface which each member manager must implement in order to sync it's state with DgraphCluster state.
type RatelManager ¶
type RatelManager struct {
// contains filtered or unexported fields
}
RatelManager manages Ratel members in a dgraph cluster. It's main function is to sync the Ratels in the clsuter with the required configuration in the DgraphCluster object.
func NewRatelManager ¶
func NewRatelManager( k8sClient kubernetes.Interface, podLister klisters.PodLister, svcLister klisters.ServiceLister, deploymentLister v1.DeploymentLister, ) *RatelManager
NewRatelManager creates a new manager for dgraph Ratel components.
func (*RatelManager) Sync ¶
func (rm *RatelManager) Sync(dc *v1alpha1.DgraphCluster) error
type ZeroManager ¶
type ZeroManager struct {
// contains filtered or unexported fields
}
ZeroManager manages Zero members in a dgraph cluster. It's main function is to sync dgraph Zeros in the clsuter with the required configuration in the DgraphCluster object.
func NewZeroManager ¶
func NewZeroManager( k8sClient kubernetes.Interface, podLister klisters.PodLister, svcLister klisters.ServiceLister, statefulSetLister v1.StatefulSetLister, ) *ZeroManager
NewZeroManager creates a new manager for dgraph zero components in the clsuter.
func (*ZeroManager) Sync ¶
func (zm *ZeroManager) Sync(dc *v1alpha1.DgraphCluster) error
Sync syncs the actual Kubernetes resources with the provided configuration of DgraphCluster using operator defined custom resources.
Source Files