Documentation ¶
Index ¶
- Constants
- type ManifestWorkAgentClient
- func (c *ManifestWorkAgentClient) Create(ctx context.Context, manifestWork *workv1.ManifestWork, ...) (*workv1.ManifestWork, error)
- func (c *ManifestWorkAgentClient) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error
- func (c *ManifestWorkAgentClient) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error
- func (c *ManifestWorkAgentClient) Get(ctx context.Context, name string, opts metav1.GetOptions) (*workv1.ManifestWork, error)
- func (c *ManifestWorkAgentClient) List(ctx context.Context, opts metav1.ListOptions) (*workv1.ManifestWorkList, error)
- func (c *ManifestWorkAgentClient) Patch(ctx context.Context, name string, pt kubetypes.PatchType, data []byte, ...) (result *workv1.ManifestWork, err error)
- func (c *ManifestWorkAgentClient) SetLister(lister workv1lister.ManifestWorkNamespaceLister)
- func (c *ManifestWorkAgentClient) Update(ctx context.Context, manifestWork *workv1.ManifestWork, ...) (*workv1.ManifestWork, error)
- func (c *ManifestWorkAgentClient) UpdateStatus(ctx context.Context, manifestWork *workv1.ManifestWork, ...) (*workv1.ManifestWork, error)
- func (c *ManifestWorkAgentClient) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Constants ¶
View Source
const ( UpdateRequestAction = "update_request" DeleteRequestAction = "delete_request" )
View Source
const ManifestsDeleted = "Deleted"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ManifestWorkAgentClient ¶
type ManifestWorkAgentClient struct {
// contains filtered or unexported fields
}
ManifestWorkAgentClient implements the ManifestWorkInterface. It sends the manifestworks status back to source by CloudEventAgentClient.
func NewManifestWorkAgentClient ¶
func NewManifestWorkAgentClient(cloudEventsClient *generic.CloudEventAgentClient[*workv1.ManifestWork], watcher *watcher.ManifestWorkWatcher) *ManifestWorkAgentClient
func (*ManifestWorkAgentClient) Create ¶
func (c *ManifestWorkAgentClient) Create(ctx context.Context, manifestWork *workv1.ManifestWork, opts metav1.CreateOptions) (*workv1.ManifestWork, error)
func (*ManifestWorkAgentClient) Delete ¶
func (c *ManifestWorkAgentClient) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error
func (*ManifestWorkAgentClient) DeleteCollection ¶
func (c *ManifestWorkAgentClient) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error
func (*ManifestWorkAgentClient) Get ¶
func (c *ManifestWorkAgentClient) Get(ctx context.Context, name string, opts metav1.GetOptions) (*workv1.ManifestWork, error)
func (*ManifestWorkAgentClient) List ¶
func (c *ManifestWorkAgentClient) List(ctx context.Context, opts metav1.ListOptions) (*workv1.ManifestWorkList, error)
func (*ManifestWorkAgentClient) Patch ¶
func (c *ManifestWorkAgentClient) Patch(ctx context.Context, name string, pt kubetypes.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *workv1.ManifestWork, err error)
func (*ManifestWorkAgentClient) SetLister ¶
func (c *ManifestWorkAgentClient) SetLister(lister workv1lister.ManifestWorkNamespaceLister)
func (*ManifestWorkAgentClient) Update ¶
func (c *ManifestWorkAgentClient) Update(ctx context.Context, manifestWork *workv1.ManifestWork, opts metav1.UpdateOptions) (*workv1.ManifestWork, error)
func (*ManifestWorkAgentClient) UpdateStatus ¶
func (c *ManifestWorkAgentClient) UpdateStatus(ctx context.Context, manifestWork *workv1.ManifestWork, opts metav1.UpdateOptions) (*workv1.ManifestWork, error)
func (*ManifestWorkAgentClient) Watch ¶
func (c *ManifestWorkAgentClient) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
Click to show internal directories.
Click to hide internal directories.