resourcev1

package
v0.8.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 25, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ResourceServiceDiscoveryProcedure is the fully-qualified name of the ResourceService's Discovery
	// RPC.
	ResourceServiceDiscoveryProcedure = "/otterscale.resource.v1.ResourceService/Discovery"
	// ResourceServiceSchemaProcedure is the fully-qualified name of the ResourceService's Schema RPC.
	ResourceServiceSchemaProcedure = "/otterscale.resource.v1.ResourceService/Schema"
	// ResourceServiceListProcedure is the fully-qualified name of the ResourceService's List RPC.
	ResourceServiceListProcedure = "/otterscale.resource.v1.ResourceService/List"
	// ResourceServiceGetProcedure is the fully-qualified name of the ResourceService's Get RPC.
	ResourceServiceGetProcedure = "/otterscale.resource.v1.ResourceService/Get"
	// ResourceServiceDescribeProcedure is the fully-qualified name of the ResourceService's Describe
	// RPC.
	ResourceServiceDescribeProcedure = "/otterscale.resource.v1.ResourceService/Describe"
	// ResourceServiceCreateProcedure is the fully-qualified name of the ResourceService's Create RPC.
	ResourceServiceCreateProcedure = "/otterscale.resource.v1.ResourceService/Create"
	// ResourceServiceApplyProcedure is the fully-qualified name of the ResourceService's Apply RPC.
	ResourceServiceApplyProcedure = "/otterscale.resource.v1.ResourceService/Apply"
	// ResourceServiceDeleteProcedure is the fully-qualified name of the ResourceService's Delete RPC.
	ResourceServiceDeleteProcedure = "/otterscale.resource.v1.ResourceService/Delete"
	// ResourceServiceWatchProcedure is the fully-qualified name of the ResourceService's Watch RPC.
	ResourceServiceWatchProcedure = "/otterscale.resource.v1.ResourceService/Watch"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// ResourceServiceName is the fully-qualified name of the ResourceService service.
	ResourceServiceName = "otterscale.resource.v1.ResourceService"
)

Variables

View Source 
var (
	WatchEvent_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_ADDED",
		2: "TYPE_MODIFIED",
		3: "TYPE_DELETED",
		4: "TYPE_BOOKMARK",
		5: "TYPE_ERROR",
	}
	WatchEvent_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_ADDED":       1,
		"TYPE_MODIFIED":    2,
		"TYPE_DELETED":     3,
		"TYPE_BOOKMARK":    4,
		"TYPE_ERROR":       5,
	}
)

Enum value maps for WatchEvent_Type.

View Source 
var File_resource_v1_resource_proto protoreflect.FileDescriptor

Functions

func NewResourceServiceHandler 

