Documentation ¶
Index ¶
- type Adapter
- func (a *Adapter) Batch(ctx context.Context, kind domain.Kind, batchType domain.BatchType, ...) error
- func (a *Adapter) Callbacks(_ context.Context) (domain.Callbacks, error)
- func (a *Adapter) DeleteObject(ctx context.Context, id domain.KindName) error
- func (a *Adapter) GetClient(id domain.KindName) (adapters.Client, error)
- func (a *Adapter) GetClientByKind(kind domain.Kind) adapters.Client
- func (a *Adapter) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error
- func (a *Adapter) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool
- func (a *Adapter) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
- func (a *Adapter) PutObject(ctx context.Context, id domain.KindName, object []byte) error
- func (a *Adapter) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)
- func (a *Adapter) Start(ctx context.Context) error
- func (a *Adapter) Stop(ctx context.Context) error
- func (a *Adapter) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error
- type BatchProcessingFunc
- type Client
- func (c *Client) Batch(ctx context.Context, kind domain.Kind, batchType domain.BatchType, ...) error
- func (c *Client) Callbacks(_ context.Context) (domain.Callbacks, error)
- func (c *Client) DeleteObject(_ context.Context, id domain.KindName) error
- func (c *Client) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error
- func (c *Client) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool
- func (c *Client) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
- func (c *Client) PutObject(_ context.Context, id domain.KindName, object []byte) error
- func (c *Client) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)
- func (c *Client) Start(ctx context.Context) error
- func (c *Client) Stop(_ context.Context) error
- func (c *Client) VerifyObject(ctx context.Context, id domain.KindName, newChecksum string) error
- type NoOpDynamicClient
- type NoOpDynamicResource
- func (n *NoOpDynamicResource) Apply(ctx context.Context, name string, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error)
- func (n *NoOpDynamicResource) ApplyStatus(ctx context.Context, name string, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error)
- func (n *NoOpDynamicResource) Create(ctx context.Context, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error)
- func (n *NoOpDynamicResource) Delete(ctx context.Context, name string, options metav1.DeleteOptions, ...) error
- func (n *NoOpDynamicResource) DeleteCollection(ctx context.Context, options metav1.DeleteOptions, ...) error
- func (n *NoOpDynamicResource) Get(ctx context.Context, name string, options metav1.GetOptions, ...) (*unstructured.Unstructured, error)
- func (n *NoOpDynamicResource) List(ctx context.Context, opts metav1.ListOptions) (*unstructured.UnstructuredList, error)
- func (n *NoOpDynamicResource) Namespace(namespace string) dynamic.ResourceInterface
- func (n *NoOpDynamicResource) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, ...) (*unstructured.Unstructured, error)
- func (n *NoOpDynamicResource) Update(ctx context.Context, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error)
- func (n *NoOpDynamicResource) UpdateStatus(ctx context.Context, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error)
- func (n *NoOpDynamicResource) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
- type NoOpWatch
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter struct {
// contains filtered or unexported fields
}
func NewInClusterAdapter ¶
func (*Adapter) DeleteObject ¶
func (*Adapter) GetClientByKind ¶ added in v0.0.47
func (*Adapter) PatchObject ¶
func (*Adapter) RegisterCallbacks ¶
type BatchProcessingFunc ¶ added in v0.0.47
type Client ¶
type Client struct { ShadowObjects map[string][]byte Strategy domain.Strategy // contains filtered or unexported fields }
func (*Client) DeleteObject ¶
func (*Client) PatchObject ¶
func (*Client) RegisterCallbacks ¶
type NoOpDynamicClient ¶ added in v0.0.67
type NoOpDynamicClient struct { }
func (*NoOpDynamicClient) Resource ¶ added in v0.0.67
func (n *NoOpDynamicClient) Resource(gvr schema.GroupVersionResource) dynamic.NamespaceableResourceInterface
type NoOpDynamicResource ¶ added in v0.0.67
type NoOpDynamicResource struct {
// contains filtered or unexported fields
}
func (*NoOpDynamicResource) Apply ¶ added in v0.0.67
func (n *NoOpDynamicResource) Apply(ctx context.Context, name string, obj *unstructured.Unstructured, options metav1.ApplyOptions, subresources ...string) (*unstructured.Unstructured, error)
func (*NoOpDynamicResource) ApplyStatus ¶ added in v0.0.67
func (n *NoOpDynamicResource) ApplyStatus(ctx context.Context, name string, obj *unstructured.Unstructured, options metav1.ApplyOptions) (*unstructured.Unstructured, error)
func (*NoOpDynamicResource) Create ¶ added in v0.0.67
func (n *NoOpDynamicResource) Create(ctx context.Context, obj *unstructured.Unstructured, options metav1.CreateOptions, subresources ...string) (*unstructured.Unstructured, error)
func (*NoOpDynamicResource) Delete ¶ added in v0.0.67
func (n *NoOpDynamicResource) Delete(ctx context.Context, name string, options metav1.DeleteOptions, subresources ...string) error
func (*NoOpDynamicResource) DeleteCollection ¶ added in v0.0.67
func (n *NoOpDynamicResource) DeleteCollection(ctx context.Context, options metav1.DeleteOptions, listOptions metav1.ListOptions) error
func (*NoOpDynamicResource) Get ¶ added in v0.0.67
func (n *NoOpDynamicResource) Get(ctx context.Context, name string, options metav1.GetOptions, subresources ...string) (*unstructured.Unstructured, error)
func (*NoOpDynamicResource) List ¶ added in v0.0.67
func (n *NoOpDynamicResource) List(ctx context.Context, opts metav1.ListOptions) (*unstructured.UnstructuredList, error)
func (*NoOpDynamicResource) Namespace ¶ added in v0.0.67
func (n *NoOpDynamicResource) Namespace(namespace string) dynamic.ResourceInterface
func (*NoOpDynamicResource) Patch ¶ added in v0.0.67
func (n *NoOpDynamicResource) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, options metav1.PatchOptions, subresources ...string) (*unstructured.Unstructured, error)
func (*NoOpDynamicResource) Update ¶ added in v0.0.67
func (n *NoOpDynamicResource) Update(ctx context.Context, obj *unstructured.Unstructured, options metav1.UpdateOptions, subresources ...string) (*unstructured.Unstructured, error)
func (*NoOpDynamicResource) UpdateStatus ¶ added in v0.0.67
func (n *NoOpDynamicResource) UpdateStatus(ctx context.Context, obj *unstructured.Unstructured, options metav1.UpdateOptions) (*unstructured.Unstructured, error)
func (*NoOpDynamicResource) Watch ¶ added in v0.0.67
func (n *NoOpDynamicResource) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Click to show internal directories.
Click to hide internal directories.