hazelcast

package
v0.0.0-...-c55d01b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 62 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultProperties = map[string]string{
	"hazelcast.cluster.version.auto.upgrade.enabled": "true",

	"hazelcast.persistence.auto.cluster.state": "true",
}

Functions

func NewSSLProperties 

func NewSSLProperties(path, password, protocol string, auth v1alpha1.MutualAuthentication) config.SSLProperties

Types

type CacheReconciler 

type CacheReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

CacheReconciler reconciles a Cache object

func NewCacheReconciler 

func NewCacheReconciler(c client.Client, log logr.Logger, s *runtime.Scheme, pht chan struct{}, cr *hzclient.HazelcastClientRegistry) *CacheReconciler

func (*CacheReconciler) Reconcile 

func (r *CacheReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*CacheReconciler) ReconcileCacheConfig 

func (r *CacheReconciler) ReconcileCacheConfig(
	ctx context.Context,
	c *hazelcastv1alpha1.Cache,
	cl hzclient.Client,
	logger logr.Logger,
) (map[string]hazelcastv1alpha1.DataStructureConfigState, error)

func (*CacheReconciler) SetupWithManager 

func (r *CacheReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ClusterState 

type ClusterState string
const (
	// Active is the default cluster state. Cluster continues to operate without restrictions.
	Active ClusterState = "ACTIVE"

	// Passive is the state when the partition table is frozen and partition assignments are not performed.
	Passive ClusterState = "PASSIVE"
)

type ConfigMapVolumeName 

type ConfigMapVolumeName func(cm string) string

type CronHotBackupReconciler 

type CronHotBackupReconciler struct {
	client.Client
	Log logr.Logger

	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

CronHotBackupReconciler reconciles a CronHotBackup object

func NewCronHotBackupReconciler 

func NewCronHotBackupReconciler(
	client client.Client, log logr.Logger, scheme *runtime.Scheme, pht chan struct{}) *CronHotBackupReconciler

func (*CronHotBackupReconciler) Reconcile 

func (r *CronHotBackupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

func (*CronHotBackupReconciler) SetupWithManager 

func (r *CronHotBackupReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type DSStatusApplier 

type DSStatusApplier interface {
	DSStatusApply(ds *hazelcastv1alpha1.DataStructureStatus)
}

type HazelcastReconciler 

type HazelcastReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

HazelcastReconciler reconciles a Hazelcast object

func NewHazelcastReconciler 

func NewHazelcastReconciler(c client.Client, log logr.Logger, s *runtime.Scheme, pht chan struct{}, cs hzclient.ClientRegistry, ssm hzclient.StatusServiceRegistry, mtlsRegistry mtls.HttpClientRegistry) *HazelcastReconciler

func (*HazelcastReconciler) Reconcile 

func (r *HazelcastReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HazelcastReconciler) SetupWithManager 

func (r *HazelcastReconciler) SetupWithManager(mgr ctrl.Manager) error

type HotBackupReconciler 

type HotBackupReconciler struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewHotBackupReconciler 

func NewHotBackupReconciler(c client.Client, log logr.Logger, pht chan struct{}, mtlsClientRegistry mtls.HttpClientRegistry, cs hzclient.ClientRegistry, ssm hzclient.StatusServiceRegistry) *HotBackupReconciler

func (*HotBackupReconciler) Reconcile 

func (r *HotBackupReconciler) Reconcile(ctx context.Context, req reconcile.Request) (result reconcile.Result, err error)

func (*HotBackupReconciler) SetupWithManager 

func (r *HotBackupReconciler) SetupWithManager(mgr ctrl.Manager) error

type HotBackupStatusApplier 

type HotBackupStatusApplier interface {
	HotBackupStatusApply(ms *hazelcastv1alpha1.HotBackupStatus)
}

type HzStatusApplier 

type HzStatusApplier interface {
	HzStatusApply(hs *hazelcastv1alpha1.HazelcastStatus)
}

type JetJobReconciler 

type JetJobReconciler struct {
	client.Client
	Log            logr.Logger
	ClientRegistry hzclient.ClientRegistry
	// contains filtered or unexported fields
}

JetJobReconciler reconciles a JetJob object

func NewJetJobReconciler 

func NewJetJobReconciler(c client.Client, log logr.Logger, cs hzclient.ClientRegistry, mtlsClientRegistry mtls.HttpClientRegistry, pht chan struct{}) *JetJobReconciler

func (*JetJobReconciler) Reconcile 

func (r *JetJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result reconcile.Result, err error)

func (*JetJobReconciler) SetupWithManager 

func (r *JetJobReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type JetJobSnapshotReconciler 

type JetJobSnapshotReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

JetJobSnapshotReconciler reconciles a JetJobSnapshot object

func NewJetJobSnapshotReconciler 

func NewJetJobSnapshotReconciler(c client.Client, log logr.Logger, scheme *runtime.Scheme, cs hzclient.ClientRegistry, mtlsClientRegistry mtls.HttpClientRegistry, pht chan struct{}) *JetJobSnapshotReconciler

func (*JetJobSnapshotReconciler) Reconcile 

func (r *JetJobSnapshotReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*JetJobSnapshotReconciler) SetupWithManager 

func (r *JetJobSnapshotReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type JetJobSnapshotStatusApplierFunc 

type JetJobSnapshotStatusApplierFunc func(s *hazelcastv1alpha1.JetJobSnapshotStatus)

type LogKey 

type LogKey string

type MapReconciler 

type MapReconciler struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

MapReconciler reconciles a Map object

func NewMapReconciler 

func NewMapReconciler(c client.Client, log logr.Logger, pht chan struct{}, cs hzclient.ClientRegistry) *MapReconciler

func (*MapReconciler) Reconcile 

func (r *MapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*MapReconciler) ReconcileMapConfig 

func (r *MapReconciler) ReconcileMapConfig(
	ctx context.Context,
	m *hazelcastv1alpha1.Map,
	hz *hazelcastv1alpha1.Hazelcast,
	cl hzclient.Client,
	createdBefore bool,
) (map[string]hazelcastv1alpha1.MapConfigState, error)

func (*MapReconciler) SetupWithManager 

func (r *MapReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type MapStatusApplier 

type MapStatusApplier interface {
	MapStatusApply(ms *hazelcastv1alpha1.MapStatus)
}

type MultiMapReconciler 

type MultiMapReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

MultiMapReconciler reconciles a MultiMap object

func NewMultiMapReconciler 

func NewMultiMapReconciler(c client.Client, log logr.Logger, s *runtime.Scheme, pht chan struct{}, cs hzclient.ClientRegistry) *MultiMapReconciler

func (*MultiMapReconciler) Reconcile 

func (r *MultiMapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*MultiMapReconciler) ReconcileMultiMapConfig 

func (r *MultiMapReconciler) ReconcileMultiMapConfig(
	ctx context.Context,
	mm *hazelcastv1alpha1.MultiMap,
	cl hzclient.Client,
	logger logr.Logger,
) (map[string]hazelcastv1alpha1.DataStructureConfigState, error)

func (*MultiMapReconciler) SetupWithManager 

func (r *MultiMapReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type QueueReconciler 

type QueueReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

QueueReconciler reconciles a Queue object

func NewQueueReconciler 

func NewQueueReconciler(c client.Client, log logr.Logger, s *runtime.Scheme, pht chan struct{}, cr hzclient.ClientRegistry) *QueueReconciler

func (*QueueReconciler) Reconcile 

func (r *QueueReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*QueueReconciler) ReconcileQueueConfig 

func (r *QueueReconciler) ReconcileQueueConfig(
	ctx context.Context,
	q *hazelcastv1alpha1.Queue,
	cl hzclient.Client,
	logger logr.Logger,
) (map[string]hazelcastv1alpha1.DataStructureConfigState, error)

func (*QueueReconciler) SetupWithManager 

func (r *QueueReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ReplicatedMapReconciler 

type ReplicatedMapReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

ReplicatedMapReconciler reconciles a ReplicatedMap object

func NewReplicatedMapReconciler 

func NewReplicatedMapReconciler(c client.Client, log logr.Logger, s *runtime.Scheme, pht chan struct{}, cs hzclient.ClientRegistry) *ReplicatedMapReconciler

func (*ReplicatedMapReconciler) Reconcile 

func (r *ReplicatedMapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ReplicatedMapReconciler) ReconcileReplicatedMapConfig 

func (r *ReplicatedMapReconciler) ReconcileReplicatedMapConfig(
	ctx context.Context,
	rm *hazelcastv1alpha1.ReplicatedMap,
	cl hzclient.Client,
	logger logr.Logger,
) (map[string]hazelcastv1alpha1.DataStructureConfigState, error)

func (*ReplicatedMapReconciler) SetupWithManager 

func (r *ReplicatedMapReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type RestClient 

type RestClient struct {
	// contains filtered or unexported fields
}

func NewRestClient 

func NewRestClient(h *v1alpha1.Hazelcast) *RestClient

func (*RestClient) ChangeState 

func (c *RestClient) ChangeState(ctx context.Context, state ClusterState) error

func (*RestClient) ForceStart 

func (c *RestClient) ForceStart(ctx context.Context) error

func (*RestClient) GetState 

func (c *RestClient) GetState(ctx context.Context) (string, error)

func (*RestClient) HotBackup 

func (c *RestClient) HotBackup(ctx context.Context) error

func (*RestClient) PartialStart 

func (c *RestClient) PartialStart(ctx context.Context) error

type TopicReconciler 

type TopicReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

TopicReconciler reconciles a Topic object

func NewTopicReconciler 

func NewTopicReconciler(c client.Client, log logr.Logger, s *runtime.Scheme, pht chan struct{}, cs hzclient.ClientRegistry) *TopicReconciler

func (*TopicReconciler) Reconcile 

func (r *TopicReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*TopicReconciler) ReconcileTopicConfig 

func (r *TopicReconciler) ReconcileTopicConfig(
	ctx context.Context,
	t *hazelcastv1alpha1.Topic,
	cl hzclient.Client,
	logger logr.Logger,
) (map[string]hazelcastv1alpha1.DataStructureConfigState, error)

func (*TopicReconciler) SetupWithManager 

func (r *TopicReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type Update 

type Update func(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type WanMapStatusApplier 

type WanMapStatusApplier interface {
	WanMapStatusApply(ms *hazelcastv1alpha1.WanReplicationMapStatus)
}

type WanRepStatusApplier 

type WanRepStatusApplier interface {
	WanRepStatusApply(ms *hazelcastv1alpha1.WanReplicationStatus)
}

type WanReplicationReconciler 

type WanReplicationReconciler struct {
	client.Client
	logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

WanReplicationReconciler reconciles a WanReplication object

func NewWanReplicationReconciler 

func NewWanReplicationReconciler(client client.Client, log logr.Logger, scheme *runtime.Scheme, pht chan struct{}, mtlsClientRegistry mtls.HttpClientRegistry, cs hzclient.ClientRegistry, ssm hzclient.StatusServiceRegistry) *WanReplicationReconciler

func (*WanReplicationReconciler) Reconcile 

func (r *WanReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*WanReplicationReconciler) SetupWithManager 

func (r *WanReplicationReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type WanSyncReconciler 

type WanSyncReconciler struct {
	client.Client
	logr.Logger
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

WanSyncReconciler reconciles a WanSync object

func NewWanSyncReconciler 

func NewWanSyncReconciler(c client.Client, log logr.Logger, scheme *runtime.Scheme, cs hzclient.ClientRegistry, pht chan struct{}) *WanSyncReconciler

func (*WanSyncReconciler) Reconcile 

func (r *WanSyncReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*WanSyncReconciler) SetupWithManager 

func (r *WanSyncReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.