func NewResourceServiceHandler(svc ResourceServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewResourceServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type APIResource 

type APIResource struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

APIResource represents a Kubernetes API resource with its metadata.

func (*APIResource) ClearGroup 

func (x *APIResource) ClearGroup()

func (*APIResource) ClearKind 

func (x *APIResource) ClearKind()

func (*APIResource) ClearNamespaced 

func (x *APIResource) ClearNamespaced()

func (*APIResource) ClearResource 

func (x *APIResource) ClearResource()

func (*APIResource) ClearVersion 

func (x *APIResource) ClearVersion()

func (*APIResource) GetGroup 

func (x *APIResource) GetGroup() string

func (*APIResource) GetKind 

func (x *APIResource) GetKind() string

func (*APIResource) GetNamespaced 

func (x *APIResource) GetNamespaced() bool

func (*APIResource) GetResource 

func (x *APIResource) GetResource() string

func (*APIResource) GetShortNames 

func (x *APIResource) GetShortNames() []string

func (*APIResource) GetVerbs 

func (x *APIResource) GetVerbs() []string

func (*APIResource) GetVersion 

func (x *APIResource) GetVersion() string

func (*APIResource) HasGroup 

func (x *APIResource) HasGroup() bool

func (*APIResource) HasKind 

func (x *APIResource) HasKind() bool

func (*APIResource) HasNamespaced 

func (x *APIResource) HasNamespaced() bool

func (*APIResource) HasResource 

func (x *APIResource) HasResource() bool

func (*APIResource) HasVersion 

func (x *APIResource) HasVersion() bool

func (*APIResource) ProtoMessage 

func (*APIResource) ProtoMessage()

func (*APIResource) ProtoReflect 

func (x *APIResource) ProtoReflect() protoreflect.Message

func (*APIResource) Reset 

func (x *APIResource) Reset()

func (*APIResource) SetGroup 

func (x *APIResource) SetGroup(v string)

func (*APIResource) SetKind 

func (x *APIResource) SetKind(v string)

func (*APIResource) SetNamespaced 

func (x *APIResource) SetNamespaced(v bool)

func (*APIResource) SetResource 

func (x *APIResource) SetResource(v string)

func (*APIResource) SetShortNames 

func (x *APIResource) SetShortNames(v []string)

func (*APIResource) SetVerbs 

func (x *APIResource) SetVerbs(v []string)

func (*APIResource) SetVersion 

func (x *APIResource) SetVersion(v string)

func (*APIResource) String 

func (x *APIResource) String() string

type APIResource_builder 

type APIResource_builder struct {

	// Kubernetes API Group (e.g., "apps" for Deployments, "" for core resources).
	Group *string
	// Kubernetes API Version (e.g., "v1").
	Version *string
	// Resource name in plural (e.g., "pods", "deployments").
	Resource *string
	// The kind of the resource (e.g., "Pod", "Deployment").
	Kind *string
	// Whether this resource is namespace-scoped.
	Namespaced *bool
	// The list of supported verbs (e.g., "get", "list", "create", "delete").
	Verbs []string
	// Abbreviated aliases for the resource (e.g., "deploy" for deployments).
	ShortNames []string
	// contains filtered or unexported fields
}

func (APIResource_builder) Build 

func (b0 APIResource_builder) Build() *APIResource

type ApplyRequest 

type ApplyRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

ApplyRequest defines the parameters for Server-Side Apply (SSA).

func (*ApplyRequest) ClearCluster 

func (x *ApplyRequest) ClearCluster()

func (*ApplyRequest) ClearFieldManager 

func (x *ApplyRequest) ClearFieldManager()

func (*ApplyRequest) ClearForce 

func (x *ApplyRequest) ClearForce()

func (*ApplyRequest) ClearGroup 

func (x *ApplyRequest) ClearGroup()

func (*ApplyRequest) ClearManifest 

func (x *ApplyRequest) ClearManifest()

func (*ApplyRequest) ClearName 

func (x *ApplyRequest) ClearName()

func (*ApplyRequest) ClearNamespace 

func (x *ApplyRequest) ClearNamespace()

func (*ApplyRequest) ClearResource 

func (x *ApplyRequest) ClearResource()

func (*ApplyRequest) ClearVersion 

func (x *ApplyRequest) ClearVersion()

func (*ApplyRequest) GetCluster 

func (x *ApplyRequest) GetCluster() string

func (*ApplyRequest) GetFieldManager 

func (x *ApplyRequest) GetFieldManager() string

func (*ApplyRequest) GetForce 

func (x *ApplyRequest) GetForce() bool

func (*ApplyRequest) GetGroup 

func (x *ApplyRequest) GetGroup() string

func (*ApplyRequest) GetManifest 

func (x *ApplyRequest) GetManifest() []byte

func (*ApplyRequest) GetName 

func (x *ApplyRequest) GetName() string

func (*ApplyRequest) GetNamespace 

func (x *ApplyRequest) GetNamespace() string

func (*ApplyRequest) GetResource 

func (x *ApplyRequest) GetResource() string

func (*ApplyRequest) GetVersion 

func (x *ApplyRequest) GetVersion() string

func (*ApplyRequest) HasCluster 

func (x *ApplyRequest) HasCluster() bool

func (*ApplyRequest) HasFieldManager 

func (x *ApplyRequest) HasFieldManager() bool

func (*ApplyRequest) HasForce 

func (x *ApplyRequest) HasForce() bool

func (*ApplyRequest) HasGroup 

func (x *ApplyRequest) HasGroup() bool

func (*ApplyRequest) HasManifest 

func (x *ApplyRequest) HasManifest() bool

func (*ApplyRequest) HasName 

func (x *ApplyRequest) HasName() bool

func (*ApplyRequest) HasNamespace 

func (x *ApplyRequest) HasNamespace() bool

func (*ApplyRequest) HasResource 

func (x *ApplyRequest) HasResource() bool

func (*ApplyRequest) HasVersion 

func (x *ApplyRequest) HasVersion() bool

func (*ApplyRequest) ProtoMessage 

func (*ApplyRequest) ProtoMessage()

func (*ApplyRequest) ProtoReflect 

func (x *ApplyRequest) ProtoReflect() protoreflect.Message

func (*ApplyRequest) Reset 

func (x *ApplyRequest) Reset()

func (*ApplyRequest) SetCluster 

func (x *ApplyRequest) SetCluster(v string)

func (*ApplyRequest) SetFieldManager 

func (x *ApplyRequest) SetFieldManager(v string)

func (*ApplyRequest) SetForce 

func (x *ApplyRequest) SetForce(v bool)

func (*ApplyRequest) SetGroup 

func (x *ApplyRequest) SetGroup(v string)

func (*ApplyRequest) SetManifest 

func (x *ApplyRequest) SetManifest(v []byte)

func (*ApplyRequest) SetName 

func (x *ApplyRequest) SetName(v string)

func (*ApplyRequest) SetNamespace 

func (x *ApplyRequest) SetNamespace(v string)

func (*ApplyRequest) SetResource 

func (x *ApplyRequest) SetResource(v string)

func (*ApplyRequest) SetVersion 

func (x *ApplyRequest) SetVersion(v string)

func (*ApplyRequest) String 

func (x *ApplyRequest) String() string

type ApplyRequest_builder 

type ApplyRequest_builder struct {

	// The target Kubernetes cluster identifier.
	Cluster *string
	// Kubernetes API Group (e.g., "apps" for Deployments, "" for core resources like Pods).
	Group *string
	// Kubernetes API Version (e.g., "v1").
	Version *string
	// Kubernetes API Resource name in plural (e.g., "pods", "deployments").
	Resource *string
	// The namespace of the resource.
	Namespace *string
	// The name of the resource.
	Name *string
	// A partial or YAML manifest in JSON format to be merged by the API server.
	Manifest []byte
	// If true, conflicts are resolved in favour of the caller's field manager.
	Force *bool
	// Identifies the entity managing the fields (e.g., "otterscale-web-ui"). Required for SSA.
	FieldManager *string
	// contains filtered or unexported fields
}

func (ApplyRequest_builder) Build 

func (b0 ApplyRequest_builder) Build() *ApplyRequest

type CreateRequest 

type CreateRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

CreateRequest defines the parameters for creating a new object.

func (*CreateRequest) ClearCluster 

func (x *CreateRequest) ClearCluster()

func (*CreateRequest) ClearGroup 

func (x *CreateRequest) ClearGroup()

func (*CreateRequest) ClearManifest 

func (x *CreateRequest) ClearManifest()

func (*CreateRequest) ClearNamespace 

func (x *CreateRequest) ClearNamespace()

func (*CreateRequest) ClearResource 

func (x *CreateRequest) ClearResource()

func (*CreateRequest) ClearVersion 

func (x *CreateRequest) ClearVersion()

func (*CreateRequest) GetCluster 

func (x *CreateRequest) GetCluster() string

func (*CreateRequest) GetGroup 

func (x *CreateRequest) GetGroup() string

func (*CreateRequest) GetManifest 

func (x *CreateRequest) GetManifest() []byte

func (*CreateRequest) GetNamespace 

func (x *CreateRequest) GetNamespace() string

func (*CreateRequest) GetResource 

func (x *CreateRequest) GetResource() string

func (*CreateRequest) GetVersion 

func (x *CreateRequest) GetVersion() string

func (*CreateRequest) HasCluster 

func (x *CreateRequest) HasCluster() bool

func (*CreateRequest) HasGroup 

func (x *CreateRequest) HasGroup() bool

func (*CreateRequest) HasManifest 

func (x *CreateRequest) HasManifest() bool

func (*CreateRequest) HasNamespace 

func (x *CreateRequest) HasNamespace() bool

func (*CreateRequest) HasResource 

func (x *CreateRequest) HasResource() bool

func (*CreateRequest) HasVersion 

func (x *CreateRequest) HasVersion() bool

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

func (x *CreateRequest) ProtoReflect() protoreflect.Message

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) SetCluster 

