controller

Documentation

Index

• type DuckLakeCatalogReconciler
  • func (r *DuckLakeCatalogReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DuckLakeCatalogReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DuckLakePoolReconciler
  • func (r *DuckLakePoolReconciler) GetPoolManager(namespace, name string) (*pool.Manager, bool)
  • func (r *DuckLakePoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DuckLakePoolReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DuckLakeTableReconciler
  • func (r *DuckLakeTableReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DuckLakeTableReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MockS3Client
  • func NewMockS3Client() *MockS3Client
  • func (m *MockS3Client) BucketExists(ctx context.Context, name string) (bool, error)
  • func (m *MockS3Client) CreateBucket(ctx context.Context, name string) error
  • func (m *MockS3Client) DeleteBucket(ctx context.Context, name string) error
  • func (m *MockS3Client) DeleteObject(ctx context.Context, bucket, key string) error
  • func (m *MockS3Client) GetBucketRegion(ctx context.Context, name string) (string, error)
  • func (m *MockS3Client) GetObject(ctx context.Context, bucket, key string) ([]byte, error)
  • func (m *MockS3Client) ListBuckets(ctx context.Context) ([]string, error)
  • func (m *MockS3Client) ListObjects(ctx context.Context, bucket, prefix string) ([]string, error)
  • func (m *MockS3Client) PutObject(ctx context.Context, bucket, key string, data []byte) error
  • func (m *MockS3Client) SetError(err error)
• type PoolManager

Types

type DuckLakeCatalogReconciler

type DuckLakeCatalogReconciler struct {
	client.Client
	Scheme      *runtime.Scheme
	Recorder    record.EventRecorder
	RetryConfig retry.RetryConfig
	Backup      *backup.BackupManager
	Storage     storage.ObjectStore
}

DuckLakeCatalogReconciler reconciles a DuckLakeCatalog object

func (*DuckLakeCatalogReconciler) Reconcile

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

Reconcile handles DuckLakeCatalog resources

func (*DuckLakeCatalogReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type DuckLakePoolReconciler

type DuckLakePoolReconciler struct {
	client.Client
	Scheme    *runtime.Scheme
	Recorder  record.EventRecorder
	Logger    *zerolog.Logger
	K8sClient kubernetes.Interface
	Config    *rest.Config
	// contains filtered or unexported fields
}

DuckLakePoolReconciler reconciles a DuckLakePool object

func (*DuckLakePoolReconciler) GetPoolManager

func (r *DuckLakePoolReconciler) GetPoolManager(namespace, name string) (*pool.Manager, bool)

GetPoolManager returns the pool manager for a given pool

func (*DuckLakePoolReconciler) Reconcile

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

Reconcile handles DuckLakePool resources

func (*DuckLakePoolReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager

type DuckLakeTableReconciler

type DuckLakeTableReconciler struct {
	client.Client
	Scheme       *runtime.Scheme
	Recorder     record.EventRecorder
	Logger       *zerolog.Logger
	JobManager   *duckdb.JobManager
	SQLGen       *sql.Generator
	Materializer *materializer.Runner
	PodTemplate  *config.PodTemplateConfig
	Consistency  *storage.ConsistencyChecker
	RetryConfig  retry.RetryConfig
	Lifecycle    *duckdb.LifecycleManager
	PoolManager  PoolManager
	Config       *rest.Config
	K8sClient    kubernetes.Interface
}

DuckLakeTableReconciler reconciles a DuckLakeTable object

func (*DuckLakeTableReconciler) Reconcile

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

Reconcile handles DuckLakeTable resources

func (*DuckLakeTableReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type MockS3Client

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

MockS3Client implements the storage.ObjectStore interface for testing

func NewMockS3Client

func NewMockS3Client() *MockS3Client

NewMockS3Client creates a new mock S3 client

func (*MockS3Client) BucketExists

func (m *MockS3Client) BucketExists(ctx context.Context, name string) (bool, error)

BucketExists mocks checking if an S3 bucket exists

func (*MockS3Client) CreateBucket

func (m *MockS3Client) CreateBucket(ctx context.Context, name string) error

CreateBucket mocks creating an S3 bucket

func (*MockS3Client) DeleteBucket

func (m *MockS3Client) DeleteBucket(ctx context.Context, name string) error

DeleteBucket mocks deleting an S3 bucket

func (*MockS3Client) DeleteObject

func (m *MockS3Client) DeleteObject(ctx context.Context, bucket, key string) error

DeleteObject mocks deleting an object from a bucket

func (*MockS3Client) GetBucketRegion

func (m *MockS3Client) GetBucketRegion(ctx context.Context, name string) (string, error)

GetBucketRegion mocks getting the region of an S3 bucket

func (*MockS3Client) GetObject

func (m *MockS3Client) GetObject(ctx context.Context, bucket, key string) ([]byte, error)

GetObject mocks getting an object from a bucket

func (*MockS3Client) ListBuckets

func (m *MockS3Client) ListBuckets(ctx context.Context) ([]string, error)

ListBuckets mocks listing S3 buckets

func (*MockS3Client) ListObjects

func (m *MockS3Client) ListObjects(ctx context.Context, bucket, prefix string) ([]string, error)

ListObjects mocks listing objects in a bucket

func (*MockS3Client) PutObject

func (m *MockS3Client) PutObject(ctx context.Context, bucket, key string, data []byte) error

PutObject mocks putting an object in a bucket

func (*MockS3Client) SetError

func (m *MockS3Client) SetError(err error)

SetError sets the error to be returned by the mock client

type PoolManager

type PoolManager interface {
	GetPoolManager(namespace, name string) (*pool.Manager, bool)
}

PoolManager provides access to warm pod pools