controllers

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

type ConfigMapCreatedEvent struct {
	Object runtime.Object
	Name   string
}

type ConfigMapDeletedEvent struct {
	Object runtime.Object
	Name   string
}

type Deployment interface {
	Name() string
	Namespace() string
	Config() *corev1.ConfigMap
	Deployment() *appsv1.Deployment
	UpdateConfig(current *corev1.ConfigMap) bool
	UpdateDeployment(current *appsv1.Deployment) bool
	Topics() []string
}

type DeploymentCreatedEvent struct {
	Object runtime.Object
	Name   string
}

type DeploymentDeletedEvent struct {
	Object runtime.Object
	Name   string
}

type DeploymentUpdatedEvent struct {
	Object runtime.Object
	Name   string
}

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

type ReconcilerEvent interface {

	// Record this into an event recorder as a Kubernetes API event
	Record(recorder record.EventRecorder)
}

type RedshiftSinkReconciler struct {
	client.Client

	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder

	KafkaTopicRegexes  *sync.Map
	KafkaClients       *sync.Map
	KafkaTopicsCache   *sync.Map
	KafkaRealtimeCache *sync.Map
	ReleaseCache       *sync.Map
	GitCache           *sync.Map
	IncludeTablesCache *sync.Map

	DefaultBatcherImage         string
	DefaultLoaderImage          string
	DefaultSecretRefName        string
	DefaultSecretRefNamespace   string
	DefaultKafkaVersion         string
	DefaultRedshiftMaxIdleConns int
	DefaultRedshiftMaxOpenConns int

	AllowedResources []string

	PrometheusClient prometheus.Client
	RedshiftMetrics  bool
}