func (x *CreateRequest) SetCluster(v string)

func (*CreateRequest) SetGroup 

func (x *CreateRequest) SetGroup(v string)

func (*CreateRequest) SetManifest 

func (x *CreateRequest) SetManifest(v []byte)

func (*CreateRequest) SetNamespace 

func (x *CreateRequest) SetNamespace(v string)

func (*CreateRequest) SetResource 

func (x *CreateRequest) SetResource(v string)

func (*CreateRequest) SetVersion 

func (x *CreateRequest) SetVersion(v string)

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateRequest_builder 

type CreateRequest_builder struct {

	// The target Kubernetes cluster identifier.
	Cluster *string
	// Kubernetes API Group (e.g., "apps" for Deployments, "" for core resources like Pods).
	Group *string
	// Kubernetes API Version (e.g., "v1").
	Version *string
	// Kubernetes API Resource name in plural (e.g., "pods", "deployments").
	Resource *string
	// The namespace of the resource.
	Namespace *string
	// The full manifest of the object to be created in YAML format.
	Manifest []byte
	// contains filtered or unexported fields
}

func (CreateRequest_builder) Build 

func (b0 CreateRequest_builder) Build() *CreateRequest

type DeleteRequest 

type DeleteRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

DeleteRequest defines the parameters to remove an object.

func (*DeleteRequest) ClearCluster 

func (x *DeleteRequest) ClearCluster()

func (*DeleteRequest) ClearGracePeriodSeconds 

func (x *DeleteRequest) ClearGracePeriodSeconds()

func (*DeleteRequest) ClearGroup 

func (x *DeleteRequest) ClearGroup()

func (*DeleteRequest) ClearName 

func (x *DeleteRequest) ClearName()

func (*DeleteRequest) ClearNamespace 

func (x *DeleteRequest) ClearNamespace()

func (*DeleteRequest) ClearResource 

func (x *DeleteRequest) ClearResource()

func (*DeleteRequest) ClearVersion 

func (x *DeleteRequest) ClearVersion()

func (*DeleteRequest) GetCluster 

func (x *DeleteRequest) GetCluster() string

func (*DeleteRequest) GetGracePeriodSeconds 

func (x *DeleteRequest) GetGracePeriodSeconds() int64

func (*DeleteRequest) GetGroup 

func (x *DeleteRequest) GetGroup() string

func (*DeleteRequest) GetName 

func (x *DeleteRequest) GetName() string

func (*DeleteRequest) GetNamespace 

func (x *DeleteRequest) GetNamespace() string

func (*DeleteRequest) GetResource 

func (x *DeleteRequest) GetResource() string

func (*DeleteRequest) GetVersion 

func (x *DeleteRequest) GetVersion() string

func (*DeleteRequest) HasCluster 

func (x *DeleteRequest) HasCluster() bool

func (*DeleteRequest) HasGracePeriodSeconds 

func (x *DeleteRequest) HasGracePeriodSeconds() bool

func (*DeleteRequest) HasGroup 

func (x *DeleteRequest) HasGroup() bool

func (*DeleteRequest) HasName 

func (x *DeleteRequest) HasName() bool

func (*DeleteRequest) HasNamespace 

func (x *DeleteRequest) HasNamespace() bool

func (*DeleteRequest) HasResource 

func (x *DeleteRequest) HasResource() bool

func (*DeleteRequest) HasVersion 

func (x *DeleteRequest) HasVersion() bool

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) SetCluster 

func (x *DeleteRequest) SetCluster(v string)

func (*DeleteRequest) SetGracePeriodSeconds 

func (x *DeleteRequest) SetGracePeriodSeconds(v int64)

func (*DeleteRequest) SetGroup 

func (x *DeleteRequest) SetGroup(v string)

func (*DeleteRequest) SetName 

func (x *DeleteRequest) SetName(v string)

func (*DeleteRequest) SetNamespace 

func (x *DeleteRequest) SetNamespace(v string)

func (*DeleteRequest) SetResource 

func (x *DeleteRequest) SetResource(v string)

func (*DeleteRequest) SetVersion 

func (x *DeleteRequest) SetVersion(v string)

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteRequest_builder 

type DeleteRequest_builder struct {

	// The target Kubernetes cluster identifier.
	Cluster *string
	// Kubernetes API Group (e.g., "apps" for Deployments, "" for core resources like Pods).
	Group *string
	// Kubernetes API Version (e.g., "v1").
	Version *string
	// Kubernetes API Resource name in plural (e.g., "pods", "deployments").
	Resource *string
	// The namespace of the resource.
	Namespace *string
	// The name of the resource.
	Name *string
	// The duration in seconds before the object should be deleted. Overrides the default grace period.
	GracePeriodSeconds *int64
	// contains filtered or unexported fields
}

func (DeleteRequest_builder) Build 

func (b0 DeleteRequest_builder) Build() *DeleteRequest

type DescribeRequest 

type DescribeRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

DescribeRequest defines the parameters to describe a resource, retrieving it along with its related Kubernetes events. Equivalent to `kubectl describe`.

func (*DescribeRequest) ClearCluster 

func (x *DescribeRequest) ClearCluster()

func (*DescribeRequest) ClearGroup 

func (x *DescribeRequest) ClearGroup()

func (*DescribeRequest) ClearName 

func (x *DescribeRequest) ClearName()

func (*DescribeRequest) ClearNamespace 

func (x *DescribeRequest) ClearNamespace()

func (*DescribeRequest) ClearResource 

func (x *DescribeRequest) ClearResource()

func (*DescribeRequest) ClearVersion 

func (x *DescribeRequest) ClearVersion()

func (*DescribeRequest) GetCluster 

func (x *DescribeRequest) GetCluster() string

func (*DescribeRequest) GetGroup 

func (x *DescribeRequest) GetGroup() string

func (*DescribeRequest) GetName 

func (x *DescribeRequest) GetName() string

func (*DescribeRequest) GetNamespace 

func (x *DescribeRequest) GetNamespace() string

func (*DescribeRequest) GetResource 

