Documentation
¶
Index ¶
- Constants
- func BackFillJSONPaths(ctx context.Context, c client.Client, obj unstructured.Unstructured, ...) (unstructured.Unstructured, error)
- func IgnoreJSONPaths(obj unstructured.Unstructured, ignorePaths []string) (unstructured.Unstructured, error)
- type ServiceReconciler
- func (s *ServiceReconciler) ExtractMetadata(manifests []unstructured.Unstructured) *console.ServiceMetadataAttributes
- func (s *ServiceReconciler) GetPollInterval() func() time.Duration
- func (s *ServiceReconciler) GetPublisher() (string, websocket.Publisher)
- func (s *ServiceReconciler) ListServices(ctx context.Context) *algorithms.Pager[*console.ServiceDeploymentEdgeFragmentForAgent]
- func (s *ServiceReconciler) Poll(ctx context.Context) error
- func (s *ServiceReconciler) Queue() workqueue.TypedRateLimitingInterface[string]
- func (s *ServiceReconciler) Reconcile(ctx context.Context, id string) (result reconcile.Result, err error)
- func (s *ServiceReconciler) Restart()
- func (s *ServiceReconciler) Shutdown()
- func (s *ServiceReconciler) ShutdownQueue()
- func (s *ServiceReconciler) UpdateErrorStatus(ctx context.Context, id string, err error)
- func (s *ServiceReconciler) UpdateErrors(id string, err *console.ServiceErrorAttributes) error
- func (s *ServiceReconciler) UpdateStatus(ctx context.Context, id, revisionID string, sha *string, ...) error
- func (s *ServiceReconciler) WipeCache()
- type ServiceReconcilerOption
- func WithConsoleURL(url string) ServiceReconcilerOption
- func WithManifestTTL(manifestTTL time.Duration) ServiceReconcilerOption
- func WithManifestTTLJitter(manifestTTLJitter time.Duration) ServiceReconcilerOption
- func WithPollInterval(pollInterval time.Duration) ServiceReconcilerOption
- func WithRestoreNamespace(namespace string) ServiceReconcilerOption
- func WithSupervisor(supervisor *streamline.Supervisor) ServiceReconcilerOption
- func WithWaveDeQueueDelay(delay time.Duration) ServiceReconcilerOption
- func WithWaveDelay(waveDelay time.Duration) ServiceReconcilerOption
- func WithWaveMaxConcurrentApplies(n int) ServiceReconcilerOption
- func WithWorkqueueBaseDelay(workqueueBaseDelay time.Duration) ServiceReconcilerOption
- func WithWorkqueueBurst(workqueueBurst int) ServiceReconcilerOption
- func WithWorkqueueMaxDelay(workqueueMaxDelay time.Duration) ServiceReconcilerOption
- func WithWorkqueueQPS(workqueueQPS int) ServiceReconcilerOption
Constants ¶
View Source
const ( Identifier = "Service Controller" OperatorService = "deploy-operator" RestoreConfigMapName = "restore-config-map" IgnoreFieldsAnnotationName = "deployments.plural.sh/ignore-fields" BackFillFieldsAnnotationName = "deployments.plural.sh/backfill-fields" )
Variables ¶
This section is empty.
Functions ¶
func BackFillJSONPaths ¶
func BackFillJSONPaths(ctx context.Context, c client.Client, obj unstructured.Unstructured, ignorePaths []string) (unstructured.Unstructured, error)
func IgnoreJSONPaths ¶
func IgnoreJSONPaths(obj unstructured.Unstructured, ignorePaths []string) (unstructured.Unstructured, error)
Types ¶
type ServiceReconciler ¶
type ServiceReconciler struct {
// contains filtered or unexported fields
}
func NewServiceReconciler ¶
func NewServiceReconciler(consoleClient client.Client, k8sClient ctrclient.Client, mapper meta.RESTMapper, clientSet kubernetes.Interface, dynamicClient dynamic.Interface, discoveryCache discoverycache.Cache, namespaceCache streamline.NamespaceCache, svcCache *cache.Cache[console.ServiceDeploymentForAgent], store store.Store, option ...ServiceReconcilerOption, ) (*ServiceReconciler, error)
func (*ServiceReconciler) ExtractMetadata ¶
func (s *ServiceReconciler) ExtractMetadata(manifests []unstructured.Unstructured) *console.ServiceMetadataAttributes
func (*ServiceReconciler) GetPollInterval ¶
func (s *ServiceReconciler) GetPollInterval() func() time.Duration
func (*ServiceReconciler) GetPublisher ¶
func (s *ServiceReconciler) GetPublisher() (string, websocket.Publisher)
func (*ServiceReconciler) ListServices ¶
func (s *ServiceReconciler) ListServices(ctx context.Context) *algorithms.Pager[*console.ServiceDeploymentEdgeFragmentForAgent]
func (*ServiceReconciler) Queue ¶
func (s *ServiceReconciler) Queue() workqueue.TypedRateLimitingInterface[string]
func (*ServiceReconciler) Restart ¶
func (s *ServiceReconciler) Restart()
func (*ServiceReconciler) Shutdown ¶
func (s *ServiceReconciler) Shutdown()
func (*ServiceReconciler) ShutdownQueue ¶
func (s *ServiceReconciler) ShutdownQueue()
func (*ServiceReconciler) UpdateErrorStatus ¶
func (s *ServiceReconciler) UpdateErrorStatus(ctx context.Context, id string, err error)
func (*ServiceReconciler) UpdateErrors ¶
func (s *ServiceReconciler) UpdateErrors(id string, err *console.ServiceErrorAttributes) error
func (*ServiceReconciler) UpdateStatus ¶
func (s *ServiceReconciler) UpdateStatus(ctx context.Context, id, revisionID string, sha *string, status console.ServiceDeploymentStatus, components []*console.ComponentAttributes, errs []*console.ServiceErrorAttributes, metadata *console.ServiceMetadataAttributes) error
func (*ServiceReconciler) WipeCache ¶
func (s *ServiceReconciler) WipeCache()
type ServiceReconcilerOption ¶
type ServiceReconcilerOption func(*ServiceReconciler)
func WithConsoleURL ¶
func WithConsoleURL(url string) ServiceReconcilerOption
func WithManifestTTL ¶
func WithManifestTTL(manifestTTL time.Duration) ServiceReconcilerOption
func WithManifestTTLJitter ¶
func WithManifestTTLJitter(manifestTTLJitter time.Duration) ServiceReconcilerOption
func WithPollInterval ¶
func WithPollInterval(pollInterval time.Duration) ServiceReconcilerOption
func WithRestoreNamespace ¶
func WithRestoreNamespace(namespace string) ServiceReconcilerOption
func WithSupervisor ¶
func WithSupervisor(supervisor *streamline.Supervisor) ServiceReconcilerOption
func WithWaveDeQueueDelay ¶
func WithWaveDeQueueDelay(delay time.Duration) ServiceReconcilerOption
func WithWaveDelay ¶
func WithWaveDelay(waveDelay time.Duration) ServiceReconcilerOption
func WithWaveMaxConcurrentApplies ¶
func WithWaveMaxConcurrentApplies(n int) ServiceReconcilerOption
func WithWorkqueueBaseDelay ¶
func WithWorkqueueBaseDelay(workqueueBaseDelay time.Duration) ServiceReconcilerOption
func WithWorkqueueBurst ¶
func WithWorkqueueBurst(workqueueBurst int) ServiceReconcilerOption
func WithWorkqueueMaxDelay ¶
func WithWorkqueueMaxDelay(workqueueMaxDelay time.Duration) ServiceReconcilerOption
func WithWorkqueueQPS ¶
func WithWorkqueueQPS(workqueueQPS int) ServiceReconcilerOption
Source Files
Click to show internal directories.
Click to hide internal directories.