controlplanev1beta1

package
v0.4.3 Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ClusterService_CreateCluster_FullMethodName       = "/redpanda.api.controlplane.v1beta1.ClusterService/CreateCluster"
	ClusterService_GetCluster_FullMethodName          = "/redpanda.api.controlplane.v1beta1.ClusterService/GetCluster"
	ClusterService_UpdateCluster_FullMethodName       = "/redpanda.api.controlplane.v1beta1.ClusterService/UpdateCluster"
	ClusterService_ListClusters_FullMethodName        = "/redpanda.api.controlplane.v1beta1.ClusterService/ListClusters"
	ClusterService_DeleteCluster_FullMethodName       = "/redpanda.api.controlplane.v1beta1.ClusterService/DeleteCluster"
	ClusterService_DummyCreateMetadata_FullMethodName = "/redpanda.api.controlplane.v1beta1.ClusterService/DummyCreateMetadata"
	ClusterService_DummyUpdateMetadata_FullMethodName = "/redpanda.api.controlplane.v1beta1.ClusterService/DummyUpdateMetadata"
	ClusterService_DummyDeleteMetadata_FullMethodName = "/redpanda.api.controlplane.v1beta1.ClusterService/DummyDeleteMetadata"
)
View Source
const (
	NamespaceService_CreateNamespace_FullMethodName = "/redpanda.api.controlplane.v1beta1.NamespaceService/CreateNamespace"
	NamespaceService_UpdateNamespace_FullMethodName = "/redpanda.api.controlplane.v1beta1.NamespaceService/UpdateNamespace"
	NamespaceService_GetNamespace_FullMethodName    = "/redpanda.api.controlplane.v1beta1.NamespaceService/GetNamespace"
	NamespaceService_ListNamespaces_FullMethodName  = "/redpanda.api.controlplane.v1beta1.NamespaceService/ListNamespaces"
	NamespaceService_DeleteNamespace_FullMethodName = "/redpanda.api.controlplane.v1beta1.NamespaceService/DeleteNamespace"
)
View Source
const (
	NetworkService_CreateNetwork_FullMethodName       = "/redpanda.api.controlplane.v1beta1.NetworkService/CreateNetwork"
	NetworkService_GetNetwork_FullMethodName          = "/redpanda.api.controlplane.v1beta1.NetworkService/GetNetwork"
	NetworkService_ListNetworks_FullMethodName        = "/redpanda.api.controlplane.v1beta1.NetworkService/ListNetworks"
	NetworkService_DeleteNetwork_FullMethodName       = "/redpanda.api.controlplane.v1beta1.NetworkService/DeleteNetwork"
	NetworkService_DummyCreateMetadata_FullMethodName = "/redpanda.api.controlplane.v1beta1.NetworkService/DummyCreateMetadata"
	NetworkService_DummyDeleteMetadata_FullMethodName = "/redpanda.api.controlplane.v1beta1.NetworkService/DummyDeleteMetadata"
)
View Source
const (
	DummyService_DummyMethod_FullMethodName = "/redpanda.api.controlplane.v1beta1.DummyService/DummyMethod"
)
View Source
const (
	OperationService_GetOperation_FullMethodName = "/redpanda.api.controlplane.v1beta1.OperationService/GetOperation"
)

Variables

View Source
var (
	Cluster_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "STATE_CREATING_AGENT",
		2: "STATE_CREATING",
		3: "STATE_READY",
		4: "STATE_DELETING",
		5: "STATE_DELETING_AGENT",
		6: "STATE_UPGRADING",
		7: "STATE_FAILED",
	}
	Cluster_State_value = map[string]int32{
		"STATE_UNSPECIFIED":    0,
		"STATE_CREATING_AGENT": 1,
		"STATE_CREATING":       2,
		"STATE_READY":          3,
		"STATE_DELETING":       4,
		"STATE_DELETING_AGENT": 5,
		"STATE_UPGRADING":      6,
		"STATE_FAILED":         7,
	}
)

Enum value maps for Cluster_State.

View Source
var (
	Cluster_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_DEDICATED",
		2: "TYPE_BYOC",
	}
	Cluster_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_DEDICATED":   1,
		"TYPE_BYOC":        2,
	}
)

Enum value maps for Cluster_Type.

View Source
var (
	Cluster_ConnectionType_name = map[int32]string{
		0: "CONNECTION_TYPE_UNSPECIFIED",
		1: "CONNECTION_TYPE_PUBLIC",
		2: "CONNECTION_TYPE_PRIVATE",
	}
	Cluster_ConnectionType_value = map[string]int32{
		"CONNECTION_TYPE_UNSPECIFIED": 0,
		"CONNECTION_TYPE_PUBLIC":      1,
		"CONNECTION_TYPE_PRIVATE":     2,
	}
)

Enum value maps for Cluster_ConnectionType.

View Source
var (
	CloudProvider_name = map[int32]string{
		0: "CLOUD_PROVIDER_UNSPECIFIED",
		1: "CLOUD_PROVIDER_AWS",
		2: "CLOUD_PROVIDER_GCP",
	}
	CloudProvider_value = map[string]int32{
		"CLOUD_PROVIDER_UNSPECIFIED": 0,
		"CLOUD_PROVIDER_AWS":         1,
		"CLOUD_PROVIDER_GCP":         2,
	}
)

Enum value maps for CloudProvider.

View Source
var (
	Reason_name = map[int32]string{
		0:  "REASON_UNSPECIFIED",
		1:  "REASON_ZONE_NOT_SUPPORTED_BY_NETWORK",
		2:  "REASON_INSUFFICIENT_QUOTA",
		3:  "REASON_DISABLING_MTLS_NOT_SUPPORTED",
		4:  "REASON_UNSUPPORTED_VERSION",
		5:  "REASON_NETWORK_ALREADY_EXISTS",
		6:  "REASON_REGION_NOT_FOUND",
		7:  "REASON_NO_TOKEN",
		8:  "REASON_TOKEN_EXPIRED",
		9:  "REASON_TOKEN_INVALID",
		10: "REASON_CLUSTER_TYPE_MISMATCH",
		11: "REASON_ONLY_ONE_CLUSTER_PER_NETWORK_ALLOWED",
		12: "REASON_INVALID_INPUT",
		13: "REASON_NETWORK_NOT_READY",
		14: "REASON_CLUSTER_NETWORK_REGION_MISMATCH",
		15: "REASON_THROUGHPUT_TIER_NOT_FOUND",
		16: "REASON_NAMESPACE_NOT_EMPTY",
		17: "REASON_CLUSTER_NETWORK_CLOUD_PROVIDER_MISMATCH",
		18: "REASON_THROUGHPUT_TIER_NOT_AVAILABLE_IN_REGION",
		19: "REASON_CLOUD_PROVIDER_STOCKOUT",
		20: "REASON_CLOUD_PROVIDER_MACHINE_TYPE_UNSUPPORTED_IN_ZONE",
		21: "REASON_CLOUD_PROVIDER_QUOTA_EXCEEDED",
		22: "REASON_NETWORK_CONTAINS_CLUSTERS",
	}
	Reason_value = map[string]int32{
		"REASON_UNSPECIFIED":                                     0,
		"REASON_ZONE_NOT_SUPPORTED_BY_NETWORK":                   1,
		"REASON_INSUFFICIENT_QUOTA":                              2,
		"REASON_DISABLING_MTLS_NOT_SUPPORTED":                    3,
		"REASON_UNSUPPORTED_VERSION":                             4,
		"REASON_NETWORK_ALREADY_EXISTS":                          5,
		"REASON_REGION_NOT_FOUND":                                6,
		"REASON_NO_TOKEN":                                        7,
		"REASON_TOKEN_EXPIRED":                                   8,
		"REASON_TOKEN_INVALID":                                   9,
		"REASON_CLUSTER_TYPE_MISMATCH":                           10,
		"REASON_ONLY_ONE_CLUSTER_PER_NETWORK_ALLOWED":            11,
		"REASON_INVALID_INPUT":                                   12,
		"REASON_NETWORK_NOT_READY":                               13,
		"REASON_CLUSTER_NETWORK_REGION_MISMATCH":                 14,
		"REASON_THROUGHPUT_TIER_NOT_FOUND":                       15,
		"REASON_NAMESPACE_NOT_EMPTY":                             16,
		"REASON_CLUSTER_NETWORK_CLOUD_PROVIDER_MISMATCH":         17,
		"REASON_THROUGHPUT_TIER_NOT_AVAILABLE_IN_REGION":         18,
		"REASON_CLOUD_PROVIDER_STOCKOUT":                         19,
		"REASON_CLOUD_PROVIDER_MACHINE_TYPE_UNSUPPORTED_IN_ZONE": 20,
		"REASON_CLOUD_PROVIDER_QUOTA_EXCEEDED":                   21,
		"REASON_NETWORK_CONTAINS_CLUSTERS":                       22,
	}
)

Enum value maps for Reason.

View Source
var (
	Network_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "STATE_CREATING",
		2: "STATE_READY",
		3: "STATE_DELETING",
		4: "STATE_DELETED",
		5: "STATE_FAILED",
	}
	Network_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"STATE_CREATING":    1,
		"STATE_READY":       2,
		"STATE_DELETING":    3,
		"STATE_DELETED":     4,
		"STATE_FAILED":      5,
	}
)

Enum value maps for Network_State.

View Source
var (
	Operation_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "STATE_IN_PROGRESS",
		2: "STATE_COMPLETED",
		3: "STATE_FAILED",
	}
	Operation_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"STATE_IN_PROGRESS": 1,
		"STATE_COMPLETED":   2,
		"STATE_FAILED":      3,
	}
)

Enum value maps for Operation_State.

View Source
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.controlplane.v1beta1.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCluster",
			Handler:    _ClusterService_CreateCluster_Handler,
		},
		{
			MethodName: "GetCluster",
			Handler:    _ClusterService_GetCluster_Handler,
		},
		{
			MethodName: "UpdateCluster",
			Handler:    _ClusterService_UpdateCluster_Handler,
		},
		{
			MethodName: "ListClusters",
			Handler:    _ClusterService_ListClusters_Handler,
		},
		{
			MethodName: "DeleteCluster",
			Handler:    _ClusterService_DeleteCluster_Handler,
		},
		{
			MethodName: "DummyCreateMetadata",
			Handler:    _ClusterService_DummyCreateMetadata_Handler,
		},
		{
			MethodName: "DummyUpdateMetadata",
			Handler:    _ClusterService_DummyUpdateMetadata_Handler,
		},
		{
			MethodName: "DummyDeleteMetadata",
			Handler:    _ClusterService_DummyDeleteMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/controlplane/v1beta1/cluster.proto",
}

ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var DummyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.controlplane.v1beta1.DummyService",
	HandlerType: (*DummyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DummyMethod",
			Handler:    _DummyService_DummyMethod_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/controlplane/v1beta1/dummy.proto",
}

DummyService_ServiceDesc is the grpc.ServiceDesc for DummyService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_redpanda_api_controlplane_v1beta1_cluster_proto protoreflect.FileDescriptor
View Source
var File_redpanda_api_controlplane_v1beta1_common_proto protoreflect.FileDescriptor
View Source
var File_redpanda_api_controlplane_v1beta1_dummy_proto protoreflect.FileDescriptor
View Source
var File_redpanda_api_controlplane_v1beta1_error_proto protoreflect.FileDescriptor
View Source
var File_redpanda_api_controlplane_v1beta1_namespace_proto protoreflect.FileDescriptor
View Source
var File_redpanda_api_controlplane_v1beta1_network_proto protoreflect.FileDescriptor
View Source
var File_redpanda_api_controlplane_v1beta1_operation_proto protoreflect.FileDescriptor
View Source
var NamespaceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.controlplane.v1beta1.NamespaceService",
	HandlerType: (*NamespaceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNamespace",
			Handler:    _NamespaceService_CreateNamespace_Handler,
		},
		{
			MethodName: "UpdateNamespace",
			Handler:    _NamespaceService_UpdateNamespace_Handler,
		},
		{
			MethodName: "GetNamespace",
			Handler:    _NamespaceService_GetNamespace_Handler,
		},
		{
			MethodName: "ListNamespaces",
			Handler:    _NamespaceService_ListNamespaces_Handler,
		},
		{
			MethodName: "DeleteNamespace",
			Handler:    _NamespaceService_DeleteNamespace_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/controlplane/v1beta1/namespace.proto",
}