func (x *DescribeRequest) GetResource() string

func (*DescribeRequest) GetVersion 

func (x *DescribeRequest) GetVersion() string

func (*DescribeRequest) HasCluster 

func (x *DescribeRequest) HasCluster() bool

func (*DescribeRequest) HasGroup 

func (x *DescribeRequest) HasGroup() bool

func (*DescribeRequest) HasName 

func (x *DescribeRequest) HasName() bool

func (*DescribeRequest) HasNamespace 

func (x *DescribeRequest) HasNamespace() bool

func (*DescribeRequest) HasResource 

func (x *DescribeRequest) HasResource() bool

func (*DescribeRequest) HasVersion 

func (x *DescribeRequest) HasVersion() bool

func (*DescribeRequest) ProtoMessage 

func (*DescribeRequest) ProtoMessage()

func (*DescribeRequest) ProtoReflect 

func (x *DescribeRequest) ProtoReflect() protoreflect.Message

func (*DescribeRequest) Reset 

func (x *DescribeRequest) Reset()

func (*DescribeRequest) SetCluster 

func (x *DescribeRequest) SetCluster(v string)

func (*DescribeRequest) SetGroup 

func (x *DescribeRequest) SetGroup(v string)

func (*DescribeRequest) SetName 

func (x *DescribeRequest) SetName(v string)

func (*DescribeRequest) SetNamespace 

func (x *DescribeRequest) SetNamespace(v string)

func (*DescribeRequest) SetResource 

func (x *DescribeRequest) SetResource(v string)

func (*DescribeRequest) SetVersion 

func (x *DescribeRequest) SetVersion(v string)

func (*DescribeRequest) String 

func (x *DescribeRequest) String() string

type DescribeRequest_builder 

type DescribeRequest_builder struct {

	// The target Kubernetes cluster identifier.
	Cluster *string
	// Kubernetes API Group (e.g., "apps" for Deployments, "" for core resources like Pods).
	Group *string
	// Kubernetes API Version (e.g., "v1").
	Version *string
	// Kubernetes API Resource name in plural (e.g., "pods", "deployments").
	Resource *string
	// The namespace of the resource.
	Namespace *string
	// The name of the resource.
	Name *string
	// contains filtered or unexported fields
}

func (DescribeRequest_builder) Build 

func (b0 DescribeRequest_builder) Build() *DescribeRequest

type DescribeResponse 

type DescribeResponse struct {
	// contains filtered or unexported fields
}

DescribeResponse contains the resource and its related Kubernetes events.

func (*DescribeResponse) ClearResource 

func (x *DescribeResponse) ClearResource()

func (*DescribeResponse) GetEvents 

func (x *DescribeResponse) GetEvents() []*Resource

func (*DescribeResponse) GetResource 

func (x *DescribeResponse) GetResource() *Resource

func (*DescribeResponse) HasResource 

func (x *DescribeResponse) HasResource() bool

func (*DescribeResponse) ProtoMessage 

func (*DescribeResponse) ProtoMessage()

func (*DescribeResponse) ProtoReflect 

func (x *DescribeResponse) ProtoReflect() protoreflect.Message

func (*DescribeResponse) Reset 

func (x *DescribeResponse) Reset()

func (*DescribeResponse) SetEvents 

func (x *DescribeResponse) SetEvents(v []*Resource)

func (*DescribeResponse) SetResource 

func (x *DescribeResponse) SetResource(v *Resource)

func (*DescribeResponse) String 

func (x *DescribeResponse) String() string

type DescribeResponse_builder 

type DescribeResponse_builder struct {

	// The full resource object.
	Resource *Resource
	// Kubernetes events related to this resource, filtered by involvedObject.uid.
	Events []*Resource
	// contains filtered or unexported fields
}

func (DescribeResponse_builder) Build 

func (b0 DescribeResponse_builder) Build() *DescribeResponse

type DiscoveryRequest 

type DiscoveryRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

DiscoveryRequest defines the parameters for discovering API resources.

func (*DiscoveryRequest) ClearCluster 

func (x *DiscoveryRequest) ClearCluster()

func (*DiscoveryRequest) GetCluster 

func (x *DiscoveryRequest) GetCluster() string

func (*DiscoveryRequest) HasCluster 

func (x *DiscoveryRequest) HasCluster() bool

func (*DiscoveryRequest) ProtoMessage 

func (*DiscoveryRequest) ProtoMessage()

func (*DiscoveryRequest) ProtoReflect 

func (x *DiscoveryRequest) ProtoReflect() protoreflect.Message

func (*DiscoveryRequest) Reset 

func (x *DiscoveryRequest) Reset()

func (*DiscoveryRequest) SetCluster 

func (x *DiscoveryRequest) SetCluster(v string)

func (*DiscoveryRequest) String 

func (x *DiscoveryRequest) String() string

type DiscoveryRequest_builder 

type DiscoveryRequest_builder struct {

	// The target Kubernetes cluster identifier.
	Cluster *string
	// contains filtered or unexported fields
}

func (DiscoveryRequest_builder) Build 

func (b0 DiscoveryRequest_builder) Build() *DiscoveryRequest

type DiscoveryResponse 

type DiscoveryResponse struct {
	// contains filtered or unexported fields
}

DiscoveryResponse contains the list of available API resources in the cluster.

func (*DiscoveryResponse) GetApiResources 

func (x *DiscoveryResponse) GetApiResources() []*APIResource

func (*DiscoveryResponse) ProtoMessage 

func (*DiscoveryResponse) ProtoMessage()

func (*DiscoveryResponse) ProtoReflect 

func (x *DiscoveryResponse) ProtoReflect() protoreflect.Message

func (*DiscoveryResponse) Reset 

func (x *DiscoveryResponse) Reset()

func (*DiscoveryResponse) SetApiResources 

func (x *DiscoveryResponse) SetApiResources(v []*APIResource)

func (*DiscoveryResponse) String 

func (x *DiscoveryResponse) String() string

type DiscoveryResponse_builder 

type DiscoveryResponse_builder struct {

	// The list of available API resources in the cluster.
	ApiResources []*APIResource
	// contains filtered or unexported fields
}

func (DiscoveryResponse_builder) Build 

