controllers

Documentation

Index

• type EdgeFunctionReconciler
  • func NewEdgeFuncReconciler(c client.Client, apiserverHost string, wasmStore manifest.Store, ...) *EdgeFunctionReconciler
  • func (r *EdgeFunctionReconciler) Reconcile(ctx context.Context, request reconcile.Request) (ctrl.Result, error)
  • func (r *EdgeFunctionReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, proxyName string) error
• type Option
  • func WithAPIServerTLSClientConfig(tlsConfig *tls.Config) Option
  • func WithAggregatedHealthChecker(hc *healthchecker.AggregatedHealthChecker) Option
  • func WithClickHouseConn(chConn clickhouse.Conn) Option
  • func WithEnvoyContrib() Option
  • func WithGoPluginDir(dir string) Option
  • func WithURLRelease(url string) Option
• type ProxyReconciler
  • func NewProxyReconciler(c client.Client, proxyName string, replicaName string, apiServerAddr string, ...) *ProxyReconciler
  • func (r *ProxyReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (r *ProxyReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error
  • func (r *ProxyReconciler) Shutdown(ctx context.Context, reason string)

Types

type EdgeFunctionReconciler

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

EdgeFunctionReconciler reconciles a Proxy object.

func NewEdgeFuncReconciler

func NewEdgeFuncReconciler(
	c client.Client,
	apiserverHost string,
	wasmStore manifest.Store,
	goStoreDir string,
) *EdgeFunctionReconciler

NewEdgeFuncReconciler returns a new reconcile.Reconciler.

func (*EdgeFunctionReconciler) Reconcile

func (r *EdgeFunctionReconciler) Reconcile(ctx context.Context, request reconcile.Request) (ctrl.Result, error)

Reconcile implements reconcile.Reconciler.

func (*EdgeFunctionReconciler) SetupWithManager

func (r *EdgeFunctionReconciler) SetupWithManager(
	ctx context.Context,
	mgr ctrl.Manager,
	proxyName string,
) error

SetupWithManager sets up the controller with the Controller Manager.

type Option

type Option func(*options)

Option is a functional option for ProxyReconciler.

func WithAPIServerTLSClientConfig

func WithAPIServerTLSClientConfig(tlsConfig *tls.Config) Option

WithAPIServerTLSClientConfig sets the TLS client configuration for the API server. If not set, the client will use an insecure connection.

func WithAggregatedHealthChecker

func WithAggregatedHealthChecker(hc *healthchecker.AggregatedHealthChecker) Option

WithAggregatedHealthChecker sets the health checker for the ProxyReconciler.

func WithClickHouseConn

func WithClickHouseConn(chConn clickhouse.Conn) Option

WithClickHouseConn sets the ClickHouse connection for the ProxyReconciler. If not set, log shipping will be disabled.

func WithEnvoyContrib

func WithEnvoyContrib() Option

WithEnvoyContrib enables the use of Envoy contrib filters.

func WithGoPluginDir

func WithGoPluginDir(dir string) Option

WithGoPluginDir sets the directory for Go plugins.

func WithURLRelease

func WithURLRelease(url string) Option

WithURLRelease enables the use of URL release. (Default is GitHub release).

type ProxyReconciler

type ProxyReconciler struct {
	client.Client
	envoy.Runtime
	// contains filtered or unexported fields
}

ProxyReconciler reconciles a Proxy object.

func NewProxyReconciler

func NewProxyReconciler(
	c client.Client,
	proxyName string,
	replicaName string,
	apiServerAddr string,
	opts ...Option,
) *ProxyReconciler

NewProxyReconciler returns a new reconcile.Reconciler implementation for the Proxy resource.

func (*ProxyReconciler) Reconcile

func (r *ProxyReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*ProxyReconciler) SetupWithManager

func (r *ProxyReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

func (*ProxyReconciler) Shutdown

func (r *ProxyReconciler) Shutdown(ctx context.Context, reason string)