NamespaceService_ServiceDesc is the grpc.ServiceDesc for NamespaceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var NetworkService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.controlplane.v1beta1.NetworkService",
	HandlerType: (*NetworkServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNetwork",
			Handler:    _NetworkService_CreateNetwork_Handler,
		},
		{
			MethodName: "GetNetwork",
			Handler:    _NetworkService_GetNetwork_Handler,
		},
		{
			MethodName: "ListNetworks",
			Handler:    _NetworkService_ListNetworks_Handler,
		},
		{
			MethodName: "DeleteNetwork",
			Handler:    _NetworkService_DeleteNetwork_Handler,
		},
		{
			MethodName: "DummyCreateMetadata",
			Handler:    _NetworkService_DummyCreateMetadata_Handler,
		},
		{
			MethodName: "DummyDeleteMetadata",
			Handler:    _NetworkService_DummyDeleteMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/controlplane/v1beta1/network.proto",
}

NetworkService_ServiceDesc is the grpc.ServiceDesc for NetworkService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var OperationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "redpanda.api.controlplane.v1beta1.OperationService",
	HandlerType: (*OperationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOperation",
			Handler:    _OperationService_GetOperation_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "redpanda/api/controlplane/v1beta1/operation.proto",
}

OperationService_ServiceDesc is the grpc.ServiceDesc for OperationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterClusterServiceServer

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

func RegisterDummyServiceServer

func RegisterDummyServiceServer(s grpc.ServiceRegistrar, srv DummyServiceServer)

func RegisterNamespaceServiceServer

func RegisterNamespaceServiceServer(s grpc.ServiceRegistrar, srv NamespaceServiceServer)

func RegisterNetworkServiceServer

func RegisterNetworkServiceServer(s grpc.ServiceRegistrar, srv NetworkServiceServer)

func RegisterOperationServiceServer

func RegisterOperationServiceServer(s grpc.ServiceRegistrar, srv OperationServiceServer)

Types

type CloudProvider

type CloudProvider int32

Cloud Provider where resources are created.

const (
	CloudProvider_CLOUD_PROVIDER_UNSPECIFIED CloudProvider = 0
	CloudProvider_CLOUD_PROVIDER_AWS         CloudProvider = 1
	CloudProvider_CLOUD_PROVIDER_GCP         CloudProvider = 2
)

func (CloudProvider) Descriptor

func (CloudProvider) Enum

func (x CloudProvider) Enum() *CloudProvider

func (CloudProvider) EnumDescriptor deprecated

func (CloudProvider) EnumDescriptor() ([]byte, []int)

Deprecated: Use CloudProvider.Descriptor instead.

func (CloudProvider) Number

func (CloudProvider) String

func (x CloudProvider) String() string

func (CloudProvider) Type

type Cluster