func (b0 DiscoveryResponse_builder) Build() *DiscoveryResponse

type GetRequest 

type GetRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

GetRequest defines the parameters to fetch a single object.

func (*GetRequest) ClearCluster 

func (x *GetRequest) ClearCluster()

func (*GetRequest) ClearGroup 

func (x *GetRequest) ClearGroup()

func (*GetRequest) ClearName 

func (x *GetRequest) ClearName()

func (*GetRequest) ClearNamespace 

func (x *GetRequest) ClearNamespace()

func (*GetRequest) ClearResource 

func (x *GetRequest) ClearResource()

func (*GetRequest) ClearVersion 

func (x *GetRequest) ClearVersion()

func (*GetRequest) GetCluster 

func (x *GetRequest) GetCluster() string

func (*GetRequest) GetGroup 

func (x *GetRequest) GetGroup() string

func (*GetRequest) GetName 

func (x *GetRequest) GetName() string

func (*GetRequest) GetNamespace 

func (x *GetRequest) GetNamespace() string

func (*GetRequest) GetResource 

func (x *GetRequest) GetResource() string

func (*GetRequest) GetVersion 

func (x *GetRequest) GetVersion() string

func (*GetRequest) HasCluster 

func (x *GetRequest) HasCluster() bool

func (*GetRequest) HasGroup 

func (x *GetRequest) HasGroup() bool

func (*GetRequest) HasName 

func (x *GetRequest) HasName() bool

func (*GetRequest) HasNamespace 

func (x *GetRequest) HasNamespace() bool

func (*GetRequest) HasResource 

func (x *GetRequest) HasResource() bool

func (*GetRequest) HasVersion 

func (x *GetRequest) HasVersion() bool

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) SetCluster 

func (x *GetRequest) SetCluster(v string)

func (*GetRequest) SetGroup 

func (x *GetRequest) SetGroup(v string)

func (*GetRequest) SetName 

func (x *GetRequest) SetName(v string)

func (*GetRequest) SetNamespace 

func (x *GetRequest) SetNamespace(v string)

func (*GetRequest) SetResource 

func (x *GetRequest) SetResource(v string)

func (*GetRequest) SetVersion 

func (x *GetRequest) SetVersion(v string)

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetRequest_builder 

type GetRequest_builder struct {

	// The target Kubernetes cluster identifier.
	Cluster *string
	// Kubernetes API Group (e.g., "apps" for Deployments, "" for core resources like Pods).
	Group *string
	// Kubernetes API Version (e.g., "v1").
	Version *string
	// Kubernetes API Resource name in plural (e.g., "pods", "deployments").
	Resource *string
	// The namespace of the resource.
	Namespace *string
	// The name of the resource.
	Name *string
	// contains filtered or unexported fields
}

func (GetRequest_builder) Build 

func (b0 GetRequest_builder) Build() *GetRequest

type ListRequest 

type ListRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

ListRequest defines the parameters for querying multiple resources.

func (*ListRequest) ClearCluster 

func (x *ListRequest) ClearCluster()

func (*ListRequest) ClearContinue 

func (x *ListRequest) ClearContinue()

func (*ListRequest) ClearFieldSelector 

func (x *ListRequest) ClearFieldSelector()

func (*ListRequest) ClearGroup 

func (x *ListRequest) ClearGroup()

func (*ListRequest) ClearLabelSelector 

func (x *ListRequest) ClearLabelSelector()

func (*ListRequest) ClearLimit 

func (x *ListRequest) ClearLimit()

func (*ListRequest) ClearNamespace 

func (x *ListRequest) ClearNamespace()

func (*ListRequest) ClearResource 

func (x *ListRequest) ClearResource()

func (*ListRequest) ClearVersion 

func (x *ListRequest) ClearVersion()

func (*ListRequest) GetCluster 

func (x *ListRequest) GetCluster() string

func (*ListRequest) GetContinue 

func (x *ListRequest) GetContinue() string

func (*ListRequest) GetFieldSelector 

func (x *ListRequest) GetFieldSelector() string

func (*ListRequest) GetGroup 

func (x *ListRequest) GetGroup() string

func (*ListRequest) GetLabelSelector 

func (x *ListRequest) GetLabelSelector() string

func (*ListRequest) GetLimit 

func (x *ListRequest) GetLimit() int64

func (*ListRequest) GetNamespace 

func (x *ListRequest) GetNamespace() string

func (*ListRequest) GetResource 

func (x *ListRequest) GetResource() string

func (*ListRequest) GetVersion 

func (x *ListRequest) GetVersion() string

func (*ListRequest) HasCluster 

func (x *ListRequest) HasCluster() bool

func (*ListRequest) HasContinue 

func (x *ListRequest) HasContinue() bool

func (*ListRequest) HasFieldSelector 

func (x *ListRequest) HasFieldSelector() bool

func (*ListRequest) HasGroup 

func (x *ListRequest) HasGroup() bool

func (*ListRequest) HasLabelSelector 

func (x *ListRequest) HasLabelSelector() bool

func (*ListRequest) HasLimit 

func (x *ListRequest) HasLimit() bool

func (*ListRequest) HasNamespace 

func (x *ListRequest) HasNamespace() bool

func (*ListRequest) HasResource 

func (x *ListRequest) HasResource() bool

func (*ListRequest) HasVersion 

func (x *ListRequest) HasVersion() bool

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

func (x *ListRequest) ProtoReflect() protoreflect.Message

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) SetCluster 

func (x *ListRequest) SetCluster(v string)

func (*ListRequest) SetContinue 

func (x *ListRequest) SetContinue(v string)

func (*ListRequest) SetFieldSelector 

func (x *ListRequest) SetFieldSelector(v string)

func (*ListRequest) SetGroup 

func (x *ListRequest) SetGroup(v string)

func (*ListRequest) SetLabelSelector 

func (x *ListRequest) SetLabelSelector(v string)

func (*ListRequest) SetLimit 

func (x *ListRequest) SetLimit(v int64)

func (*ListRequest) SetNamespace 

func (x *ListRequest) SetNamespace(v string)

func (*ListRequest) SetResource 

func (x *ListRequest) SetResource(v string)

func (*ListRequest) SetVersion 

func (x *ListRequest) SetVersion(v string)

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListRequest_builder 

