Documentation
¶
Index ¶
- type Client
- func (k *Client) Close() error
- func (k *Client) CreateEvent(ctx context.Context, obj client.Object, reason, message, eventType string) error
- func (k *Client) CreateEventForCRD(ctx context.Context, ...) error
- func (k *Client) CreateMCPServer(ctx context.Context, server *musterv1alpha1.MCPServer) error
- func (k *Client) CreateWorkflow(ctx context.Context, workflow *musterv1alpha1.Workflow) error
- func (k *Client) DeleteMCPServer(ctx context.Context, name, namespace string) error
- func (k *Client) DeleteWorkflow(ctx context.Context, name, namespace string) error
- func (k *Client) GetMCPServer(ctx context.Context, name, namespace string) (*musterv1alpha1.MCPServer, error)
- func (k *Client) GetWorkflow(ctx context.Context, name, namespace string) (*musterv1alpha1.Workflow, error)
- func (k *Client) IsKubernetesMode() bool
- func (k *Client) ListMCPServers(ctx context.Context, namespace string) ([]musterv1alpha1.MCPServer, error)
- func (k *Client) ListWorkflows(ctx context.Context, namespace string) ([]musterv1alpha1.Workflow, error)
- func (k *Client) QueryEvents(ctx context.Context, options api.EventQueryOptions) (*api.EventQueryResult, error)
- func (k *Client) Scheme() *runtime.Scheme
- func (k *Client) UpdateMCPServer(ctx context.Context, server *musterv1alpha1.MCPServer) error
- func (k *Client) UpdateMCPServerStatus(ctx context.Context, server *musterv1alpha1.MCPServer) error
- func (k *Client) UpdateWorkflow(ctx context.Context, workflow *musterv1alpha1.Workflow) error
- func (k *Client) UpdateWorkflowStatus(ctx context.Context, workflow *musterv1alpha1.Workflow) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is a Kubernetes-API-backed implementation of the muster client interface. Per-domain CRUD methods live in sibling files (mcpserver.go, workflow.go, events.go); this file keeps the type, constructor, scheme, lifecycle methods, and discovery-based CRD validation.
func New ¶
New returns a Kubernetes-backed Client for the given REST config. CRD presence is validated at construction so callers fail fast if the cluster hasn't installed muster's CRDs yet.
func (*Client) Close ¶
Close performs cleanup for the Kubernetes client. Controller-runtime clients don't require explicit cleanup; this method exists for interface compatibility.
func (*Client) CreateEvent ¶
func (k *Client) CreateEvent(ctx context.Context, obj client.Object, reason, message, eventType string) error
CreateEvent creates a Kubernetes Event for the given object.
func (*Client) CreateEventForCRD ¶
func (k *Client) CreateEventForCRD(ctx context.Context, crdType, name, namespace, reason, message, eventType string) error
CreateEventForCRD creates a Kubernetes Event for a CRD by type, name, and namespace.
func (*Client) CreateMCPServer ¶
CreateMCPServer creates a new MCPServer resource.
func (*Client) CreateWorkflow ¶
CreateWorkflow creates a new Workflow in Kubernetes.
func (*Client) DeleteMCPServer ¶
DeleteMCPServer deletes an MCPServer resource.
func (*Client) DeleteWorkflow ¶
DeleteWorkflow deletes a Workflow from Kubernetes.
func (*Client) GetMCPServer ¶
func (k *Client) GetMCPServer(ctx context.Context, name, namespace string) (*musterv1alpha1.MCPServer, error)
GetMCPServer retrieves a specific MCPServer resource.
func (*Client) GetWorkflow ¶
func (k *Client) GetWorkflow(ctx context.Context, name, namespace string) (*musterv1alpha1.Workflow, error)
GetWorkflow retrieves a specific Workflow from Kubernetes.
func (*Client) IsKubernetesMode ¶
IsKubernetesMode returns true since this is the Kubernetes implementation.
func (*Client) ListMCPServers ¶
func (k *Client) ListMCPServers(ctx context.Context, namespace string) ([]musterv1alpha1.MCPServer, error)
ListMCPServers lists all MCPServer resources in a namespace.
func (*Client) ListWorkflows ¶
func (k *Client) ListWorkflows(ctx context.Context, namespace string) ([]musterv1alpha1.Workflow, error)
ListWorkflows lists all Workflows in a namespace from Kubernetes.
func (*Client) QueryEvents ¶
func (k *Client) QueryEvents(ctx context.Context, options api.EventQueryOptions) (*api.EventQueryResult, error)
QueryEvents retrieves events from the Kubernetes Events API with filtering. Time-range and source-component filtering happen client-side because the Kubernetes field-selector API doesn't support those.
func (*Client) UpdateMCPServer ¶
UpdateMCPServer updates an existing MCPServer resource.
func (*Client) UpdateMCPServerStatus ¶
UpdateMCPServerStatus updates only the status subresource of an MCPServer.
func (*Client) UpdateWorkflow ¶
UpdateWorkflow updates an existing Workflow in Kubernetes.
func (*Client) UpdateWorkflowStatus ¶
UpdateWorkflowStatus updates only the status subresource of a Workflow.
Source Files