type Cluster struct {

	// ID of the cluster. ID is an output of CreateCluster, and cannot be set by the caller.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the cluster.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Namespace where the cluster will be placed.
	NamespaceId string `protobuf:"bytes,3,opt,name=namespace_id,proto3" json:"namespace_id,omitempty"`
	// Timestamp when the cluster was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,proto3" json:"created_at,omitempty"`
	// Timestamp when the cluster was updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,proto3" json:"updated_at,omitempty"`
	// State of the cluster
	State            Cluster_State  `protobuf:"varint,6,opt,name=state,proto3,enum=redpanda.api.controlplane.v1beta1.Cluster_State" json:"state,omitempty"`
	StateDescription *status.Status `protobuf:"bytes,23,opt,name=state_description,json=stateDescription,proto3" json:"state_description,omitempty"`
	// Desired redpanda version when creating a cluster, only major.minor semver
	// supported on creation.
	RedpandaVersion string                 `protobuf:"bytes,7,opt,name=redpanda_version,json=redpandaVersion,proto3" json:"redpanda_version,omitempty"`
	ThroughputTier  string                 `protobuf:"bytes,8,opt,name=throughput_tier,proto3" json:"throughput_tier,omitempty"`
	Type            Cluster_Type           `protobuf:"varint,9,opt,name=type,proto3,enum=redpanda.api.controlplane.v1beta1.Cluster_Type" json:"type,omitempty"`
	ConnectionType  Cluster_ConnectionType `` /* 147-byte string literal not displayed */
	// Network ID referst to the network of the cluster.
	NetworkId string `protobuf:"bytes,11,opt,name=network_id,proto3" json:"network_id,omitempty"`
	// Cloud Provider where the cluster is created
	CloudProvider CloudProvider `` /* 136-byte string literal not displayed */
	// Region represents the name of the region where the cluster will be provisioned.
	Region string `protobuf:"bytes,13,opt,name=region,proto3" json:"region,omitempty"`
	// Zones of the cluster. Must be valid zones within the selected region.
	// If multiple zones are used, the cluster is a multi-AZ cluster.
	Zones                    []string                          `protobuf:"bytes,14,rep,name=zones,proto3" json:"zones,omitempty"`
	KafkaApi                 *Cluster_KafkaAPI                 `protobuf:"bytes,16,opt,name=kafka_api,proto3" json:"kafka_api,omitempty"`
	HttpProxy                *Cluster_HTTPProxy                `protobuf:"bytes,17,opt,name=http_proxy,proto3" json:"http_proxy,omitempty"`
	RedpandaConsole          *Cluster_RedpandaConsole          `protobuf:"bytes,18,opt,name=redpanda_console,proto3" json:"redpanda_console,omitempty"`
	SchemaRegistry           *Cluster_SchemaRegistry           `protobuf:"bytes,19,opt,name=schema_registry,proto3" json:"schema_registry,omitempty"`
	Prometheus               *Cluster_Prometheus               `protobuf:"bytes,20,opt,name=prometheus,proto3" json:"prometheus,omitempty"`
	CustomerManagedResources *Cluster_CustomerManagedResources `protobuf:"bytes,21,opt,name=customer_managed_resources,proto3" json:"customer_managed_resources,omitempty"`
	PrivateLink              *Cluster_PrivateLinkSpec          `protobuf:"bytes,22,opt,name=private_link,json=privateLink,proto3" json:"private_link,omitempty"`
	DataplaneApi             *Cluster_DataplaneAPI             `protobuf:"bytes,24,opt,name=dataplane_api,proto3" json:"dataplane_api,omitempty"`
	// Tags that are placed on Cloud resources.
	CloudTags map[string]string `` /* 177-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated

func (*Cluster) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetCloudProvider

func (x *Cluster) GetCloudProvider() CloudProvider

func (*Cluster) GetCloudTags

func (x *Cluster) GetCloudTags() map[string]string

func (*Cluster) GetConnectionType

func (x *Cluster) GetConnectionType() Cluster_ConnectionType

func (*Cluster) GetCreatedAt

func (x *Cluster) GetCreatedAt() *timestamppb.Timestamp

func (*Cluster) GetCustomerManagedResources

func (x *Cluster) GetCustomerManagedResources() *Cluster_CustomerManagedResources

func (*Cluster) GetDataplaneApi

func (x *Cluster) GetDataplaneApi() *Cluster_DataplaneAPI

func (*Cluster) GetHttpProxy

func (x *Cluster) GetHttpProxy() *Cluster_HTTPProxy

func (*Cluster) GetId

func (x *Cluster) GetId() string

func (*Cluster) GetKafkaApi

func (x *Cluster) GetKafkaApi() *Cluster_KafkaAPI

func (*Cluster) GetName

func (x *Cluster) GetName() string

func (*Cluster) GetNamespaceId

func (x *Cluster) GetNamespaceId() string

func (*Cluster) GetNetworkId

func (x *Cluster) GetNetworkId() string
func (x *Cluster) GetPrivateLink() *Cluster_PrivateLinkSpec

func (*Cluster) GetPrometheus

func (x *Cluster) GetPrometheus() *Cluster_Prometheus

func (*Cluster) GetRedpandaConsole

func (x *Cluster) GetRedpandaConsole() *Cluster_RedpandaConsole

func (*Cluster) GetRedpandaVersion

func (x *Cluster) GetRedpandaVersion() string

func (*Cluster) GetRegion

func (x *Cluster) GetRegion() string

func (*Cluster) GetSchemaRegistry

func (x *Cluster) GetSchemaRegistry() *Cluster_SchemaRegistry

func (*Cluster) GetState

func (x *Cluster) GetState() Cluster_State

func (*Cluster) GetStateDescription

func (x *Cluster) GetStateDescription() *status.Status

func (*Cluster) GetThroughputTier

func (x *Cluster) GetThroughputTier() string

func (*Cluster) GetType

func (x *Cluster) GetType() Cluster_Type

func (*Cluster) GetUpdatedAt

func (x *Cluster) GetUpdatedAt() *timestamppb.Timestamp

func (*Cluster) GetZones

func (x *Cluster) GetZones() []string

func (*Cluster) ProtoMessage

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect

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

func (*Cluster) Reset

func (x *Cluster) Reset()

func (*Cluster) String

func (x *Cluster) String() string

type ClusterServiceClient

type ClusterServiceClient interface {
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// CreateCluster create a Redpanda cluster. The input contains the spec, that describes the cluster.
	// A Operation is returned. This task allows the caller to find out when the long-running operation of creating a cluster has finished.
	CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*Operation, error)
	// GetCluster retrieves the cluster's information
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// UpdateCluster updates the cluster. It returns a Operation that can be used to wait for the Update to be applied.
	UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*Operation, error)
	// ListClusters lists clusters.
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// DeleteCluster deletes a cluster. It returns a Operation, that can be used to wait for the deletion to be finished.
	DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*Operation, error)
	// Force openapi generator to generate the CreateClusterMetadata, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyCreateMetadata(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*CreateClusterMetadata, error)
	// Force openapi generator to generate the UpdateClusterMetadata, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyUpdateMetadata(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*UpdateClusterMetadata, error)
	// Force openapi generator to generate the DeleteClusterMetadata, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyDeleteMetadata(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*DeleteClusterMetadata, error)
}

ClusterServiceClient is the client API for ClusterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ClusterServiceServer

type ClusterServiceServer interface {
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// CreateCluster create a Redpanda cluster. The input contains the spec, that describes the cluster.
	// A Operation is returned. This task allows the caller to find out when the long-running operation of creating a cluster has finished.
	CreateCluster(context.Context, *CreateClusterRequest) (*Operation, error)
	// GetCluster retrieves the cluster's information
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// UpdateCluster updates the cluster. It returns a Operation that can be used to wait for the Update to be applied.
	UpdateCluster(context.Context, *UpdateClusterRequest) (*Operation, error)
	// ListClusters lists clusters.
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// DeleteCluster deletes a cluster. It returns a Operation, that can be used to wait for the deletion to be finished.
	DeleteCluster(context.Context, *DeleteClusterRequest) (*Operation, error)
	// Force openapi generator to generate the CreateClusterMetadata, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyCreateMetadata(context.Context, *CreateClusterRequest) (*CreateClusterMetadata, error)
	// Force openapi generator to generate the UpdateClusterMetadata, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyUpdateMetadata(context.Context, *UpdateClusterRequest) (*UpdateClusterMetadata, error)
	// Force openapi generator to generate the DeleteClusterMetadata, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyDeleteMetadata(context.Context, *DeleteClusterRequest) (*DeleteClusterMetadata, error)
}

ClusterServiceServer is the server API for ClusterService service. All implementations should embed UnimplementedClusterServiceServer for forward compatibility

type Cluster_ConnectionType

type Cluster_ConnectionType int32

ConnectionType describes the cluster connection type of a Redpanda Cluster. Private clusters are not exposted to the internet.

const (
	Cluster_CONNECTION_TYPE_UNSPECIFIED Cluster_ConnectionType = 0
	Cluster_CONNECTION_TYPE_PUBLIC      Cluster_ConnectionType = 1
	Cluster_CONNECTION_TYPE_PRIVATE     Cluster_ConnectionType = 2
)

func (Cluster_ConnectionType) Descriptor

func (Cluster_ConnectionType) Enum

func (Cluster_ConnectionType) EnumDescriptor deprecated

func (Cluster_ConnectionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Cluster_ConnectionType.Descriptor instead.

func (Cluster_ConnectionType) Number

func (Cluster_ConnectionType) String

func (x Cluster_ConnectionType) String() string

func (Cluster_ConnectionType) Type

type Cluster_CustomerManagedResources

type Cluster_CustomerManagedResources struct {

	// Types that are assignable to CloudProvider:
	//
	//	*Cluster_CustomerManagedResources_Gcp
	CloudProvider isCluster_CustomerManagedResources_CloudProvider `protobuf_oneof:"cloud_provider"`
	// contains filtered or unexported fields
}

The cloud resources created by user.

func (*Cluster_CustomerManagedResources) Descriptor deprecated

func (*Cluster_CustomerManagedResources) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_CustomerManagedResources.ProtoReflect.Descriptor instead.

func (*Cluster_CustomerManagedResources) GetCloudProvider

func (m *Cluster_CustomerManagedResources) GetCloudProvider() isCluster_CustomerManagedResources_CloudProvider

func (*Cluster_CustomerManagedResources) GetGcp

func (*Cluster_CustomerManagedResources) ProtoMessage

func (*Cluster_CustomerManagedResources) ProtoMessage()

func (*Cluster_CustomerManagedResources) ProtoReflect

func (*Cluster_CustomerManagedResources) Reset

func (*Cluster_CustomerManagedResources) String

type Cluster_CustomerManagedResources_GCP

type Cluster_CustomerManagedResources_GCP struct {

	// GCP subnet where Redpanda cluster is deployed.
	Subnet *Cluster_CustomerManagedResources_GCP_Subnet `protobuf:"bytes,1,opt,name=subnet,proto3" json:"subnet,omitempty"`
	// GCP service account for the agent.
	AgentServiceAccount *Cluster_CustomerManagedResources_GCP_ServiceAccount `protobuf:"bytes,2,opt,name=agent_service_account,proto3" json:"agent_service_account,omitempty"`
	// GCP service account for the Redpanda console.
	ConsoleServiceAccount *Cluster_CustomerManagedResources_GCP_ServiceAccount `protobuf:"bytes,3,opt,name=console_service_account,proto3" json:"console_service_account,omitempty"`
	// GCP service account for the connectors.
	ConnectorServiceAccount *Cluster_CustomerManagedResources_GCP_ServiceAccount `protobuf:"bytes,4,opt,name=connector_service_account,proto3" json:"connector_service_account,omitempty"`
	// GCP service account for the Redpanda cluster.
	RedpandaClusterServiceAccount *Cluster_CustomerManagedResources_GCP_ServiceAccount `protobuf:"bytes,5,opt,name=redpanda_cluster_service_account,proto3" json:"redpanda_cluster_service_account,omitempty"`
	// GCP service account for GKE (GCP Kubernetes Engine).
	GkeServiceAccount *Cluster_CustomerManagedResources_GCP_ServiceAccount `protobuf:"bytes,6,opt,name=gke_service_account,proto3" json:"gke_service_account,omitempty"`
	// GCP storage bucket for tiered storage.
	TieredStorageBucket *CustomerManagedGoogleCloudStorageBucket `protobuf:"bytes,7,opt,name=tiered_storage_bucket,proto3" json:"tiered_storage_bucket,omitempty"`
	// contains filtered or unexported fields
}

GCP resources created by user.

func (*Cluster_CustomerManagedResources_GCP) Descriptor deprecated

func (*Cluster_CustomerManagedResources_GCP) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_CustomerManagedResources_GCP.ProtoReflect.Descriptor instead.

func (*Cluster_CustomerManagedResources_GCP) GetAgentServiceAccount

func (*Cluster_CustomerManagedResources_GCP) GetConnectorServiceAccount

func (*Cluster_CustomerManagedResources_GCP) GetConsoleServiceAccount

func (*Cluster_CustomerManagedResources_GCP) GetGkeServiceAccount

func (*Cluster_CustomerManagedResources_GCP) GetRedpandaClusterServiceAccount

func (*Cluster_CustomerManagedResources_GCP) GetSubnet

func (*Cluster_CustomerManagedResources_GCP) GetTieredStorageBucket

func (*Cluster_CustomerManagedResources_GCP) ProtoMessage

func (*Cluster_CustomerManagedResources_GCP) ProtoMessage()

func (*Cluster_CustomerManagedResources_GCP) ProtoReflect

func (*Cluster_CustomerManagedResources_GCP) Reset

func (*Cluster_CustomerManagedResources_GCP) String

type Cluster_CustomerManagedResources_GCP_ServiceAccount

type Cluster_CustomerManagedResources_GCP_ServiceAccount struct {

	// The email of GCP service account.
	Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	// contains filtered or unexported fields
}

ServiceAccount specifies GCP service account.

func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) Descriptor deprecated

Deprecated: Use Cluster_CustomerManagedResources_GCP_ServiceAccount.ProtoReflect.Descriptor instead.

func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) GetEmail

func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) ProtoMessage

func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) ProtoReflect

func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) Reset

func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) String

type Cluster_CustomerManagedResources_GCP_Subnet

type Cluster_CustomerManagedResources_GCP_Subnet struct {

	// Subnet name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Secondary IPv4 range for pods.
	SecondaryIpv4RangePods *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range `protobuf:"bytes,3,opt,name=secondary_ipv4_range_pods,proto3" json:"secondary_ipv4_range_pods,omitempty"`
	// Secondary IPv4 range for services.
	SecondaryIpv4RangeServices *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range `protobuf:"bytes,4,opt,name=secondary_ipv4_range_services,proto3" json:"secondary_ipv4_range_services,omitempty"`
	// Kubernetes Master IPv4 range, e.g. 10.0.0.0/24.
	K8SMasterIpv4Range string `protobuf:"bytes,5,opt,name=k8s_master_ipv4_range,proto3" json:"k8s_master_ipv4_range,omitempty"`
	// contains filtered or unexported fields
}

Subnet defines the GCP subnet where Redpanda cluster is deployed. GCP API: https://cloud.google.com/compute/docs/reference/rest/v1/subnetworks

func (*Cluster_CustomerManagedResources_GCP_Subnet) Descriptor deprecated

Deprecated: Use Cluster_CustomerManagedResources_GCP_Subnet.ProtoReflect.Descriptor instead.

func (*Cluster_CustomerManagedResources_GCP_Subnet) GetK8SMasterIpv4Range

func (x *Cluster_CustomerManagedResources_GCP_Subnet) GetK8SMasterIpv4Range() string

func (*Cluster_CustomerManagedResources_GCP_Subnet) GetName

func (*Cluster_CustomerManagedResources_GCP_Subnet) GetSecondaryIpv4RangePods

func (*Cluster_CustomerManagedResources_GCP_Subnet) GetSecondaryIpv4RangeServices

func (*Cluster_CustomerManagedResources_GCP_Subnet) ProtoMessage

func (*Cluster_CustomerManagedResources_GCP_Subnet) ProtoReflect

func (*Cluster_CustomerManagedResources_GCP_Subnet) Reset

func (*Cluster_CustomerManagedResources_GCP_Subnet) String

type Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range

type Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

SecondaryIPv4Range defines IPv4 range.

func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) Descriptor deprecated

Deprecated: Use Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range.ProtoReflect.Descriptor instead.

func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) GetName

func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) ProtoMessage

func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) ProtoReflect

func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) Reset

func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) String

type Cluster_CustomerManagedResources_Gcp

type Cluster_CustomerManagedResources_Gcp struct {
	// GCP defines GCP resources created by user.
	Gcp *Cluster_CustomerManagedResources_GCP `protobuf:"bytes,1,opt,name=gcp,proto3,oneof"`
}

type Cluster_DataplaneAPI

type Cluster_DataplaneAPI struct {
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_DataplaneAPI) Descriptor deprecated

func (*Cluster_DataplaneAPI) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_DataplaneAPI.ProtoReflect.Descriptor instead.

func (*Cluster_DataplaneAPI) GetUrl

func (x *Cluster_DataplaneAPI) GetUrl() string

func (*Cluster_DataplaneAPI) ProtoMessage

func (*Cluster_DataplaneAPI) ProtoMessage()

func (*Cluster_DataplaneAPI) ProtoReflect

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

func (*Cluster_DataplaneAPI) Reset

func (x *Cluster_DataplaneAPI) Reset()

func (*Cluster_DataplaneAPI) String

func (x *Cluster_DataplaneAPI) String() string

type Cluster_HTTPProxy

type Cluster_HTTPProxy struct {
	Mtls *MTLSSpec `protobuf:"bytes,1,opt,name=mtls,proto3" json:"mtls,omitempty"`
	// HTTP Proxy URL.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_HTTPProxy) Descriptor deprecated

func (*Cluster_HTTPProxy) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_HTTPProxy.ProtoReflect.Descriptor instead.

func (*Cluster_HTTPProxy) GetMtls

func (x *Cluster_HTTPProxy) GetMtls() *MTLSSpec

func (*Cluster_HTTPProxy) GetUrl

func (x *Cluster_HTTPProxy) GetUrl() string

func (*Cluster_HTTPProxy) ProtoMessage

func (*Cluster_HTTPProxy) ProtoMessage()

func (*Cluster_HTTPProxy) ProtoReflect

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

func (*Cluster_HTTPProxy) Reset

func (x *Cluster_HTTPProxy) Reset()

func (*Cluster_HTTPProxy) String

func (x *Cluster_HTTPProxy) String() string

type Cluster_KafkaAPI

type Cluster_KafkaAPI struct {

	// Kafka API Seed Brokers (also known as Bootstrap servers).
	SeedBrokers []string `protobuf:"bytes,1,rep,name=seed_brokers,proto3" json:"seed_brokers,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_KafkaAPI) Descriptor deprecated

func (*Cluster_KafkaAPI) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_KafkaAPI.ProtoReflect.Descriptor instead.

func (*Cluster_KafkaAPI) GetSeedBrokers

func (x *Cluster_KafkaAPI) GetSeedBrokers() []string

func (*Cluster_KafkaAPI) ProtoMessage

func (*Cluster_KafkaAPI) ProtoMessage()

func (*Cluster_KafkaAPI) ProtoReflect

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

func (*Cluster_KafkaAPI) Reset

func (x *Cluster_KafkaAPI) Reset()

func (*Cluster_KafkaAPI) String

func (x *Cluster_KafkaAPI) String() string

type Cluster_PrivateLinkSpec

type Cluster_PrivateLinkSpec struct {

	// Indication on whether Redpanda AWS Private Link Endpoint Service is enabled.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Types that are assignable to CloudProvider:
	//
	//	*Cluster_PrivateLinkSpec_Aws
	//	*Cluster_PrivateLinkSpec_Gcp
	CloudProvider isCluster_PrivateLinkSpec_CloudProvider `protobuf_oneof:"cloud_provider"`
	// The status of Redpanda Private Link Service.
	Status *Cluster_PrivateLinkSpec_PrivateLinkStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Describes specifics about GCP PSC or AWS Private Link.

func (*Cluster_PrivateLinkSpec) Descriptor deprecated

func (*Cluster_PrivateLinkSpec) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_PrivateLinkSpec.ProtoReflect.Descriptor instead.

func (*Cluster_PrivateLinkSpec) GetAws

func (*Cluster_PrivateLinkSpec) GetCloudProvider

func (m *Cluster_PrivateLinkSpec) GetCloudProvider() isCluster_PrivateLinkSpec_CloudProvider

func (*Cluster_PrivateLinkSpec) GetEnabled

func (x *Cluster_PrivateLinkSpec) GetEnabled() bool

func (*Cluster_PrivateLinkSpec) GetGcp

func (*Cluster_PrivateLinkSpec) GetStatus

func (*Cluster_PrivateLinkSpec) ProtoMessage

func (*Cluster_PrivateLinkSpec) ProtoMessage()

func (*Cluster_PrivateLinkSpec) ProtoReflect

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

func (*Cluster_PrivateLinkSpec) Reset

func (x *Cluster_PrivateLinkSpec) Reset()

func (*Cluster_PrivateLinkSpec) String

func (x *Cluster_PrivateLinkSpec) String() string

type Cluster_PrivateLinkSpec_AWS

type Cluster_PrivateLinkSpec_AWS struct {
	AllowedPrincipals []string `protobuf:"bytes,7,rep,name=allowed_principals,json=allowedPrincipals,proto3" json:"allowed_principals,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_PrivateLinkSpec_AWS) Descriptor deprecated

func (*Cluster_PrivateLinkSpec_AWS) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_PrivateLinkSpec_AWS.ProtoReflect.Descriptor instead.

func (*Cluster_PrivateLinkSpec_AWS) GetAllowedPrincipals

func (x *Cluster_PrivateLinkSpec_AWS) GetAllowedPrincipals() []string

func (*Cluster_PrivateLinkSpec_AWS) ProtoMessage

func (*Cluster_PrivateLinkSpec_AWS) ProtoMessage()

func (*Cluster_PrivateLinkSpec_AWS) ProtoReflect

func (*Cluster_PrivateLinkSpec_AWS) Reset

func (x *Cluster_PrivateLinkSpec_AWS) Reset()

func (*Cluster_PrivateLinkSpec_AWS) String

func (x *Cluster_PrivateLinkSpec_AWS) String() string

type Cluster_PrivateLinkSpec_Aws

type Cluster_PrivateLinkSpec_Aws struct {
	Aws *Cluster_PrivateLinkSpec_AWS `protobuf:"bytes,2,opt,name=aws,proto3,oneof"`
}

type Cluster_PrivateLinkSpec_GCP

type Cluster_PrivateLinkSpec_GCP struct {
	ConsumerAcceptList []string `protobuf:"bytes,2,rep,name=consumer_accept_list,json=consumerAcceptList,proto3" json:"consumer_accept_list,omitempty"`
	ConsumerRejectList []string `protobuf:"bytes,3,rep,name=consumer_reject_list,json=consumerRejectList,proto3" json:"consumer_reject_list,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_PrivateLinkSpec_GCP) Descriptor deprecated

func (*Cluster_PrivateLinkSpec_GCP) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_PrivateLinkSpec_GCP.ProtoReflect.Descriptor instead.

func (*Cluster_PrivateLinkSpec_GCP) GetConsumerAcceptList

func (x *Cluster_PrivateLinkSpec_GCP) GetConsumerAcceptList() []string

func (*Cluster_PrivateLinkSpec_GCP) GetConsumerRejectList

func (x *Cluster_PrivateLinkSpec_GCP) GetConsumerRejectList() []string

func (*Cluster_PrivateLinkSpec_GCP) ProtoMessage

func (*Cluster_PrivateLinkSpec_GCP) ProtoMessage()

func (*Cluster_PrivateLinkSpec_GCP) ProtoReflect

func (*Cluster_PrivateLinkSpec_GCP) Reset

func (x *Cluster_PrivateLinkSpec_GCP) Reset()

func (*Cluster_PrivateLinkSpec_GCP) String

func (x *Cluster_PrivateLinkSpec_GCP) String() string

type Cluster_PrivateLinkSpec_Gcp

type Cluster_PrivateLinkSpec_Gcp struct {
	Gcp *Cluster_PrivateLinkSpec_GCP `protobuf:"bytes,3,opt,name=gcp,proto3,oneof"`
}

type Cluster_PrivateLinkSpec_PrivateLinkStatus

type Cluster_PrivateLinkSpec_PrivateLinkStatus struct {

	// Types that are assignable to CloudProvider:
	//
	//	*Cluster_PrivateLinkSpec_PrivateLinkStatus_Aws
	//	*Cluster_PrivateLinkSpec_PrivateLinkStatus_Gcp
	CloudProvider isCluster_PrivateLinkSpec_PrivateLinkStatus_CloudProvider `protobuf_oneof:"cloud_provider"`
	// contains filtered or unexported fields
}

PrivateLinkStatus defines the status of Redpanda Private Link Service.

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) Descriptor deprecated

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus.ProtoReflect.Descriptor instead.

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) GetAws

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) GetCloudProvider

func (m *Cluster_PrivateLinkSpec_PrivateLinkStatus) GetCloudProvider() isCluster_PrivateLinkSpec_PrivateLinkStatus_CloudProvider

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) GetGcp

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) ProtoMessage

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) ProtoReflect

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) Reset

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) String

type Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS

type Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS struct {
	ServiceId    string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	ServiceName  string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	ServiceState string `protobuf:"bytes,3,opt,name=service_state,json=serviceState,proto3" json:"service_state,omitempty"`
	// Timestamp when Redpanda AWS Private Link Endpoint Service was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Timestamp when Redpanda AWS Private Link Service was deleted.
	DeletedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	// The list of VPC endpoints established with Redpanda AWS Private Link Endpoint Service.
	VpcEndpointConnections []*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection `` /* 129-byte string literal not displayed */
	// The port of Kafka API seed service.
	KafkaApiSeedPort int32 `protobuf:"varint,7,opt,name=kafka_api_seed_port,json=kafkaApiSeedPort,proto3" json:"kafka_api_seed_port,omitempty"`
	// The port of Schema Registry seed service.
	SchemaRegistrySeedPort int32 `` /* 132-byte string literal not displayed */
	// The port of Redpanda Proxy seed service.
	RedpandaProxySeedPort int32 `` /* 129-byte string literal not displayed */
	// The base port of Kafka API node service. The port for node i (0 .. node_count-1) is kafka_api_node_base_port + i.
	KafkaApiNodeBasePort int32 `` /* 129-byte string literal not displayed */
	// The base port of Redpanda Proxy node service. The port for node i (0 .. node_count-1) is redpanda_proxy_node_base_port + i.
	RedpandaProxyNodeBasePort int32 `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) Descriptor deprecated

Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS.ProtoReflect.Descriptor instead.

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetCreatedAt

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetDeletedAt

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetKafkaApiNodeBasePort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetKafkaApiNodeBasePort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetKafkaApiSeedPort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetKafkaApiSeedPort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetRedpandaProxyNodeBasePort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetRedpandaProxyNodeBasePort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetRedpandaProxySeedPort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetRedpandaProxySeedPort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetSchemaRegistrySeedPort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetSchemaRegistrySeedPort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceId

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceName

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceState

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetVpcEndpointConnections

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) ProtoMessage

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) ProtoReflect

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) Reset

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) String

type Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection

type Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection struct {

	// The ID of VPC endpoint.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The owner of VPC endpoint.
	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// Timestamp when was an VPC endpoint created.
	CreatedAt    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ConnectionId string                 `protobuf:"bytes,5,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// The list of load balancer ARNs.
	LoadBalancerArns []string `protobuf:"bytes,6,rep,name=load_balancer_arns,json=loadBalancerArns,proto3" json:"load_balancer_arns,omitempty"`
	// The list of DNS entries associated to VPC endpoint.
	DnsEntries []*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry `protobuf:"bytes,7,rep,name=dns_entries,json=dnsEntries,proto3" json:"dns_entries,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) Descriptor deprecated

Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection.ProtoReflect.Descriptor instead.

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetConnectionId

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetCreatedAt

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetDnsEntries

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetId

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetLoadBalancerArns

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetOwner

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetState

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) ProtoMessage

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) ProtoReflect

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) Reset

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) String

type Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry

type Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry struct {
	DnsName string `protobuf:"bytes,1,opt,name=dns_name,json=dnsName,proto3" json:"dns_name,omitempty"`
	// The ID of Route53 DNS zone.
	HostedZoneId string `protobuf:"bytes,2,opt,name=hosted_zone_id,json=hostedZoneId,proto3" json:"hosted_zone_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) Descriptor deprecated

Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry.ProtoReflect.Descriptor instead.

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) GetDnsName

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) GetHostedZoneId

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) ProtoMessage

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) ProtoReflect

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) Reset

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) String