type ListRequest_builder struct {

	// The target Kubernetes cluster identifier.
	Cluster *string
	// Kubernetes API Group (e.g., "apps" for Deployments, "" for core resources like Pods).
	Group *string
	// Kubernetes API Version (e.g., "v1").
	Version *string
	// Kubernetes API Resource name in plural (e.g., "pods", "deployments").
	Resource *string
	// The namespace to query. If empty, the request may target all namespaces depending on cluster permissions.
	Namespace *string
	// A selector to restrict the list of returned objects by their labels.
	LabelSelector *string
	// A selector to restrict the list of returned objects by their fields (e.g., "status.phase=Running").
	FieldSelector *string
	// The maximum number of items to return in a single page.
	Limit *int64
	// The continue token for pagination, retrieved from a previous ListResponse.
	Continue *string
	// contains filtered or unexported fields
}

func (ListRequest_builder) Build 

func (b0 ListRequest_builder) Build() *ListRequest

type ListResponse 

type ListResponse struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

ListResponse contains the requested list of resources and pagination metadata.

func (*ListResponse) ClearContinue 

func (x *ListResponse) ClearContinue()

func (*ListResponse) ClearRemainingItemCount 

func (x *ListResponse) ClearRemainingItemCount()

func (*ListResponse) ClearResourceVersion 

func (x *ListResponse) ClearResourceVersion()

func (*ListResponse) GetContinue 

func (x *ListResponse) GetContinue() string

func (*ListResponse) GetItems 

func (x *ListResponse) GetItems() []*Resource

func (*ListResponse) GetRemainingItemCount 

func (x *ListResponse) GetRemainingItemCount() int64

func (*ListResponse) GetResourceVersion 

func (x *ListResponse) GetResourceVersion() string

func (*ListResponse) HasContinue 

func (x *ListResponse) HasContinue() bool

func (*ListResponse) HasRemainingItemCount 

func (x *ListResponse) HasRemainingItemCount() bool

func (*ListResponse) HasResourceVersion 

func (x *ListResponse) HasResourceVersion() bool

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

func (x *ListResponse) ProtoReflect() protoreflect.Message

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) SetContinue 

func (x *ListResponse) SetContinue(v string)

func (*ListResponse) SetItems 

func (x *ListResponse) SetItems(v []*Resource)

func (*ListResponse) SetRemainingItemCount 

func (x *ListResponse) SetRemainingItemCount(v int64)

func (*ListResponse) SetResourceVersion 

func (x *ListResponse) SetResourceVersion(v string)

func (*ListResponse) String 

func (x *ListResponse) String() string

type ListResponse_builder 

type ListResponse_builder struct {

	// The resourceVersion of the list, used to initiate a Watch from a specific point in time.
	ResourceVersion *string
	// A token used to retrieve the next page of results. Empty if no more pages exist.
	Continue *string
	// The estimated number of items remaining if pagination is used.
	RemainingItemCount *int64
	// The list of resources found.
	Items []*Resource
	// contains filtered or unexported fields
}

func (ListResponse_builder) Build 

func (b0 ListResponse_builder) Build() *ListResponse

type Resource 

type Resource struct {
	// contains filtered or unexported fields
}

Resource represents a single Kubernetes object serialized as a JSON string.

func (*Resource) ClearObject 

func (x *Resource) ClearObject()

func (*Resource) GetObject 

func (x *Resource) GetObject() *structpb.Struct

func (*Resource) HasObject 

func (x *Resource) HasObject() bool

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect 

func (x *Resource) ProtoReflect() protoreflect.Message

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) SetObject 

func (x *Resource) SetObject(v *structpb.Struct)

func (*Resource) String 

func (x *Resource) String() string

type ResourceServiceClient 

type ResourceServiceClient interface {
	// Discovery retrieves the available API resources in the specified cluster.
	Discovery(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)
	// Schema retrieves the structural definition (JSON Schema) for a specific resource type.
	// It supports both native Kubernetes resources and installed CRDs.
	// The raw JSON Schema (Draft 4/7 or 2020-12) describing the resource structure.
	// This is typically derived from Kubernetes OpenAPIV3Schema.
	Schema(context.Context, *SchemaRequest) (*structpb.Struct, error)
	// List retrieves a collection of resources based on the provided GVR and filters.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// Get retrieves a single resource by its name within a namespace.
	Get(context.Context, *GetRequest) (*Resource, error)
	// Describe retrieves a resource along with its related Kubernetes events,
	// equivalent to `kubectl describe`.
	Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
	// Create creates a new resource in the cluster using the provided manifest.
	Create(context.Context, *CreateRequest) (*Resource, error)
	// Apply performs a Server-Side Apply (SSA) to update or create a resource.
	// This is the recommended way to perform partial updates.
	Apply(context.Context, *ApplyRequest) (*Resource, error)
	// Delete removes a resource from the cluster by its name.
	Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
	// Watch initiates a server-side stream to monitor resource changes in real-time.
	Watch(context.Context, *WatchRequest) (*connect.ServerStreamForClient[WatchEvent], error)
}

ResourceServiceClient is a client for the otterscale.resource.v1.ResourceService service.

func NewResourceServiceClient 

func NewResourceServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ResourceServiceClient

NewResourceServiceClient constructs a client for the otterscale.resource.v1.ResourceService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ResourceServiceHandler 

type ResourceServiceHandler interface {
	// Discovery retrieves the available API resources in the specified cluster.
	Discovery(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)
	// Schema retrieves the structural definition (JSON Schema) for a specific resource type.
	// It supports both native Kubernetes resources and installed CRDs.
	// The raw JSON Schema (Draft 4/7 or 2020-12) describing the resource structure.
	// This is typically derived from Kubernetes OpenAPIV3Schema.
	Schema(context.Context, *SchemaRequest) (*structpb.Struct, error)
	// List retrieves a collection of resources based on the provided GVR and filters.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// Get retrieves a single resource by its name within a namespace.
	Get(context.Context, *GetRequest) (*Resource, error)
	// Describe retrieves a resource along with its related Kubernetes events,
	// equivalent to `kubectl describe`.
	Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
	// Create creates a new resource in the cluster using the provided manifest.
	Create(context.Context, *CreateRequest) (*Resource, error)
	// Apply performs a Server-Side Apply (SSA) to update or create a resource.
	// This is the recommended way to perform partial updates.
	Apply(context.Context, *ApplyRequest) (*Resource, error)
	// Delete removes a resource from the cluster by its name.
	Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
	// Watch initiates a server-side stream to monitor resource changes in real-time.
	Watch(context.Context, *WatchRequest, *connect.ServerStream[WatchEvent]) error
}