type Cluster_PrivateLinkSpec_PrivateLinkStatus_Aws

type Cluster_PrivateLinkSpec_PrivateLinkStatus_Aws struct {
	Aws *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS `protobuf:"bytes,1,opt,name=aws,proto3,oneof"`
}

type Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP

type Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP struct {

	// The service attachment used by by consumers to create endpoint connections to Redpanda GCP PSC.
	ServiceAttachment string `protobuf:"bytes,1,opt,name=service_attachment,json=serviceAttachment,proto3" json:"service_attachment,omitempty"`
	// Timestamp when Redpanda GCP PSC was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Timestamp when Redpanda GCP PSC was deleted.
	DeletedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	// The list of VPC endpoints established with GCP PSC.
	EndpointConnections []*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection `protobuf:"bytes,4,rep,name=endpoint_connections,json=endpointConnections,proto3" json:"endpoint_connections,omitempty"`
	// The port of Kafka API seed service.
	KafkaApiSeedPort int32 `protobuf:"varint,5,opt,name=kafka_api_seed_port,json=kafkaApiSeedPort,proto3" json:"kafka_api_seed_port,omitempty"`
	// The port of Schema Registry seed service.
	SchemaRegistrySeedPort int32 `` /* 132-byte string literal not displayed */
	// The port of Redpanda Proxy seed service.
	RedpandaProxySeedPort int32 `` /* 129-byte string literal not displayed */
	// The base port of Kafka API node service. The port for node i (0 .. node_count-1) is kafka_api_node_base_port + i.
	KafkaApiNodeBasePort int32 `` /* 128-byte string literal not displayed */
	// The base port of Redpanda Proxy node service. The port for node i (0 .. node_count-1) is redpanda_proxy_node_base_port + i.
	RedpandaProxyNodeBasePort int32 `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) Descriptor deprecated

Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP.ProtoReflect.Descriptor instead.

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetCreatedAt

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetDeletedAt

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetEndpointConnections

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetKafkaApiNodeBasePort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetKafkaApiNodeBasePort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetKafkaApiSeedPort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetKafkaApiSeedPort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetRedpandaProxyNodeBasePort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetRedpandaProxyNodeBasePort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetRedpandaProxySeedPort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetRedpandaProxySeedPort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetSchemaRegistrySeedPort

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetSchemaRegistrySeedPort() int32

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetServiceAttachment

func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetServiceAttachment() string

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) ProtoMessage

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) ProtoReflect

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) Reset

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) String

type Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection

type Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection struct {

	// The ID of endpoint connection.
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// The network of consumer connecting to Redpanda GCP PSC (Private Service Connect).
	// e.g. https://www.googleapis.com/compute/v1/projects/my-project/global/networks/vpc-consumer-psc
	ConsumerNetwork string `protobuf:"bytes,2,opt,name=consumer_network,json=consumerNetwork,proto3" json:"consumer_network,omitempty"`
	// The endpoint of connection.
	// e.g. https://www.googleapis.com/compute/v1/projects/my-project/regions/us-west2/forwardingRules/vpc-consumer-psc
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// The state of the endpoint (ACCEPTED | REJECTED).
	State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) Descriptor deprecated

Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection.ProtoReflect.Descriptor instead.

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetConnectionId

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetConsumerNetwork

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetEndpoint

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetState

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) ProtoMessage

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) ProtoReflect

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) Reset

func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) String

type Cluster_PrivateLinkSpec_PrivateLinkStatus_Gcp

type Cluster_PrivateLinkSpec_PrivateLinkStatus_Gcp struct {
	Gcp *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP `protobuf:"bytes,2,opt,name=gcp,proto3,oneof"`
}

type Cluster_Prometheus

type Cluster_Prometheus struct {
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_Prometheus) Descriptor deprecated

func (*Cluster_Prometheus) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_Prometheus.ProtoReflect.Descriptor instead.

func (*Cluster_Prometheus) GetUrl

func (x *Cluster_Prometheus) GetUrl() string

func (*Cluster_Prometheus) ProtoMessage

func (*Cluster_Prometheus) ProtoMessage()

func (*Cluster_Prometheus) ProtoReflect

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

func (*Cluster_Prometheus) Reset

func (x *Cluster_Prometheus) Reset()

func (*Cluster_Prometheus) String

func (x *Cluster_Prometheus) String() string

type Cluster_RedpandaConsole

type Cluster_RedpandaConsole struct {
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_RedpandaConsole) Descriptor deprecated

func (*Cluster_RedpandaConsole) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_RedpandaConsole.ProtoReflect.Descriptor instead.

func (*Cluster_RedpandaConsole) GetUrl

func (x *Cluster_RedpandaConsole) GetUrl() string

func (*Cluster_RedpandaConsole) ProtoMessage

func (*Cluster_RedpandaConsole) ProtoMessage()

func (*Cluster_RedpandaConsole) ProtoReflect

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

func (*Cluster_RedpandaConsole) Reset

func (x *Cluster_RedpandaConsole) Reset()

func (*Cluster_RedpandaConsole) String

func (x *Cluster_RedpandaConsole) String() string

type Cluster_SchemaRegistry

type Cluster_SchemaRegistry struct {
	Mtls *MTLSSpec `protobuf:"bytes,1,opt,name=mtls,proto3" json:"mtls,omitempty"`
	// Schema Registry URL.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_SchemaRegistry) Descriptor deprecated

func (*Cluster_SchemaRegistry) Descriptor() ([]byte, []int)

Deprecated: Use Cluster_SchemaRegistry.ProtoReflect.Descriptor instead.

func (*Cluster_SchemaRegistry) GetMtls

func (x *Cluster_SchemaRegistry) GetMtls() *MTLSSpec

func (*Cluster_SchemaRegistry) GetUrl

func (x *Cluster_SchemaRegistry) GetUrl() string

func (*Cluster_SchemaRegistry) ProtoMessage

func (*Cluster_SchemaRegistry) ProtoMessage()

func (*Cluster_SchemaRegistry) ProtoReflect

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

func (*Cluster_SchemaRegistry) Reset

func (x *Cluster_SchemaRegistry) Reset()

func (*Cluster_SchemaRegistry) String

func (x *Cluster_SchemaRegistry) String() string

type Cluster_State

type Cluster_State int32

State describes the state of the cluster.

const (
	Cluster_STATE_UNSPECIFIED    Cluster_State = 0
	Cluster_STATE_CREATING_AGENT Cluster_State = 1
	Cluster_STATE_CREATING       Cluster_State = 2
	Cluster_STATE_READY          Cluster_State = 3
	Cluster_STATE_DELETING       Cluster_State = 4
	Cluster_STATE_DELETING_AGENT Cluster_State = 5
	Cluster_STATE_UPGRADING      Cluster_State = 6
	Cluster_STATE_FAILED         Cluster_State = 7
)

func (Cluster_State) Descriptor

func (Cluster_State) Enum

func (x Cluster_State) Enum() *Cluster_State

func (Cluster_State) EnumDescriptor deprecated

func (Cluster_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Cluster_State.Descriptor instead.

func (Cluster_State) Number

func (Cluster_State) String

func (x Cluster_State) String() string

func (Cluster_State) Type

type Cluster_Type

type Cluster_Type int32

Type of the Cluster. Immutable. Can only be set on cluster creation.

const (
	Cluster_TYPE_UNSPECIFIED Cluster_Type = 0
	Cluster_TYPE_DEDICATED   Cluster_Type = 1
	Cluster_TYPE_BYOC        Cluster_Type = 2
)

func (Cluster_Type) Descriptor

func (Cluster_Type) Enum

func (x Cluster_Type) Enum() *Cluster_Type

func (Cluster_Type) EnumDescriptor deprecated

func (Cluster_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Cluster_Type.Descriptor instead.

func (Cluster_Type) Number

func (Cluster_Type) String

func (x Cluster_Type) String() string

func (Cluster_Type) Type

type CreateClusterMetadata

type CreateClusterMetadata struct {

	// ID of the Cluster created by this operation.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

CreateClusterMetadata provides in-progress information about a CreateCluster Operation.

func (*CreateClusterMetadata) Descriptor deprecated

func (*CreateClusterMetadata) Descriptor() ([]byte, []int)

Deprecated: Use CreateClusterMetadata.ProtoReflect.Descriptor instead.

func (*CreateClusterMetadata) GetClusterId

func (x *CreateClusterMetadata) GetClusterId() string

func (*CreateClusterMetadata) ProtoMessage

func (*CreateClusterMetadata) ProtoMessage()

func (*CreateClusterMetadata) ProtoReflect

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

func (*CreateClusterMetadata) Reset

func (x *CreateClusterMetadata) Reset()

func (*CreateClusterMetadata) String

func (x *CreateClusterMetadata) String() string

type CreateClusterRequest

type CreateClusterRequest struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

CreateClusterRequest is the request of CreateCluster.

func (*CreateClusterRequest) Descriptor deprecated

func (*CreateClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetCluster

func (x *CreateClusterRequest) GetCluster() *Cluster

func (*CreateClusterRequest) ProtoMessage

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect

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

func (*CreateClusterRequest) Reset

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String

func (x *CreateClusterRequest) String() string

type CreateNamespaceRequest

type CreateNamespaceRequest struct {
	Namespace *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

CreateNamespaceRequest is the request of CreateNamespace.

func (*CreateNamespaceRequest) Descriptor deprecated

func (*CreateNamespaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*CreateNamespaceRequest) GetNamespace

func (x *CreateNamespaceRequest) GetNamespace() *Namespace

func (*CreateNamespaceRequest) ProtoMessage

func (*CreateNamespaceRequest) ProtoMessage()

func (*CreateNamespaceRequest) ProtoReflect

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

func (*CreateNamespaceRequest) Reset

func (x *CreateNamespaceRequest) Reset()

func (*CreateNamespaceRequest) String

func (x *CreateNamespaceRequest) String() string

type CreateNetworkMetadata

type CreateNetworkMetadata struct {

	// ID of the network created by this Operation.
	NetworkId string `protobuf:"bytes,1,opt,name=network_id,proto3" json:"network_id,omitempty"`
	// contains filtered or unexported fields
}

CreateNetworkMetadata provides in-progress information about a CreateNetwork Operation.

func (*CreateNetworkMetadata) Descriptor deprecated

func (*CreateNetworkMetadata) Descriptor() ([]byte, []int)

Deprecated: Use CreateNetworkMetadata.ProtoReflect.Descriptor instead.

func (*CreateNetworkMetadata) GetNetworkId

func (x *CreateNetworkMetadata) GetNetworkId() string

func (*CreateNetworkMetadata) ProtoMessage

func (*CreateNetworkMetadata) ProtoMessage()

func (*CreateNetworkMetadata) ProtoReflect

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

func (*CreateNetworkMetadata) Reset

func (x *CreateNetworkMetadata) Reset()

func (*CreateNetworkMetadata) String

func (x *CreateNetworkMetadata) String() string

type CreateNetworkRequest

type CreateNetworkRequest struct {
	Network *Network `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	// contains filtered or unexported fields
}