ResourceServiceHandler is an implementation of the otterscale.resource.v1.ResourceService service.

type Resource_builder 

type Resource_builder struct {

	// The full JSON representation of the Kubernetes object.
	// Note: Backend may strip managedFields to reduce payload size.
	Object *structpb.Struct
	// contains filtered or unexported fields
}

func (Resource_builder) Build 

func (b0 Resource_builder) Build() *Resource

type SchemaRequest 

type SchemaRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

SchemaRequest defines the parameters to retrieve the schema of a specific GVK.

func (*SchemaRequest) ClearCluster 

func (x *SchemaRequest) ClearCluster()

func (*SchemaRequest) ClearGroup 

func (x *SchemaRequest) ClearGroup()

func (*SchemaRequest) ClearKind 

func (x *SchemaRequest) ClearKind()

func (*SchemaRequest) ClearVersion 

func (x *SchemaRequest) ClearVersion()

func (*SchemaRequest) GetCluster 

func (x *SchemaRequest) GetCluster() string

func (*SchemaRequest) GetGroup 

func (x *SchemaRequest) GetGroup() string

func (*SchemaRequest) GetKind 

func (x *SchemaRequest) GetKind() string

func (*SchemaRequest) GetVersion 

func (x *SchemaRequest) GetVersion() string

func (*SchemaRequest) HasCluster 

func (x *SchemaRequest) HasCluster() bool

func (*SchemaRequest) HasGroup 

func (x *SchemaRequest) HasGroup() bool

func (*SchemaRequest) HasKind 

func (x *SchemaRequest) HasKind() bool

func (*SchemaRequest) HasVersion 

func (x *SchemaRequest) HasVersion() bool

func (*SchemaRequest) ProtoMessage 

func (*SchemaRequest) ProtoMessage()

func (*SchemaRequest) ProtoReflect 

func (x *SchemaRequest) ProtoReflect() protoreflect.Message

func (*SchemaRequest) Reset 

func (x *SchemaRequest) Reset()

func (*SchemaRequest) SetCluster 

func (x *SchemaRequest) SetCluster(v string)

func (*SchemaRequest) SetGroup 

func (x *SchemaRequest) SetGroup(v string)

func (*SchemaRequest) SetKind 

func (x *SchemaRequest) SetKind(v string)

func (*SchemaRequest) SetVersion 

func (x *SchemaRequest) SetVersion(v string)

func (*SchemaRequest) String 

func (x *SchemaRequest) String() string

type SchemaRequest_builder 

type SchemaRequest_builder struct {

	// The target Kubernetes cluster identifier.
	Cluster *string
	// Kubernetes API Group (e.g., "apps" for Deployments, "" for core resources like Pods).
	Group *string
	// Kubernetes API Version (e.g., "v1").
	Version *string
	// Kubernetes API Kind (e.g., "Pod").
	Kind *string
	// contains filtered or unexported fields
}

func (SchemaRequest_builder) Build 

func (b0 SchemaRequest_builder) Build() *SchemaRequest

type UnimplementedResourceServiceHandler 

type UnimplementedResourceServiceHandler struct{}

UnimplementedResourceServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedResourceServiceHandler) Apply 

func (UnimplementedResourceServiceHandler) Apply(context.Context, *ApplyRequest) (*Resource, error)

func (UnimplementedResourceServiceHandler) Create 

func (UnimplementedResourceServiceHandler) Create(context.Context, *CreateRequest) (*Resource, error)

func (UnimplementedResourceServiceHandler) Delete 

func (UnimplementedResourceServiceHandler) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)

func (UnimplementedResourceServiceHandler) Describe 

func (UnimplementedResourceServiceHandler) Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)

func (UnimplementedResourceServiceHandler) Discovery 

func (UnimplementedResourceServiceHandler) Discovery(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

func (UnimplementedResourceServiceHandler) Get 

func (UnimplementedResourceServiceHandler) Get(context.Context, *GetRequest) (*Resource, error)

func (UnimplementedResourceServiceHandler) List 

func (UnimplementedResourceServiceHandler) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedResourceServiceHandler) Schema 

func (UnimplementedResourceServiceHandler) Schema(context.Context, *SchemaRequest) (*structpb.Struct, error)

func (UnimplementedResourceServiceHandler) Watch 

func (UnimplementedResourceServiceHandler) Watch(context.Context, *WatchRequest, *connect.ServerStream[WatchEvent]) error

type WatchEvent 

type WatchEvent struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

WatchEvent represents a single change notification from the Kubernetes API.

func (*WatchEvent) ClearResource 

func (x *WatchEvent) ClearResource()

func (*WatchEvent) ClearResourceVersion 

func (x *WatchEvent) ClearResourceVersion()

func (*WatchEvent) ClearType 

func (x *WatchEvent) ClearType()

func (*WatchEvent) GetResource 

func (x *WatchEvent) GetResource() *Resource

func (*WatchEvent) GetResourceVersion 

func (x *WatchEvent) GetResourceVersion() string

func (*WatchEvent) GetType 

func (x *WatchEvent) GetType() WatchEvent_Type

func (*WatchEvent) HasResource 

func (x *WatchEvent) HasResource() bool

func (*WatchEvent) HasResourceVersion 

func (x *WatchEvent) HasResourceVersion() bool

func (*WatchEvent) HasType 

func (x *WatchEvent) HasType() bool

func (*WatchEvent) ProtoMessage 

func (*WatchEvent) ProtoMessage()

func (*WatchEvent) ProtoReflect 

func (x *WatchEvent) ProtoReflect() protoreflect.Message

func (*WatchEvent) Reset 

func (x *WatchEvent) Reset()

func (*WatchEvent) SetResource 

func (x *WatchEvent) SetResource(v *Resource)

func (*WatchEvent) SetResourceVersion 

func (x *WatchEvent) SetResourceVersion(v string)

func (*WatchEvent) SetType 

func (x *WatchEvent) SetType(v WatchEvent_Type)

func (*WatchEvent) String 

func (x *WatchEvent) String() string

type WatchEvent_Type 

type WatchEvent_Type int32

Type defines the possible types of events from Kubernetes watch. 

const (
	// Unspecified event type (default zero value).
	WatchEvent_TYPE_UNSPECIFIED WatchEvent_Type = 0
	// A resource was added.
	WatchEvent_TYPE_ADDED WatchEvent_Type = 1
	// A resource was modified.
	WatchEvent_TYPE_MODIFIED WatchEvent_Type = 2
	// A resource was deleted.
	WatchEvent_TYPE_DELETED WatchEvent_Type = 3
	// A bookmark event carrying only a resourceVersion (no resource payload).
	WatchEvent_TYPE_BOOKMARK WatchEvent_Type = 4
	// An error occurred on the server side.
	WatchEvent_TYPE_ERROR WatchEvent_Type = 5
)

func (WatchEvent_Type) Descriptor 

func (WatchEvent_Type) Descriptor() protoreflect.EnumDescriptor

func (WatchEvent_Type) Enum 

func (x WatchEvent_Type) Enum() *WatchEvent_Type

func (WatchEvent_Type) Number 

func (x WatchEvent_Type) Number() protoreflect.EnumNumber

func (WatchEvent_Type) String 

func (x WatchEvent_Type) String() string

func (WatchEvent_Type) Type 

func (WatchEvent_Type) Type() protoreflect.EnumType

type WatchEvent_builder 

type WatchEvent_builder struct {

	// The type of the watch event.
	Type *WatchEvent_Type
	// The state of the resource associated with the event.
	Resource *Resource
	// The resourceVersion of the watch event, used to initiate a Watch from a specific point in time.
	ResourceVersion *string
	// contains filtered or unexported fields
}

func (WatchEvent_builder) Build 

func (b0 WatchEvent_builder) Build() *WatchEvent

type WatchRequest 

type WatchRequest struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

WatchRequest defines the parameters to start a streaming watch.

func (*WatchRequest) ClearCluster 

func (x *WatchRequest) ClearCluster()

func (*WatchRequest) ClearFieldSelector 

func (x *WatchRequest) ClearFieldSelector()

func (*WatchRequest) ClearGroup 

func (x *WatchRequest) ClearGroup()

func (*WatchRequest) ClearLabelSelector 

func (x *WatchRequest) ClearLabelSelector()

func (*WatchRequest) ClearNamespace 

func (x *WatchRequest) ClearNamespace()

func (*WatchRequest) ClearResource 

func (x *WatchRequest) ClearResource()

func (*WatchRequest) ClearResourceVersion 

func (x *WatchRequest) ClearResourceVersion()

func (*WatchRequest) ClearVersion 

func (x *WatchRequest) ClearVersion()

func (*WatchRequest) GetCluster 

func (x *WatchRequest) GetCluster() string

func (*WatchRequest) GetFieldSelector 

func (x *WatchRequest) GetFieldSelector() string

func (*WatchRequest) GetGroup 

func (x *WatchRequest) GetGroup() string

func (*WatchRequest) GetLabelSelector 

func (x *WatchRequest) GetLabelSelector() string

func (*WatchRequest) GetNamespace 

func (x *WatchRequest) GetNamespace() string

func (*WatchRequest) GetResource 

func (x *WatchRequest) GetResource() string

func (*WatchRequest) GetResourceVersion 

func (x *WatchRequest) GetResourceVersion() string

func (*WatchRequest) GetVersion 

func (x *WatchRequest) GetVersion() string

func (*WatchRequest) HasCluster 

func (x *WatchRequest) HasCluster() bool

func (*WatchRequest) HasFieldSelector 

func (x *WatchRequest) HasFieldSelector() bool

func (*WatchRequest) HasGroup 

func (x *WatchRequest) HasGroup() bool

func (*WatchRequest) HasLabelSelector 

func (x *WatchRequest) HasLabelSelector() bool

func (*WatchRequest) HasNamespace 

func (x *WatchRequest) HasNamespace() bool

func (*WatchRequest) HasResource 

func (x *WatchRequest) HasResource() bool

func (*WatchRequest) HasResourceVersion 

func (x *WatchRequest) HasResourceVersion() bool

func (*WatchRequest) HasVersion 

func (x *WatchRequest) HasVersion() bool

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect 

func (x *WatchRequest) ProtoReflect() protoreflect.Message

func (*WatchRequest) Reset 

func (x *WatchRequest) Reset()

func (*WatchRequest) SetCluster 

func (x *WatchRequest) SetCluster(v string)

func (*WatchRequest) SetFieldSelector 

func (x *WatchRequest) SetFieldSelector(v string)

func (*WatchRequest) SetGroup 

func (x *WatchRequest) SetGroup(v string)

func (*WatchRequest) SetLabelSelector 

func (x *WatchRequest) SetLabelSelector(v string)

func (*WatchRequest) SetNamespace 

func (x *WatchRequest) SetNamespace(v string)

func (*WatchRequest) SetResource 

func (x *WatchRequest) SetResource(v string)

func (*WatchRequest) SetResourceVersion 

func (x *WatchRequest) SetResourceVersion(v string)

func (*WatchRequest) SetVersion 

func (x *WatchRequest) SetVersion(v string)

func (*WatchRequest) String 

func (x *WatchRequest) String() string

type WatchRequest_builder 

type WatchRequest_builder struct {

	// The target Kubernetes cluster identifier.
	Cluster *string
	// Kubernetes API Group (e.g., "apps" for Deployments, "" for core resources like Pods).
	Group *string
	// Kubernetes API Version (e.g., "v1").
	Version *string
	// Kubernetes API Resource name in plural (e.g., "pods", "deployments").
	Resource *string
	// The namespace to watch.
	Namespace *string
	// A selector to restrict watched objects by their labels.
	LabelSelector *string
	// A selector to restrict watched objects by their fields.
	FieldSelector *string
	// Start the watch from this specific resource version.
	ResourceVersion *string
	// contains filtered or unexported fields
}

func (WatchRequest_builder) Build 

func (b0 WatchRequest_builder) Build() *WatchRequest

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.