CreateNetworkRequest is the request of CreateNetwork.

func (*CreateNetworkRequest) Descriptor deprecated

func (*CreateNetworkRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateNetworkRequest.ProtoReflect.Descriptor instead.

func (*CreateNetworkRequest) GetNetwork

func (x *CreateNetworkRequest) GetNetwork() *Network

func (*CreateNetworkRequest) ProtoMessage

func (*CreateNetworkRequest) ProtoMessage()

func (*CreateNetworkRequest) ProtoReflect

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

func (*CreateNetworkRequest) Reset

func (x *CreateNetworkRequest) Reset()

func (*CreateNetworkRequest) String

func (x *CreateNetworkRequest) String() string

type CustomerManagedGoogleCloudStorageBucket

type CustomerManagedGoogleCloudStorageBucket struct {

	// The name of GCP storage bucket.
	// Naming restrictions: https://cloud.google.com/storage/docs/buckets?_ga=2.149222271.-875130499.1677603347#naming
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

GCP storage bucket.

func (*CustomerManagedGoogleCloudStorageBucket) Descriptor deprecated

func (*CustomerManagedGoogleCloudStorageBucket) Descriptor() ([]byte, []int)

Deprecated: Use CustomerManagedGoogleCloudStorageBucket.ProtoReflect.Descriptor instead.

func (*CustomerManagedGoogleCloudStorageBucket) GetName

func (*CustomerManagedGoogleCloudStorageBucket) ProtoMessage

func (*CustomerManagedGoogleCloudStorageBucket) ProtoReflect

func (*CustomerManagedGoogleCloudStorageBucket) Reset

func (*CustomerManagedGoogleCloudStorageBucket) String

type DeleteClusterMetadata

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

DeleteClusterMetadata provides in-progress information about a DeleteCluster Operation.

func (*DeleteClusterMetadata) Descriptor deprecated

func (*DeleteClusterMetadata) Descriptor() ([]byte, []int)

Deprecated: Use DeleteClusterMetadata.ProtoReflect.Descriptor instead.

func (*DeleteClusterMetadata) ProtoMessage

func (*DeleteClusterMetadata) ProtoMessage()

func (*DeleteClusterMetadata) ProtoReflect

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

func (*DeleteClusterMetadata) Reset

func (x *DeleteClusterMetadata) Reset()

func (*DeleteClusterMetadata) String

func (x *DeleteClusterMetadata) String() string

type DeleteClusterRequest

type DeleteClusterRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

DeleteClusterRequest is the request of DeleteCluster.

func (*DeleteClusterRequest) Descriptor deprecated

func (*DeleteClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetId

func (x *DeleteClusterRequest) GetId() string

func (*DeleteClusterRequest) ProtoMessage

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) ProtoReflect

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

func (*DeleteClusterRequest) Reset

func (x *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String

func (x *DeleteClusterRequest) String() string

type DeleteClusterResponse

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

DeleteClusterResponse is the response of DeleteCluster. It is provided by the Operation returned by DeleteCluster once the Operation is done.

func (*DeleteClusterResponse) Descriptor deprecated

func (*DeleteClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteClusterResponse.ProtoReflect.Descriptor instead.

func (*DeleteClusterResponse) ProtoMessage

func (*DeleteClusterResponse) ProtoMessage()

func (*DeleteClusterResponse) ProtoReflect

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

func (*DeleteClusterResponse) Reset

func (x *DeleteClusterResponse) Reset()

func (*DeleteClusterResponse) String

func (x *DeleteClusterResponse) String() string

type DeleteNamespaceRequest

type DeleteNamespaceRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

DeleteNamespaceRequest is the request of DeleteNamespace.

func (*DeleteNamespaceRequest) Descriptor deprecated

func (*DeleteNamespaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceRequest) GetId

func (x *DeleteNamespaceRequest) GetId() string

func (*DeleteNamespaceRequest) ProtoMessage

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) ProtoReflect

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

func (*DeleteNamespaceRequest) Reset

func (x *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) String

func (x *DeleteNamespaceRequest) String() string

type DeleteNamespaceResponse

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

func (*DeleteNamespaceResponse) Descriptor deprecated

func (*DeleteNamespaceResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceResponse) ProtoMessage

func (*DeleteNamespaceResponse) ProtoMessage()

func (*DeleteNamespaceResponse) ProtoReflect

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

func (*DeleteNamespaceResponse) Reset

func (x *DeleteNamespaceResponse) Reset()

func (*DeleteNamespaceResponse) String

func (x *DeleteNamespaceResponse) String() string

type DeleteNetworkMetadata

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

DeleteNetworkMetadata provides in-progress information about a DeleteNetwork Operation.

func (*DeleteNetworkMetadata) Descriptor deprecated

func (*DeleteNetworkMetadata) Descriptor() ([]byte, []int)

Deprecated: Use DeleteNetworkMetadata.ProtoReflect.Descriptor instead.

func (*DeleteNetworkMetadata) ProtoMessage

func (*DeleteNetworkMetadata) ProtoMessage()

func (*DeleteNetworkMetadata) ProtoReflect

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

func (*DeleteNetworkMetadata) Reset

func (x *DeleteNetworkMetadata) Reset()

func (*DeleteNetworkMetadata) String

func (x *DeleteNetworkMetadata) String() string

type DeleteNetworkRequest

type DeleteNetworkRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

DeleteNetworkRequest is the request of DeleteNetwork.

func (*DeleteNetworkRequest) Descriptor deprecated

func (*DeleteNetworkRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteNetworkRequest.ProtoReflect.Descriptor instead.

func (*DeleteNetworkRequest) GetId

func (x *DeleteNetworkRequest) GetId() string

func (*DeleteNetworkRequest) ProtoMessage

func (*DeleteNetworkRequest) ProtoMessage()

func (*DeleteNetworkRequest) ProtoReflect

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

func (*DeleteNetworkRequest) Reset

func (x *DeleteNetworkRequest) Reset()

func (*DeleteNetworkRequest) String

func (x *DeleteNetworkRequest) String() string

type DeleteNetworkResponse

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

DeleteNetworkResponse is the response of DeleteNetwork. It is provided by the Operation returned by DeleteNetwork once the Operation is done.

func (*DeleteNetworkResponse) Descriptor deprecated

func (*DeleteNetworkResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteNetworkResponse.ProtoReflect.Descriptor instead.

func (*DeleteNetworkResponse) ProtoMessage

func (*DeleteNetworkResponse) ProtoMessage()

func (*DeleteNetworkResponse) ProtoReflect

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

func (*DeleteNetworkResponse) Reset

func (x *DeleteNetworkResponse) Reset()

func (*DeleteNetworkResponse) String

func (x *DeleteNetworkResponse) String() string

type DummyMethodResponse

type DummyMethodResponse struct {
	BadRequest   *errdetails.BadRequest   `protobuf:"bytes,1,opt,name=bad_request,json=badRequest,proto3" json:"bad_request,omitempty"`
	ErrorInfo    *errdetails.ErrorInfo    `protobuf:"bytes,2,opt,name=error_info,json=errorInfo,proto3" json:"error_info,omitempty"`
	QuotaFailure *errdetails.QuotaFailure `protobuf:"bytes,3,opt,name=quota_failure,json=quotaFailure,proto3" json:"quota_failure,omitempty"`
	Help         *errdetails.Help         `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"`
	// contains filtered or unexported fields
}

func (*DummyMethodResponse) Descriptor deprecated

func (*DummyMethodResponse) Descriptor() ([]byte, []int)

Deprecated: Use DummyMethodResponse.ProtoReflect.Descriptor instead.

func (*DummyMethodResponse) GetBadRequest

func (x *DummyMethodResponse) GetBadRequest() *errdetails.BadRequest

func (*DummyMethodResponse) GetErrorInfo

func (x *DummyMethodResponse) GetErrorInfo() *errdetails.ErrorInfo

func (*DummyMethodResponse) GetHelp

func (x *DummyMethodResponse) GetHelp() *errdetails.Help

func (*DummyMethodResponse) GetQuotaFailure

func (x *DummyMethodResponse) GetQuotaFailure() *errdetails.QuotaFailure

func (*DummyMethodResponse) ProtoMessage

func (*DummyMethodResponse) ProtoMessage()

func (*DummyMethodResponse) ProtoReflect

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

func (*DummyMethodResponse) Reset

func (x *DummyMethodResponse) Reset()

func (*DummyMethodResponse) String

func (x *DummyMethodResponse) String() string

type DummyServiceClient

type DummyServiceClient interface {
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyMethod(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DummyMethodResponse, error)
}

DummyServiceClient is the client API for DummyService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type DummyServiceServer

type DummyServiceServer interface {
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyMethod(context.Context, *emptypb.Empty) (*DummyMethodResponse, error)
}

DummyServiceServer is the server API for DummyService service. All implementations should embed UnimplementedDummyServiceServer for forward compatibility

type GetClusterRequest

type GetClusterRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetClusterRequest is the request of GetCluster.

func (*GetClusterRequest) Descriptor deprecated

func (*GetClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.

func (*GetClusterRequest) GetId

func (x *GetClusterRequest) GetId() string

func (*GetClusterRequest) ProtoMessage

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) ProtoReflect

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

func (*GetClusterRequest) Reset

func (x *GetClusterRequest) Reset()

func (*GetClusterRequest) String

func (x *GetClusterRequest) String() string

type GetNamespaceRequest

type GetNamespaceRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetNamespaceRequest is the request of GetNamespace.

func (*GetNamespaceRequest) Descriptor deprecated

func (*GetNamespaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetNamespaceRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceRequest) GetId

func (x *GetNamespaceRequest) GetId() string

func (*GetNamespaceRequest) ProtoMessage

func (*GetNamespaceRequest) ProtoMessage()

func (*GetNamespaceRequest) ProtoReflect

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

func (*GetNamespaceRequest) Reset

func (x *GetNamespaceRequest) Reset()

func (*GetNamespaceRequest) String

func (x *GetNamespaceRequest) String() string

type GetNetworkRequest

type GetNetworkRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetNetworkRequest is the request of GetNetwork.

func (*GetNetworkRequest) Descriptor deprecated

func (*GetNetworkRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetNetworkRequest.ProtoReflect.Descriptor instead.

func (*GetNetworkRequest) GetId

func (x *GetNetworkRequest) GetId() string

func (*GetNetworkRequest) ProtoMessage

func (*GetNetworkRequest) ProtoMessage()

func (*GetNetworkRequest) ProtoReflect

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

func (*GetNetworkRequest) Reset

func (x *GetNetworkRequest) Reset()

func (*GetNetworkRequest) String

func (x *GetNetworkRequest) String() string

type GetOperationRequest

type GetOperationRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetOperationRequest is the request of GetOperation

func (*GetOperationRequest) Descriptor deprecated

func (*GetOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetOperationRequest.ProtoReflect.Descriptor instead.

func (*GetOperationRequest) GetId

func (x *GetOperationRequest) GetId() string

func (*GetOperationRequest) ProtoMessage

func (*GetOperationRequest) ProtoMessage()

func (*GetOperationRequest) ProtoReflect

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

func (*GetOperationRequest) Reset

func (x *GetOperationRequest) Reset()

func (*GetOperationRequest) String

func (x *GetOperationRequest) String() string

type ListClustersRequest

type ListClustersRequest struct {
	Filter   *ListClustersRequest_Filter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	PageSize int32                       `protobuf:"varint,3,opt,name=page_size,proto3" json:"page_size,omitempty"`
	// Value of the next_page_token field returned by the previous response. If not provided, the system assumes the first page is requested.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

ListClustersRequest is the request of ListClusters.

func (*ListClustersRequest) Descriptor deprecated

func (*ListClustersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) GetFilter

func (*ListClustersRequest) GetPageSize

func (x *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) GetPageToken

func (x *ListClustersRequest) GetPageToken() string

func (*ListClustersRequest) ProtoMessage

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect

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

func (*ListClustersRequest) Reset

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) String

func (x *ListClustersRequest) String() string

type ListClustersRequest_Filter

type ListClustersRequest_Filter struct {
	NamespaceId   string        `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Name          string        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Region        string        `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	CloudProvider CloudProvider `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListClustersRequest_Filter) Descriptor deprecated

func (*ListClustersRequest_Filter) Descriptor() ([]byte, []int)

Deprecated: Use ListClustersRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListClustersRequest_Filter) GetCloudProvider

func (x *ListClustersRequest_Filter) GetCloudProvider() CloudProvider

func (*ListClustersRequest_Filter) GetName

func (x *ListClustersRequest_Filter) GetName() string

func (*ListClustersRequest_Filter) GetNamespaceId

func (x *ListClustersRequest_Filter) GetNamespaceId() string

func (*ListClustersRequest_Filter) GetRegion

func (x *ListClustersRequest_Filter) GetRegion() string

func (*ListClustersRequest_Filter) ProtoMessage

func (*ListClustersRequest_Filter) ProtoMessage()

func (*ListClustersRequest_Filter) ProtoReflect

func (*ListClustersRequest_Filter) Reset

func (x *ListClustersRequest_Filter) Reset()

func (*ListClustersRequest_Filter) String

func (x *ListClustersRequest_Filter) String() string

type ListClustersResponse

type ListClustersResponse struct {
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// Page Token to fetch the next page. The value can be used as next_page_token in the next call to this endpoint. If the response respresents the final page, this field is not set.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

ListClustersResponse is the response of ListClusters.

func (*ListClustersResponse) Descriptor deprecated

func (*ListClustersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetClusters

func (x *ListClustersResponse) GetClusters() []*Cluster

func (*ListClustersResponse) GetNextPageToken

func (x *ListClustersResponse) GetNextPageToken() string

func (*ListClustersResponse) ProtoMessage

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect

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

func (*ListClustersResponse) Reset

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) String

func (x *ListClustersResponse) String() string

type ListNamespacesRequest

type ListNamespacesRequest struct {
	Filter    *ListNamespacesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	PageSize  int32                         `protobuf:"varint,2,opt,name=page_size,proto3" json:"page_size,omitempty"`
	PageToken string                        `protobuf:"bytes,3,opt,name=page_token,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

ListNamespacesRequest is the request of ListNamespaces.

func (*ListNamespacesRequest) Descriptor deprecated

func (*ListNamespacesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListNamespacesRequest.ProtoReflect.Descriptor instead.

func (*ListNamespacesRequest) GetFilter

func (*ListNamespacesRequest) GetPageSize

func (x *ListNamespacesRequest) GetPageSize() int32

func (*ListNamespacesRequest) GetPageToken

func (x *ListNamespacesRequest) GetPageToken() string

func (*ListNamespacesRequest) ProtoMessage

func (*ListNamespacesRequest) ProtoMessage()

func (*ListNamespacesRequest) ProtoReflect

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

func (*ListNamespacesRequest) Reset

func (x *ListNamespacesRequest) Reset()

func (*ListNamespacesRequest) String

func (x *ListNamespacesRequest) String() string

type ListNamespacesRequest_Filter

type ListNamespacesRequest_Filter struct {
	Name string `protobuf:"bytes,1,opt,name=name,json=namespace,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNamespacesRequest_Filter) Descriptor deprecated

func (*ListNamespacesRequest_Filter) Descriptor() ([]byte, []int)

Deprecated: Use ListNamespacesRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListNamespacesRequest_Filter) GetName

func (x *ListNamespacesRequest_Filter) GetName() string

func (*ListNamespacesRequest_Filter) ProtoMessage

func (*ListNamespacesRequest_Filter) ProtoMessage()

func (*ListNamespacesRequest_Filter) ProtoReflect

func (*ListNamespacesRequest_Filter) Reset

func (x *ListNamespacesRequest_Filter) Reset()

func (*ListNamespacesRequest_Filter) String

type ListNamespacesResponse

type ListNamespacesResponse struct {
	Namespaces    []*Namespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	NextPageToken string       `protobuf:"bytes,2,opt,name=next_page_token,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

ListNamespacesResponse is the response of ListNamespaces.

func (*ListNamespacesResponse) Descriptor deprecated

func (*ListNamespacesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListNamespacesResponse.ProtoReflect.Descriptor instead.

func (*ListNamespacesResponse) GetNamespaces

func (x *ListNamespacesResponse) GetNamespaces() []*Namespace

func (*ListNamespacesResponse) GetNextPageToken

func (x *ListNamespacesResponse) GetNextPageToken() string

func (*ListNamespacesResponse) ProtoMessage

func (*ListNamespacesResponse) ProtoMessage()

func (*ListNamespacesResponse) ProtoReflect

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

func (*ListNamespacesResponse) Reset

func (x *ListNamespacesResponse) Reset()

func (*ListNamespacesResponse) String

func (x *ListNamespacesResponse) String() string

type ListNetworksRequest

type ListNetworksRequest struct {
	Filter    *ListNetworksRequest_Filter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	PageSize  int32                       `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string                      `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

ListNetworksRequest is the request of ListNetworks.

func (*ListNetworksRequest) Descriptor deprecated

func (*ListNetworksRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListNetworksRequest.ProtoReflect.Descriptor instead.

func (*ListNetworksRequest) GetFilter

func (*ListNetworksRequest) GetPageSize

func (x *ListNetworksRequest) GetPageSize() int32

func (*ListNetworksRequest) GetPageToken

func (x *ListNetworksRequest) GetPageToken() string

func (*ListNetworksRequest) ProtoMessage

func (*ListNetworksRequest) ProtoMessage()

func (*ListNetworksRequest) ProtoReflect

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

func (*ListNetworksRequest) Reset

func (x *ListNetworksRequest) Reset()

func (*ListNetworksRequest) String

func (x *ListNetworksRequest) String() string

type ListNetworksRequest_Filter

type ListNetworksRequest_Filter struct {
	NamespaceId   string        `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Name          string        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Region        string        `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	CloudProvider CloudProvider `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListNetworksRequest_Filter) Descriptor deprecated

func (*ListNetworksRequest_Filter) Descriptor() ([]byte, []int)

Deprecated: Use ListNetworksRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListNetworksRequest_Filter) GetCloudProvider

func (x *ListNetworksRequest_Filter) GetCloudProvider() CloudProvider

func (*ListNetworksRequest_Filter) GetName

func (x *ListNetworksRequest_Filter) GetName() string

func (*ListNetworksRequest_Filter) GetNamespaceId

func (x *ListNetworksRequest_Filter) GetNamespaceId() string

func (*ListNetworksRequest_Filter) GetRegion

func (x *ListNetworksRequest_Filter) GetRegion() string

func (*ListNetworksRequest_Filter) ProtoMessage

func (*ListNetworksRequest_Filter) ProtoMessage()

func (*ListNetworksRequest_Filter) ProtoReflect

func (*ListNetworksRequest_Filter) Reset

func (x *ListNetworksRequest_Filter) Reset()

func (*ListNetworksRequest_Filter) String

func (x *ListNetworksRequest_Filter) String() string

type ListNetworksResponse

type ListNetworksResponse struct {
	Networks      []*Network `protobuf:"bytes,1,rep,name=networks,proto3" json:"networks,omitempty"`
	NextPageToken string     `protobuf:"bytes,2,opt,name=next_page_token,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

ListNetworksResponse is the response of ListNetworks.

func (*ListNetworksResponse) Descriptor deprecated

func (*ListNetworksResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListNetworksResponse.ProtoReflect.Descriptor instead.

func (*ListNetworksResponse) GetNetworks

func (x *ListNetworksResponse) GetNetworks() []*Network

func (*ListNetworksResponse) GetNextPageToken

func (x *ListNetworksResponse) GetNextPageToken() string

func (*ListNetworksResponse) ProtoMessage

func (*ListNetworksResponse) ProtoMessage()

func (*ListNetworksResponse) ProtoReflect

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

func (*ListNetworksResponse) Reset

func (x *ListNetworksResponse) Reset()

func (*ListNetworksResponse) String

func (x *ListNetworksResponse) String() string

type MTLSSpec

type MTLSSpec struct {
	Enabled           bool     `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	CaCertificatesPem []string `protobuf:"bytes,2,rep,name=ca_certificates_pem,proto3" json:"ca_certificates_pem,omitempty"`
	// contains filtered or unexported fields
}

MTLSSpec describes the mTLS configuration of a component.

func (*MTLSSpec) Descriptor deprecated

func (*MTLSSpec) Descriptor() ([]byte, []int)

Deprecated: Use MTLSSpec.ProtoReflect.Descriptor instead.

func (*MTLSSpec) GetCaCertificatesPem

func (x *MTLSSpec) GetCaCertificatesPem() []string

func (*MTLSSpec) GetEnabled

func (x *MTLSSpec) GetEnabled() bool

func (*MTLSSpec) ProtoMessage

func (*MTLSSpec) ProtoMessage()

func (*MTLSSpec) ProtoReflect

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

func (*MTLSSpec) Reset

func (x *MTLSSpec) Reset()

func (*MTLSSpec) String

func (x *MTLSSpec) String() string

type Namespace

type Namespace struct {

	// ID of the namespace. ID is an output of CreateNamespace and cannot be set up by the caller
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the namespace.
	Name      string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=updated_at,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Namespace) Descriptor deprecated

func (*Namespace) Descriptor() ([]byte, []int)

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetCreatedAt

func (x *Namespace) GetCreatedAt() *timestamppb.Timestamp

func (*Namespace) GetId

func (x *Namespace) GetId() string

func (*Namespace) GetName

func (x *Namespace) GetName() string

func (*Namespace) GetUpdatedAt

func (x *Namespace) GetUpdatedAt() *timestamppb.Timestamp

func (*Namespace) ProtoMessage

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect

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

func (*Namespace) Reset

func (x *Namespace) Reset()

func (*Namespace) String

func (x *Namespace) String() string

type NamespaceServiceClient

type NamespaceServiceClient interface {
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// CreateNamespace creates the namespace
	CreateNamespace(ctx context.Context, in *CreateNamespaceRequest, opts ...grpc.CallOption) (*Namespace, error)
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// UpdateNamespace updates the namespace. It returns a Operation that can be used to wait for the Update to be applied.
	UpdateNamespace(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*Namespace, error)
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// GetNamespace retrieves the namespace's information
	GetNamespace(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*Namespace, error)
	// ListNamespaces list namespaces.
	ListNamespaces(ctx context.Context, in *ListNamespacesRequest, opts ...grpc.CallOption) (*ListNamespacesResponse, error)
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// DeleteNamespace deletes a namespace.
	DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*DeleteNamespaceResponse, error)
}

NamespaceServiceClient is the client API for NamespaceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type NamespaceServiceServer

type NamespaceServiceServer interface {
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// CreateNamespace creates the namespace
	CreateNamespace(context.Context, *CreateNamespaceRequest) (*Namespace, error)
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// UpdateNamespace updates the namespace. It returns a Operation that can be used to wait for the Update to be applied.
	UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*Namespace, error)
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// GetNamespace retrieves the namespace's information
	GetNamespace(context.Context, *GetNamespaceRequest) (*Namespace, error)
	// ListNamespaces list namespaces.
	ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// DeleteNamespace deletes a namespace.
	DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
}

NamespaceServiceServer is the server API for NamespaceService service. All implementations should embed UnimplementedNamespaceServiceServer for forward compatibility

type Network

type Network struct {

	// ID of the network. ID is an output of CreateNetwork, and cannot be set by the caller.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the network.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Namespace where the cluster will be placed.
	NamespaceId string                 `protobuf:"bytes,3,opt,name=namespace_id,proto3" json:"namespace_id,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,proto3" json:"created_at,omitempty"`
	UpdatedAt   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,proto3" json:"updated_at,omitempty"`
	// State of the network, refers to the state machine of the network.
	State Network_State `protobuf:"varint,6,opt,name=state,proto3,enum=redpanda.api.controlplane.v1beta1.Network_State" json:"state,omitempty"`
	// Cloud Provider of the network.
	CloudProvider CloudProvider `` /* 135-byte string literal not displayed */
	// The name of the region
	Region string `protobuf:"bytes,8,opt,name=region,proto3" json:"region,omitempty"`
	// network CIDR from where public and private subnets are derived. At least a 21 bits CIDR is required.
	CidrBlock                string                            `protobuf:"bytes,9,opt,name=cidr_block,proto3" json:"cidr_block,omitempty"`
	ClusterType              Cluster_Type                      `` /* 131-byte string literal not displayed */
	CustomerManagedResources *Network_CustomerManagedResources `protobuf:"bytes,11,opt,name=customer_managed_resources,proto3" json:"customer_managed_resources,omitempty"`
	// contains filtered or unexported fields
}

Network describes a managed Redpanda network

func (*Network) Descriptor deprecated

func (*Network) Descriptor() ([]byte, []int)

Deprecated: Use Network.ProtoReflect.Descriptor instead.

func (*Network) GetCidrBlock

func (x *Network) GetCidrBlock() string

func (*Network) GetCloudProvider

func (x *Network) GetCloudProvider() CloudProvider

func (*Network) GetClusterType

func (x *Network) GetClusterType() Cluster_Type

func (*Network) GetCreatedAt

func (x *Network) GetCreatedAt() *timestamppb.Timestamp

func (*Network) GetCustomerManagedResources

func (x *Network) GetCustomerManagedResources() *Network_CustomerManagedResources

func (*Network) GetId

func (x *Network) GetId() string

func (*Network) GetName

func (x *Network) GetName() string

func (*Network) GetNamespaceId

func (x *Network) GetNamespaceId() string

func (*Network) GetRegion

func (x *Network) GetRegion() string

func (*Network) GetState

func (x *Network) GetState() Network_State

func (*Network) GetUpdatedAt

func (x *Network) GetUpdatedAt() *timestamppb.Timestamp

func (*Network) ProtoMessage

func (*Network) ProtoMessage()

func (*Network) ProtoReflect

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

func (*Network) Reset

func (x *Network) Reset()

func (*Network) String

func (x *Network) String() string

type NetworkServiceClient

type NetworkServiceClient interface {
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// CreateNetwork create a Redpanda managed network. The input contains the spec, that describes the network.
	// A Operation is returned. This task allows the caller to find out when the long-running operation of creating a network has finished.
	CreateNetwork(ctx context.Context, in *CreateNetworkRequest, opts ...grpc.CallOption) (*Operation, error)
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// GetNetwork retrieves the network's information
	GetNetwork(ctx context.Context, in *GetNetworkRequest, opts ...grpc.CallOption) (*Network, error)
	// ListNetworks list networks.
	ListNetworks(ctx context.Context, in *ListNetworksRequest, opts ...grpc.CallOption) (*ListNetworksResponse, error)
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// DeleteNetwork deletes a network. It returns a Operation, that can be used to wait for the deletion to be finished.
	DeleteNetwork(ctx context.Context, in *DeleteNetworkRequest, opts ...grpc.CallOption) (*Operation, error)
	// Force openapi generator to generate the CreateClusterResponse, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyCreateMetadata(ctx context.Context, in *CreateNetworkRequest, opts ...grpc.CallOption) (*CreateNetworkMetadata, error)
	// Force openapi generator to generate the DeleteClusterResponse, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyDeleteMetadata(ctx context.Context, in *DeleteNetworkRequest, opts ...grpc.CallOption) (*DeleteNetworkMetadata, error)
}

NetworkServiceClient is the client API for NetworkService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type NetworkServiceServer

type NetworkServiceServer interface {
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// CreateNetwork create a Redpanda managed network. The input contains the spec, that describes the network.
	// A Operation is returned. This task allows the caller to find out when the long-running operation of creating a network has finished.
	CreateNetwork(context.Context, *CreateNetworkRequest) (*Operation, error)
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// GetNetwork retrieves the network's information
	GetNetwork(context.Context, *GetNetworkRequest) (*Network, error)
	// ListNetworks list networks.
	ListNetworks(context.Context, *ListNetworksRequest) (*ListNetworksResponse, error)
	// Ignore these linter rules, because we intentionally return a generic Operation message for all long-running operations.
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	// DeleteNetwork deletes a network. It returns a Operation, that can be used to wait for the deletion to be finished.
	DeleteNetwork(context.Context, *DeleteNetworkRequest) (*Operation, error)
	// Force openapi generator to generate the CreateClusterResponse, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyCreateMetadata(context.Context, *CreateNetworkRequest) (*CreateNetworkMetadata, error)
	// Force openapi generator to generate the DeleteClusterResponse, so we can use it in OpenAPI schema.
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	// buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
	DummyDeleteMetadata(context.Context, *DeleteNetworkRequest) (*DeleteNetworkMetadata, error)
}

NetworkServiceServer is the server API for NetworkService service. All implementations should embed UnimplementedNetworkServiceServer for forward compatibility

type Network_CustomerManagedResources

type Network_CustomerManagedResources struct {

	// Currently, CustomerManagedResources supports only GCP.
	//
	// Types that are assignable to CloudProvider:
	//
	//	*Network_CustomerManagedResources_Gcp
	CloudProvider isNetwork_CustomerManagedResources_CloudProvider `protobuf_oneof:"cloud_provider"`
	// contains filtered or unexported fields
}

The cloud resources created by user.

func (*Network_CustomerManagedResources) Descriptor deprecated

func (*Network_CustomerManagedResources) Descriptor() ([]byte, []int)

Deprecated: Use Network_CustomerManagedResources.ProtoReflect.Descriptor instead.

func (*Network_CustomerManagedResources) GetCloudProvider

func (m *Network_CustomerManagedResources) GetCloudProvider() isNetwork_CustomerManagedResources_CloudProvider

func (*Network_CustomerManagedResources) GetGcp

func (*Network_CustomerManagedResources) ProtoMessage

func (*Network_CustomerManagedResources) ProtoMessage()

func (*Network_CustomerManagedResources) ProtoReflect

func (*Network_CustomerManagedResources) Reset

func (*Network_CustomerManagedResources) String

type Network_CustomerManagedResources_GCP

type Network_CustomerManagedResources_GCP struct {

	// The name of network that is created by user, and Redpanda cluster is deployed to.
	// See GCP API: https://cloud.google.com/compute/docs/reference/rest/v1/networks
	NetworkName string `protobuf:"bytes,1,opt,name=network_name,proto3" json:"network_name,omitempty"`
	// The GCP project ID where the network is created.
	NetworkProjectId string `protobuf:"bytes,2,opt,name=network_project_id,proto3" json:"network_project_id,omitempty"`
	// The GCP storage bucket storing the state of Redpanda cluster deployment.
	ManagementBucket *CustomerManagedGoogleCloudStorageBucket `protobuf:"bytes,3,opt,name=management_bucket,proto3" json:"management_bucket,omitempty"`
	// contains filtered or unexported fields
}

GCP resources if Redpanda cluster is deployed on GCP.

func (*Network_CustomerManagedResources_GCP) Descriptor deprecated

func (*Network_CustomerManagedResources_GCP) Descriptor() ([]byte, []int)

Deprecated: Use Network_CustomerManagedResources_GCP.ProtoReflect.Descriptor instead.

func (*Network_CustomerManagedResources_GCP) GetManagementBucket

func (*Network_CustomerManagedResources_GCP) GetNetworkName

func (x *Network_CustomerManagedResources_GCP) GetNetworkName() string

func (*Network_CustomerManagedResources_GCP) GetNetworkProjectId

func (x *Network_CustomerManagedResources_GCP) GetNetworkProjectId() string

func (*Network_CustomerManagedResources_GCP) ProtoMessage

func (*Network_CustomerManagedResources_GCP) ProtoMessage()

func (*Network_CustomerManagedResources_GCP) ProtoReflect

func (*Network_CustomerManagedResources_GCP) Reset

func (*Network_CustomerManagedResources_GCP) String

type Network_CustomerManagedResources_Gcp

type Network_CustomerManagedResources_Gcp struct {
	Gcp *Network_CustomerManagedResources_GCP `protobuf:"bytes,1,opt,name=gcp,proto3,oneof"`
}

type Network_State

type Network_State int32
const (
	Network_STATE_UNSPECIFIED Network_State = 0
	Network_STATE_CREATING    Network_State = 1
	Network_STATE_READY       Network_State = 2
	Network_STATE_DELETING    Network_State = 3
	Network_STATE_DELETED     Network_State = 4
	Network_STATE_FAILED      Network_State = 5
)

func (Network_State) Descriptor

func (Network_State) Enum

func (x Network_State) Enum() *Network_State

func (Network_State) EnumDescriptor deprecated

func (Network_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Network_State.Descriptor instead.

func (Network_State) Number

func (Network_State) String

func (x Network_State) String() string

func (Network_State) Type

type Operation

type Operation struct {

	// ID of the operation.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Metadata of the long-running operation.
	Metadata *anypb.Any      `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	State    Operation_State `protobuf:"varint,3,opt,name=state,proto3,enum=redpanda.api.controlplane.v1beta1.Operation_State" json:"state,omitempty"`
	// result only available when the Operation is done, it can be either and error or the result of the operation
	//
	// Types that are assignable to Result:
	//
	//	*Operation_Error
	//	*Operation_Response
	Result isOperation_Result `protobuf_oneof:"result"`
	// Timestamp when the operation has started.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// Timestamp when the operation has finished.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// contains filtered or unexported fields
}

Operation describes a long running operation

func (*Operation) Descriptor deprecated

func (*Operation) Descriptor() ([]byte, []int)

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetError

func (x *Operation) GetError() *status.Status

func (*Operation) GetFinishedAt

func (x *Operation) GetFinishedAt() *timestamppb.Timestamp

func (*Operation) GetId

func (x *Operation) GetId() string

func (*Operation) GetMetadata

func (x *Operation) GetMetadata() *anypb.Any

func (*Operation) GetResponse

func (x *Operation) GetResponse() *anypb.Any

func (*Operation) GetResult

func (m *Operation) GetResult() isOperation_Result

func (*Operation) GetStartedAt

func (x *Operation) GetStartedAt() *timestamppb.Timestamp

func (*Operation) GetState

func (x *Operation) GetState() Operation_State

func (*Operation) ProtoMessage

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect

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

func (*Operation) Reset

func (x *Operation) Reset()

func (*Operation) String

func (x *Operation) String() string

type OperationServiceClient

type OperationServiceClient interface {
	GetOperation(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*Operation, error)
}

OperationServiceClient is the client API for OperationService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type OperationServiceServer

type OperationServiceServer interface {
	GetOperation(context.Context, *GetOperationRequest) (*Operation, error)
}

OperationServiceServer is the server API for OperationService service. All implementations should embed UnimplementedOperationServiceServer for forward compatibility

type Operation_Error

type Operation_Error struct {
	Error *status.Status `protobuf:"bytes,4,opt,name=error,proto3,oneof"`
}

type Operation_Response

type Operation_Response struct {
	Response *anypb.Any `protobuf:"bytes,5,opt,name=response,proto3,oneof"`
}

type Operation_State

type Operation_State int32

describes if the operation has finished, or is still in progress. Only if done is true, either error or result become available.

const (
	Operation_STATE_UNSPECIFIED Operation_State = 0
	Operation_STATE_IN_PROGRESS Operation_State = 1
	Operation_STATE_COMPLETED   Operation_State = 2
	Operation_STATE_FAILED      Operation_State = 3
)

func (Operation_State) Descriptor

func (Operation_State) Enum

func (x Operation_State) Enum() *Operation_State

func (Operation_State) EnumDescriptor deprecated

func (Operation_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Operation_State.Descriptor instead.

func (Operation_State) Number

func (Operation_State) String

func (x Operation_State) String() string

func (Operation_State) Type

type Reason

type Reason int32
const (
	Reason_REASON_UNSPECIFIED Reason = 0
	// Cluster zones must be subset of Network zones.
	Reason_REASON_ZONE_NOT_SUPPORTED_BY_NETWORK Reason = 1
	// No Quota to create resource.
	Reason_REASON_INSUFFICIENT_QUOTA Reason = 2
	// Disabling mTLS is not supported.
	Reason_REASON_DISABLING_MTLS_NOT_SUPPORTED Reason = 3
	// The provided Redpanda Version is not supported.
	Reason_REASON_UNSUPPORTED_VERSION Reason = 4
	// Network name is already in use by another Network within the Organization.
	Reason_REASON_NETWORK_ALREADY_EXISTS Reason = 5
	// Region with given name not found.
	Reason_REASON_REGION_NOT_FOUND Reason = 6
	// No token provided. REASON_NO_TOKEN = 7;
	Reason_REASON_NO_TOKEN Reason = 7
	// Provided token has expired.
	Reason_REASON_TOKEN_EXPIRED Reason = 8
	// Provided token is invalid.
	Reason_REASON_TOKEN_INVALID Reason = 9
	// ClusterType of Cluster and Network do not match.
	Reason_REASON_CLUSTER_TYPE_MISMATCH Reason = 10
	// Only one Cluster per Network is allowed, placing additional clusters is
	// not yet supported. This restriction will be lifted in the future.
	Reason_REASON_ONLY_ONE_CLUSTER_PER_NETWORK_ALLOWED Reason = 11
	// Generic input validation error. Refer to BadRequest errordetail for details.
	Reason_REASON_INVALID_INPUT Reason = 12
	// Network is not in READY state, which is a precondition to create a Cluster.
	Reason_REASON_NETWORK_NOT_READY Reason = 13
	// Cluster and Network region do not match.
	Reason_REASON_CLUSTER_NETWORK_REGION_MISMATCH Reason = 14
	// ThroughputTier does not exist.
	Reason_REASON_THROUGHPUT_TIER_NOT_FOUND Reason = 15
	// Namespace contains resources.
	Reason_REASON_NAMESPACE_NOT_EMPTY Reason = 16
	// Cluster and Network have different cloud providers.
	Reason_REASON_CLUSTER_NETWORK_CLOUD_PROVIDER_MISMATCH Reason = 17
	// Throughput tier not available in requested region and/or requested cluster type.
	Reason_REASON_THROUGHPUT_TIER_NOT_AVAILABLE_IN_REGION Reason = 18
	// Cloud Provider lacks capacity for the requested machine type.
	Reason_REASON_CLOUD_PROVIDER_STOCKOUT Reason = 19
	// Cloud Provider does not support the machine type in the zone.
	Reason_REASON_CLOUD_PROVIDER_MACHINE_TYPE_UNSUPPORTED_IN_ZONE Reason = 20
	// Cloud Provider quota has been exceeded.
	Reason_REASON_CLOUD_PROVIDER_QUOTA_EXCEEDED Reason = 21
	// Network still contains clusters. Only empty networks can be deleted.
	Reason_REASON_NETWORK_CONTAINS_CLUSTERS Reason = 22
)

func (Reason) Descriptor

func (Reason) Descriptor() protoreflect.EnumDescriptor

func (Reason) Enum

func (x Reason) Enum() *Reason

func (Reason) EnumDescriptor deprecated

func (Reason) EnumDescriptor() ([]byte, []int)

Deprecated: Use Reason.Descriptor instead.

func (Reason) Number

func (x Reason) Number() protoreflect.EnumNumber

func (Reason) String

func (x Reason) String() string

func (Reason) Type

func (Reason) Type() protoreflect.EnumType

type UnimplementedClusterServiceServer

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) CreateCluster

func (UnimplementedClusterServiceServer) DeleteCluster

func (UnimplementedClusterServiceServer) DummyCreateMetadata

func (UnimplementedClusterServiceServer) DummyDeleteMetadata

func (UnimplementedClusterServiceServer) DummyUpdateMetadata

func (UnimplementedClusterServiceServer) GetCluster

func (UnimplementedClusterServiceServer) ListClusters

func (UnimplementedClusterServiceServer) UpdateCluster

type UnimplementedDummyServiceServer

type UnimplementedDummyServiceServer struct {
}

UnimplementedDummyServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDummyServiceServer) DummyMethod

type UnimplementedNamespaceServiceServer

type UnimplementedNamespaceServiceServer struct {
}

UnimplementedNamespaceServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedNamespaceServiceServer) CreateNamespace

func (UnimplementedNamespaceServiceServer) DeleteNamespace

func (UnimplementedNamespaceServiceServer) GetNamespace

func (UnimplementedNamespaceServiceServer) ListNamespaces

func (UnimplementedNamespaceServiceServer) UpdateNamespace

type UnimplementedNetworkServiceServer

type UnimplementedNetworkServiceServer struct {
}

UnimplementedNetworkServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedNetworkServiceServer) CreateNetwork

func (UnimplementedNetworkServiceServer) DeleteNetwork

func (UnimplementedNetworkServiceServer) DummyCreateMetadata

func (UnimplementedNetworkServiceServer) DummyDeleteMetadata

func (UnimplementedNetworkServiceServer) GetNetwork

func (UnimplementedNetworkServiceServer) ListNetworks

type UnimplementedOperationServiceServer

type UnimplementedOperationServiceServer struct {
}

UnimplementedOperationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedOperationServiceServer) GetOperation

type UnsafeClusterServiceServer

type UnsafeClusterServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeClusterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServiceServer will result in compilation errors.

type UnsafeDummyServiceServer

type UnsafeDummyServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDummyServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DummyServiceServer will result in compilation errors.

type UnsafeNamespaceServiceServer

type UnsafeNamespaceServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeNamespaceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NamespaceServiceServer will result in compilation errors.

type UnsafeNetworkServiceServer

type UnsafeNetworkServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeNetworkServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NetworkServiceServer will result in compilation errors.

type UnsafeOperationServiceServer

type UnsafeOperationServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeOperationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OperationServiceServer will result in compilation errors.

type UpdateClusterMetadata

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

UpdateClusterMetadata provides in-progress information about a UpdateCluster Operation.

func (*UpdateClusterMetadata) Descriptor deprecated

func (*UpdateClusterMetadata) Descriptor() ([]byte, []int)

Deprecated: Use UpdateClusterMetadata.ProtoReflect.Descriptor instead.

func (*UpdateClusterMetadata) ProtoMessage

func (*UpdateClusterMetadata) ProtoMessage()

func (*UpdateClusterMetadata) ProtoReflect

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

func (*UpdateClusterMetadata) Reset

func (x *UpdateClusterMetadata) Reset()

func (*UpdateClusterMetadata) String

func (x *UpdateClusterMetadata) String() string

type UpdateClusterRequest

type UpdateClusterRequest struct {
	Cluster    *Cluster               `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateClusterRequest is the request of UpdateCluster.

func (*UpdateClusterRequest) Descriptor deprecated

func (*UpdateClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterRequest) GetCluster

func (x *UpdateClusterRequest) GetCluster() *Cluster

func (*UpdateClusterRequest) GetUpdateMask

func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateClusterRequest) ProtoMessage

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) ProtoReflect

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

func (*UpdateClusterRequest) Reset

func (x *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) String

func (x *UpdateClusterRequest) String() string

type UpdateClusterResponse

type UpdateClusterResponse struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

UpdateClusterResponse is the resposne of UpdateCluster. It is provided by the Operation returned by UpdateCluster once the Operation is done.

func (*UpdateClusterResponse) Descriptor deprecated

func (*UpdateClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateClusterResponse.ProtoReflect.Descriptor instead.

func (*UpdateClusterResponse) GetCluster

func (x *UpdateClusterResponse) GetCluster() *Cluster

func (*UpdateClusterResponse) ProtoMessage

func (*UpdateClusterResponse) ProtoMessage()

func (*UpdateClusterResponse) ProtoReflect

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

func (*UpdateClusterResponse) Reset

func (x *UpdateClusterResponse) Reset()

func (*UpdateClusterResponse) String

func (x *UpdateClusterResponse) String() string

type UpdateNamespaceRequest

type UpdateNamespaceRequest struct {
	Namespace *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

UpdateNamespaceRequest is the request of UpdateNamespace

func (*UpdateNamespaceRequest) Descriptor deprecated

func (*UpdateNamespaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceRequest) GetNamespace

func (x *UpdateNamespaceRequest) GetNamespace() *Namespace

func (*UpdateNamespaceRequest) ProtoMessage

func (*UpdateNamespaceRequest) ProtoMessage()

func (*UpdateNamespaceRequest) ProtoReflect

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

func (*UpdateNamespaceRequest) Reset

func (x *UpdateNamespaceRequest) Reset()

func (*UpdateNamespaceRequest) String

func (x *UpdateNamespaceRequest) String() string

type UpdateNamespaceResponse

type UpdateNamespaceResponse struct {
	Namespace *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

UpdateNamespaceResponse is the response of UpdateNamespace.

func (*UpdateNamespaceResponse) Descriptor deprecated

func (*UpdateNamespaceResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceResponse) GetNamespace

func (x *UpdateNamespaceResponse) GetNamespace() *Namespace

func (*UpdateNamespaceResponse) ProtoMessage

func (*UpdateNamespaceResponse) ProtoMessage()

func (*UpdateNamespaceResponse) ProtoReflect

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

func (*UpdateNamespaceResponse) Reset

func (x *UpdateNamespaceResponse) Reset()

func (*UpdateNamespaceResponse) String

func (x *UpdateNamespaceResponse) String() string

type UpdateNetworkRequest

type UpdateNetworkRequest struct {
	Network    *Network               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateNetworkRequest is the request of UpdateNetwork

func (*UpdateNetworkRequest) Descriptor deprecated

func (*UpdateNetworkRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateNetworkRequest.ProtoReflect.Descriptor instead.

func (*UpdateNetworkRequest) GetNetwork

func (x *UpdateNetworkRequest) GetNetwork() *Network

func (*UpdateNetworkRequest) GetUpdateMask

func (x *UpdateNetworkRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateNetworkRequest) ProtoMessage

func (*UpdateNetworkRequest) ProtoMessage()

func (*UpdateNetworkRequest) ProtoReflect

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

func (*UpdateNetworkRequest) Reset

func (x *UpdateNetworkRequest) Reset()

func (*UpdateNetworkRequest) String

func (x *UpdateNetworkRequest) String() string

type UpdateNetworkResponse

type UpdateNetworkResponse struct {
	Network *Network `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	// contains filtered or unexported fields
}

UpdateNetworkResponse is the response of UpdateNetwork. It is provided by the Operation returned by UpdateNetwork once the Operation is done.

func (*UpdateNetworkResponse) Descriptor deprecated

func (*UpdateNetworkResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateNetworkResponse.ProtoReflect.Descriptor instead.

func (*UpdateNetworkResponse) GetNetwork

func (x *UpdateNetworkResponse) GetNetwork() *Network

func (*UpdateNetworkResponse) ProtoMessage

func (*UpdateNetworkResponse) ProtoMessage()

func (*UpdateNetworkResponse) ProtoReflect

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

func (*UpdateNetworkResponse) Reset

func (x *UpdateNetworkResponse) Reset()

func (*UpdateNetworkResponse) String

func (x *UpdateNetworkResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL