Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)
- func RegisterDummyServiceServer(s grpc.ServiceRegistrar, srv DummyServiceServer)
- func RegisterNamespaceServiceServer(s grpc.ServiceRegistrar, srv NamespaceServiceServer)
- func RegisterNetworkServiceServer(s grpc.ServiceRegistrar, srv NetworkServiceServer)
- func RegisterOperationServiceServer(s grpc.ServiceRegistrar, srv OperationServiceServer)
- type CloudProvider
- func (CloudProvider) Descriptor() protoreflect.EnumDescriptor
- func (x CloudProvider) Enum() *CloudProvider
- func (CloudProvider) EnumDescriptor() ([]byte, []int)deprecated
- func (x CloudProvider) Number() protoreflect.EnumNumber
- func (x CloudProvider) String() string
- func (CloudProvider) Type() protoreflect.EnumType
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster) GetCloudProvider() CloudProvider
- func (x *Cluster) GetCloudTags() map[string]string
- func (x *Cluster) GetConnectionType() Cluster_ConnectionType
- func (x *Cluster) GetCreatedAt() *timestamppb.Timestamp
- func (x *Cluster) GetCustomerManagedResources() *Cluster_CustomerManagedResources
- func (x *Cluster) GetDataplaneApi() *Cluster_DataplaneAPI
- func (x *Cluster) GetHttpProxy() *Cluster_HTTPProxy
- func (x *Cluster) GetId() string
- func (x *Cluster) GetKafkaApi() *Cluster_KafkaAPI
- func (x *Cluster) GetName() string
- func (x *Cluster) GetNamespaceId() string
- func (x *Cluster) GetNetworkId() string
- func (x *Cluster) GetPrivateLink() *Cluster_PrivateLinkSpec
- func (x *Cluster) GetPrometheus() *Cluster_Prometheus
- func (x *Cluster) GetRedpandaConsole() *Cluster_RedpandaConsole
- func (x *Cluster) GetRedpandaVersion() string
- func (x *Cluster) GetRegion() string
- func (x *Cluster) GetSchemaRegistry() *Cluster_SchemaRegistry
- func (x *Cluster) GetState() Cluster_State
- func (x *Cluster) GetStateDescription() *status.Status
- func (x *Cluster) GetThroughputTier() string
- func (x *Cluster) GetType() Cluster_Type
- func (x *Cluster) GetUpdatedAt() *timestamppb.Timestamp
- func (x *Cluster) GetZones() []string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (x *Cluster) String() string
- type ClusterServiceClient
- type ClusterServiceServer
- type Cluster_ConnectionType
- func (Cluster_ConnectionType) Descriptor() protoreflect.EnumDescriptor
- func (x Cluster_ConnectionType) Enum() *Cluster_ConnectionType
- func (Cluster_ConnectionType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Cluster_ConnectionType) Number() protoreflect.EnumNumber
- func (x Cluster_ConnectionType) String() string
- func (Cluster_ConnectionType) Type() protoreflect.EnumType
- type Cluster_CustomerManagedResources
- func (*Cluster_CustomerManagedResources) Descriptor() ([]byte, []int)deprecated
- func (m *Cluster_CustomerManagedResources) GetCloudProvider() isCluster_CustomerManagedResources_CloudProvider
- func (x *Cluster_CustomerManagedResources) GetGcp() *Cluster_CustomerManagedResources_GCP
- func (*Cluster_CustomerManagedResources) ProtoMessage()
- func (x *Cluster_CustomerManagedResources) ProtoReflect() protoreflect.Message
- func (x *Cluster_CustomerManagedResources) Reset()
- func (x *Cluster_CustomerManagedResources) String() string
- type Cluster_CustomerManagedResources_GCP
- func (*Cluster_CustomerManagedResources_GCP) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_CustomerManagedResources_GCP) GetAgentServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
- func (x *Cluster_CustomerManagedResources_GCP) GetConnectorServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
- func (x *Cluster_CustomerManagedResources_GCP) GetConsoleServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
- func (x *Cluster_CustomerManagedResources_GCP) GetGkeServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
- func (x *Cluster_CustomerManagedResources_GCP) GetRedpandaClusterServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
- func (x *Cluster_CustomerManagedResources_GCP) GetSubnet() *Cluster_CustomerManagedResources_GCP_Subnet
- func (x *Cluster_CustomerManagedResources_GCP) GetTieredStorageBucket() *CustomerManagedGoogleCloudStorageBucket
- func (*Cluster_CustomerManagedResources_GCP) ProtoMessage()
- func (x *Cluster_CustomerManagedResources_GCP) ProtoReflect() protoreflect.Message
- func (x *Cluster_CustomerManagedResources_GCP) Reset()
- func (x *Cluster_CustomerManagedResources_GCP) String() string
- type Cluster_CustomerManagedResources_GCP_ServiceAccount
- func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_CustomerManagedResources_GCP_ServiceAccount) GetEmail() string
- func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) ProtoMessage()
- func (x *Cluster_CustomerManagedResources_GCP_ServiceAccount) ProtoReflect() protoreflect.Message
- func (x *Cluster_CustomerManagedResources_GCP_ServiceAccount) Reset()
- func (x *Cluster_CustomerManagedResources_GCP_ServiceAccount) String() string
- type Cluster_CustomerManagedResources_GCP_Subnet
- func (*Cluster_CustomerManagedResources_GCP_Subnet) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_CustomerManagedResources_GCP_Subnet) GetK8SMasterIpv4Range() string
- func (x *Cluster_CustomerManagedResources_GCP_Subnet) GetName() string
- func (x *Cluster_CustomerManagedResources_GCP_Subnet) GetSecondaryIpv4RangePods() *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range
- func (x *Cluster_CustomerManagedResources_GCP_Subnet) GetSecondaryIpv4RangeServices() *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range
- func (*Cluster_CustomerManagedResources_GCP_Subnet) ProtoMessage()
- func (x *Cluster_CustomerManagedResources_GCP_Subnet) ProtoReflect() protoreflect.Message
- func (x *Cluster_CustomerManagedResources_GCP_Subnet) Reset()
- func (x *Cluster_CustomerManagedResources_GCP_Subnet) String() string
- type Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range
- func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) GetName() string
- func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) ProtoMessage()
- func (x *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) ProtoReflect() protoreflect.Message
- func (x *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) Reset()
- func (x *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) String() string
- type Cluster_CustomerManagedResources_Gcp
- type Cluster_DataplaneAPI
- func (*Cluster_DataplaneAPI) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_DataplaneAPI) GetUrl() string
- func (*Cluster_DataplaneAPI) ProtoMessage()
- func (x *Cluster_DataplaneAPI) ProtoReflect() protoreflect.Message
- func (x *Cluster_DataplaneAPI) Reset()
- func (x *Cluster_DataplaneAPI) String() string
- type Cluster_HTTPProxy
- func (*Cluster_HTTPProxy) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_HTTPProxy) GetMtls() *MTLSSpec
- func (x *Cluster_HTTPProxy) GetUrl() string
- func (*Cluster_HTTPProxy) ProtoMessage()
- func (x *Cluster_HTTPProxy) ProtoReflect() protoreflect.Message
- func (x *Cluster_HTTPProxy) Reset()
- func (x *Cluster_HTTPProxy) String() string
- type Cluster_KafkaAPI
- type Cluster_PrivateLinkSpec
- func (*Cluster_PrivateLinkSpec) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_PrivateLinkSpec) GetAws() *Cluster_PrivateLinkSpec_AWS
- func (m *Cluster_PrivateLinkSpec) GetCloudProvider() isCluster_PrivateLinkSpec_CloudProvider
- func (x *Cluster_PrivateLinkSpec) GetEnabled() bool
- func (x *Cluster_PrivateLinkSpec) GetGcp() *Cluster_PrivateLinkSpec_GCP
- func (x *Cluster_PrivateLinkSpec) GetStatus() *Cluster_PrivateLinkSpec_PrivateLinkStatus
- func (*Cluster_PrivateLinkSpec) ProtoMessage()
- func (x *Cluster_PrivateLinkSpec) ProtoReflect() protoreflect.Message
- func (x *Cluster_PrivateLinkSpec) Reset()
- func (x *Cluster_PrivateLinkSpec) String() string
- type Cluster_PrivateLinkSpec_AWS
- func (*Cluster_PrivateLinkSpec_AWS) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_PrivateLinkSpec_AWS) GetAllowedPrincipals() []string
- func (*Cluster_PrivateLinkSpec_AWS) ProtoMessage()
- func (x *Cluster_PrivateLinkSpec_AWS) ProtoReflect() protoreflect.Message
- func (x *Cluster_PrivateLinkSpec_AWS) Reset()
- func (x *Cluster_PrivateLinkSpec_AWS) String() string
- type Cluster_PrivateLinkSpec_Aws
- type Cluster_PrivateLinkSpec_GCP
- func (*Cluster_PrivateLinkSpec_GCP) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_PrivateLinkSpec_GCP) GetConsumerAcceptList() []string
- func (x *Cluster_PrivateLinkSpec_GCP) GetConsumerRejectList() []string
- func (*Cluster_PrivateLinkSpec_GCP) ProtoMessage()
- func (x *Cluster_PrivateLinkSpec_GCP) ProtoReflect() protoreflect.Message
- func (x *Cluster_PrivateLinkSpec_GCP) Reset()
- func (x *Cluster_PrivateLinkSpec_GCP) String() string
- type Cluster_PrivateLinkSpec_Gcp
- type Cluster_PrivateLinkSpec_PrivateLinkStatus
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus) GetAws() *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS
- func (m *Cluster_PrivateLinkSpec_PrivateLinkStatus) GetCloudProvider() isCluster_PrivateLinkSpec_PrivateLinkStatus_CloudProvider
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus) GetGcp() *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) ProtoMessage()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus) ProtoReflect() protoreflect.Message
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus) Reset()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus) String() string
- type Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetCreatedAt() *timestamppb.Timestamp
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetDeletedAt() *timestamppb.Timestamp
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetKafkaApiNodeBasePort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetKafkaApiSeedPort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetRedpandaProxyNodeBasePort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetRedpandaProxySeedPort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetSchemaRegistrySeedPort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceId() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceName() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceState() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetVpcEndpointConnections() []*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) ProtoMessage()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) ProtoReflect() protoreflect.Message
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) Reset()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) String() string
- type Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetConnectionId() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetCreatedAt() *timestamppb.Timestamp
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetDnsEntries() ...
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetId() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetLoadBalancerArns() []string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetOwner() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetState() string
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) ProtoMessage()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) ProtoReflect() protoreflect.Message
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) Reset()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) String() string
- type Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) GetDnsName() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) GetHostedZoneId() string
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) ProtoMessage()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) ProtoReflect() protoreflect.Message
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) Reset()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) String() string
- type Cluster_PrivateLinkSpec_PrivateLinkStatus_Aws
- type Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetCreatedAt() *timestamppb.Timestamp
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetDeletedAt() *timestamppb.Timestamp
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetEndpointConnections() []*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetKafkaApiNodeBasePort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetKafkaApiSeedPort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetRedpandaProxyNodeBasePort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetRedpandaProxySeedPort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetSchemaRegistrySeedPort() int32
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetServiceAttachment() string
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) ProtoMessage()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) ProtoReflect() protoreflect.Message
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) Reset()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) String() string
- type Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetConnectionId() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetConsumerNetwork() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetEndpoint() string
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetState() string
- func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) ProtoMessage()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) ProtoReflect() protoreflect.Message
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) Reset()
- func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) String() string
- type Cluster_PrivateLinkSpec_PrivateLinkStatus_Gcp
- type Cluster_Prometheus
- type Cluster_RedpandaConsole
- func (*Cluster_RedpandaConsole) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_RedpandaConsole) GetUrl() string
- func (*Cluster_RedpandaConsole) ProtoMessage()
- func (x *Cluster_RedpandaConsole) ProtoReflect() protoreflect.Message
- func (x *Cluster_RedpandaConsole) Reset()
- func (x *Cluster_RedpandaConsole) String() string
- type Cluster_SchemaRegistry
- func (*Cluster_SchemaRegistry) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_SchemaRegistry) GetMtls() *MTLSSpec
- func (x *Cluster_SchemaRegistry) GetUrl() string
- func (*Cluster_SchemaRegistry) ProtoMessage()
- func (x *Cluster_SchemaRegistry) ProtoReflect() protoreflect.Message
- func (x *Cluster_SchemaRegistry) Reset()
- func (x *Cluster_SchemaRegistry) String() string
- type Cluster_State
- func (Cluster_State) Descriptor() protoreflect.EnumDescriptor
- func (x Cluster_State) Enum() *Cluster_State
- func (Cluster_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Cluster_State) Number() protoreflect.EnumNumber
- func (x Cluster_State) String() string
- func (Cluster_State) Type() protoreflect.EnumType
- type Cluster_Type
- func (Cluster_Type) Descriptor() protoreflect.EnumDescriptor
- func (x Cluster_Type) Enum() *Cluster_Type
- func (Cluster_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x Cluster_Type) Number() protoreflect.EnumNumber
- func (x Cluster_Type) String() string
- func (Cluster_Type) Type() protoreflect.EnumType
- type CreateClusterMetadata
- func (*CreateClusterMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *CreateClusterMetadata) GetClusterId() string
- func (*CreateClusterMetadata) ProtoMessage()
- func (x *CreateClusterMetadata) ProtoReflect() protoreflect.Message
- func (x *CreateClusterMetadata) Reset()
- func (x *CreateClusterMetadata) String() string
- type CreateClusterRequest
- func (*CreateClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateClusterRequest) GetCluster() *Cluster
- func (*CreateClusterRequest) ProtoMessage()
- func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message
- func (x *CreateClusterRequest) Reset()
- func (x *CreateClusterRequest) String() string
- type CreateNamespaceRequest
- func (*CreateNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateNamespaceRequest) GetNamespace() *Namespace
- func (*CreateNamespaceRequest) ProtoMessage()
- func (x *CreateNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateNamespaceRequest) Reset()
- func (x *CreateNamespaceRequest) String() string
- type CreateNetworkMetadata
- func (*CreateNetworkMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *CreateNetworkMetadata) GetNetworkId() string
- func (*CreateNetworkMetadata) ProtoMessage()
- func (x *CreateNetworkMetadata) ProtoReflect() protoreflect.Message
- func (x *CreateNetworkMetadata) Reset()
- func (x *CreateNetworkMetadata) String() string
- type CreateNetworkRequest
- func (*CreateNetworkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateNetworkRequest) GetNetwork() *Network
- func (*CreateNetworkRequest) ProtoMessage()
- func (x *CreateNetworkRequest) ProtoReflect() protoreflect.Message
- func (x *CreateNetworkRequest) Reset()
- func (x *CreateNetworkRequest) String() string
- type CustomerManagedGoogleCloudStorageBucket
- func (*CustomerManagedGoogleCloudStorageBucket) Descriptor() ([]byte, []int)deprecated
- func (x *CustomerManagedGoogleCloudStorageBucket) GetName() string
- func (*CustomerManagedGoogleCloudStorageBucket) ProtoMessage()
- func (x *CustomerManagedGoogleCloudStorageBucket) ProtoReflect() protoreflect.Message
- func (x *CustomerManagedGoogleCloudStorageBucket) Reset()
- func (x *CustomerManagedGoogleCloudStorageBucket) String() string
- type DeleteClusterMetadata
- type DeleteClusterRequest
- func (*DeleteClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteClusterRequest) GetId() string
- func (*DeleteClusterRequest) ProtoMessage()
- func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteClusterRequest) Reset()
- func (x *DeleteClusterRequest) String() string
- type DeleteClusterResponse
- type DeleteNamespaceRequest
- func (*DeleteNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteNamespaceRequest) GetId() string
- func (*DeleteNamespaceRequest) ProtoMessage()
- func (x *DeleteNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteNamespaceRequest) Reset()
- func (x *DeleteNamespaceRequest) String() string
- type DeleteNamespaceResponse
- type DeleteNetworkMetadata
- type DeleteNetworkRequest
- func (*DeleteNetworkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteNetworkRequest) GetId() string
- func (*DeleteNetworkRequest) ProtoMessage()
- func (x *DeleteNetworkRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteNetworkRequest) Reset()
- func (x *DeleteNetworkRequest) String() string
- type DeleteNetworkResponse
- type DummyMethodResponse
- func (*DummyMethodResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DummyMethodResponse) GetBadRequest() *errdetails.BadRequest
- func (x *DummyMethodResponse) GetErrorInfo() *errdetails.ErrorInfo
- func (x *DummyMethodResponse) GetHelp() *errdetails.Help
- func (x *DummyMethodResponse) GetQuotaFailure() *errdetails.QuotaFailure
- func (*DummyMethodResponse) ProtoMessage()
- func (x *DummyMethodResponse) ProtoReflect() protoreflect.Message
- func (x *DummyMethodResponse) Reset()
- func (x *DummyMethodResponse) String() string
- type DummyServiceClient
- type DummyServiceServer
- type GetClusterRequest
- type GetNamespaceRequest
- func (*GetNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceRequest) GetId() string
- func (*GetNamespaceRequest) ProtoMessage()
- func (x *GetNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceRequest) Reset()
- func (x *GetNamespaceRequest) String() string
- type GetNetworkRequest
- type GetOperationRequest
- func (*GetOperationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetOperationRequest) GetId() string
- func (*GetOperationRequest) ProtoMessage()
- func (x *GetOperationRequest) ProtoReflect() protoreflect.Message
- func (x *GetOperationRequest) Reset()
- func (x *GetOperationRequest) String() string
- type ListClustersRequest
- func (*ListClustersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListClustersRequest) GetFilter() *ListClustersRequest_Filter
- func (x *ListClustersRequest) GetPageSize() int32
- func (x *ListClustersRequest) GetPageToken() string
- func (*ListClustersRequest) ProtoMessage()
- func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
- func (x *ListClustersRequest) Reset()
- func (x *ListClustersRequest) String() string
- type ListClustersRequest_Filter
- func (*ListClustersRequest_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *ListClustersRequest_Filter) GetCloudProvider() CloudProvider
- func (x *ListClustersRequest_Filter) GetName() string
- func (x *ListClustersRequest_Filter) GetNamespaceId() string
- func (x *ListClustersRequest_Filter) GetRegion() string
- func (*ListClustersRequest_Filter) ProtoMessage()
- func (x *ListClustersRequest_Filter) ProtoReflect() protoreflect.Message
- func (x *ListClustersRequest_Filter) Reset()
- func (x *ListClustersRequest_Filter) String() string
- type ListClustersResponse
- func (*ListClustersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClustersResponse) GetClusters() []*Cluster
- func (x *ListClustersResponse) GetNextPageToken() string
- func (*ListClustersResponse) ProtoMessage()
- func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
- func (x *ListClustersResponse) Reset()
- func (x *ListClustersResponse) String() string
- type ListNamespacesRequest
- func (*ListNamespacesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListNamespacesRequest) GetFilter() *ListNamespacesRequest_Filter
- func (x *ListNamespacesRequest) GetPageSize() int32
- func (x *ListNamespacesRequest) GetPageToken() string
- func (*ListNamespacesRequest) ProtoMessage()
- func (x *ListNamespacesRequest) ProtoReflect() protoreflect.Message
- func (x *ListNamespacesRequest) Reset()
- func (x *ListNamespacesRequest) String() string
- type ListNamespacesRequest_Filter
- func (*ListNamespacesRequest_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *ListNamespacesRequest_Filter) GetName() string
- func (*ListNamespacesRequest_Filter) ProtoMessage()
- func (x *ListNamespacesRequest_Filter) ProtoReflect() protoreflect.Message
- func (x *ListNamespacesRequest_Filter) Reset()
- func (x *ListNamespacesRequest_Filter) String() string
- type ListNamespacesResponse
- func (*ListNamespacesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListNamespacesResponse) GetNamespaces() []*Namespace
- func (x *ListNamespacesResponse) GetNextPageToken() string
- func (*ListNamespacesResponse) ProtoMessage()
- func (x *ListNamespacesResponse) ProtoReflect() protoreflect.Message
- func (x *ListNamespacesResponse) Reset()
- func (x *ListNamespacesResponse) String() string
- type ListNetworksRequest
- func (*ListNetworksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListNetworksRequest) GetFilter() *ListNetworksRequest_Filter
- func (x *ListNetworksRequest) GetPageSize() int32
- func (x *ListNetworksRequest) GetPageToken() string
- func (*ListNetworksRequest) ProtoMessage()
- func (x *ListNetworksRequest) ProtoReflect() protoreflect.Message
- func (x *ListNetworksRequest) Reset()
- func (x *ListNetworksRequest) String() string
- type ListNetworksRequest_Filter
- func (*ListNetworksRequest_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *ListNetworksRequest_Filter) GetCloudProvider() CloudProvider
- func (x *ListNetworksRequest_Filter) GetName() string
- func (x *ListNetworksRequest_Filter) GetNamespaceId() string
- func (x *ListNetworksRequest_Filter) GetRegion() string
- func (*ListNetworksRequest_Filter) ProtoMessage()
- func (x *ListNetworksRequest_Filter) ProtoReflect() protoreflect.Message
- func (x *ListNetworksRequest_Filter) Reset()
- func (x *ListNetworksRequest_Filter) String() string
- type ListNetworksResponse
- func (*ListNetworksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListNetworksResponse) GetNetworks() []*Network
- func (x *ListNetworksResponse) GetNextPageToken() string
- func (*ListNetworksResponse) ProtoMessage()
- func (x *ListNetworksResponse) ProtoReflect() protoreflect.Message
- func (x *ListNetworksResponse) Reset()
- func (x *ListNetworksResponse) String() string
- type MTLSSpec
- type Namespace
- func (*Namespace) Descriptor() ([]byte, []int)deprecated
- func (x *Namespace) GetCreatedAt() *timestamppb.Timestamp
- func (x *Namespace) GetId() string
- func (x *Namespace) GetName() string
- func (x *Namespace) GetUpdatedAt() *timestamppb.Timestamp
- func (*Namespace) ProtoMessage()
- func (x *Namespace) ProtoReflect() protoreflect.Message
- func (x *Namespace) Reset()
- func (x *Namespace) String() string
- type NamespaceServiceClient
- type NamespaceServiceServer
- type Network
- func (*Network) Descriptor() ([]byte, []int)deprecated
- func (x *Network) GetCidrBlock() string
- func (x *Network) GetCloudProvider() CloudProvider
- func (x *Network) GetClusterType() Cluster_Type
- func (x *Network) GetCreatedAt() *timestamppb.Timestamp
- func (x *Network) GetCustomerManagedResources() *Network_CustomerManagedResources
- func (x *Network) GetId() string
- func (x *Network) GetName() string
- func (x *Network) GetNamespaceId() string
- func (x *Network) GetRegion() string
- func (x *Network) GetState() Network_State
- func (x *Network) GetUpdatedAt() *timestamppb.Timestamp
- func (*Network) ProtoMessage()
- func (x *Network) ProtoReflect() protoreflect.Message
- func (x *Network) Reset()
- func (x *Network) String() string
- type NetworkServiceClient
- type NetworkServiceServer
- type Network_CustomerManagedResources
- func (*Network_CustomerManagedResources) Descriptor() ([]byte, []int)deprecated
- func (m *Network_CustomerManagedResources) GetCloudProvider() isNetwork_CustomerManagedResources_CloudProvider
- func (x *Network_CustomerManagedResources) GetGcp() *Network_CustomerManagedResources_GCP
- func (*Network_CustomerManagedResources) ProtoMessage()
- func (x *Network_CustomerManagedResources) ProtoReflect() protoreflect.Message
- func (x *Network_CustomerManagedResources) Reset()
- func (x *Network_CustomerManagedResources) String() string
- type Network_CustomerManagedResources_GCP
- func (*Network_CustomerManagedResources_GCP) Descriptor() ([]byte, []int)deprecated
- func (x *Network_CustomerManagedResources_GCP) GetManagementBucket() *CustomerManagedGoogleCloudStorageBucket
- func (x *Network_CustomerManagedResources_GCP) GetNetworkName() string
- func (x *Network_CustomerManagedResources_GCP) GetNetworkProjectId() string
- func (*Network_CustomerManagedResources_GCP) ProtoMessage()
- func (x *Network_CustomerManagedResources_GCP) ProtoReflect() protoreflect.Message
- func (x *Network_CustomerManagedResources_GCP) Reset()
- func (x *Network_CustomerManagedResources_GCP) String() string
- type Network_CustomerManagedResources_Gcp
- type Network_State
- func (Network_State) Descriptor() protoreflect.EnumDescriptor
- func (x Network_State) Enum() *Network_State
- func (Network_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Network_State) Number() protoreflect.EnumNumber
- func (x Network_State) String() string
- func (Network_State) Type() protoreflect.EnumType
- type Operation
- func (*Operation) Descriptor() ([]byte, []int)deprecated
- func (x *Operation) GetError() *status.Status
- func (x *Operation) GetFinishedAt() *timestamppb.Timestamp
- func (x *Operation) GetId() string
- func (x *Operation) GetMetadata() *anypb.Any
- func (x *Operation) GetResponse() *anypb.Any
- func (m *Operation) GetResult() isOperation_Result
- func (x *Operation) GetStartedAt() *timestamppb.Timestamp
- func (x *Operation) GetState() Operation_State
- func (*Operation) ProtoMessage()
- func (x *Operation) ProtoReflect() protoreflect.Message
- func (x *Operation) Reset()
- func (x *Operation) String() string
- type OperationServiceClient
- type OperationServiceServer
- type Operation_Error
- type Operation_Response
- type Operation_State
- func (Operation_State) Descriptor() protoreflect.EnumDescriptor
- func (x Operation_State) Enum() *Operation_State
- func (Operation_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Operation_State) Number() protoreflect.EnumNumber
- func (x Operation_State) String() string
- func (Operation_State) Type() protoreflect.EnumType
- type Reason
- type UnimplementedClusterServiceServer
- func (UnimplementedClusterServiceServer) CreateCluster(context.Context, *CreateClusterRequest) (*Operation, error)
- func (UnimplementedClusterServiceServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*Operation, error)
- func (UnimplementedClusterServiceServer) DummyCreateMetadata(context.Context, *CreateClusterRequest) (*CreateClusterMetadata, error)
- func (UnimplementedClusterServiceServer) DummyDeleteMetadata(context.Context, *DeleteClusterRequest) (*DeleteClusterMetadata, error)
- func (UnimplementedClusterServiceServer) DummyUpdateMetadata(context.Context, *UpdateClusterRequest) (*UpdateClusterMetadata, error)
- func (UnimplementedClusterServiceServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
- func (UnimplementedClusterServiceServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
- func (UnimplementedClusterServiceServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*Operation, error)
- type UnimplementedDummyServiceServer
- type UnimplementedNamespaceServiceServer
- func (UnimplementedNamespaceServiceServer) CreateNamespace(context.Context, *CreateNamespaceRequest) (*Namespace, error)
- func (UnimplementedNamespaceServiceServer) DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
- func (UnimplementedNamespaceServiceServer) GetNamespace(context.Context, *GetNamespaceRequest) (*Namespace, error)
- func (UnimplementedNamespaceServiceServer) ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)
- func (UnimplementedNamespaceServiceServer) UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*Namespace, error)
- type UnimplementedNetworkServiceServer
- func (UnimplementedNetworkServiceServer) CreateNetwork(context.Context, *CreateNetworkRequest) (*Operation, error)
- func (UnimplementedNetworkServiceServer) DeleteNetwork(context.Context, *DeleteNetworkRequest) (*Operation, error)
- func (UnimplementedNetworkServiceServer) DummyCreateMetadata(context.Context, *CreateNetworkRequest) (*CreateNetworkMetadata, error)
- func (UnimplementedNetworkServiceServer) DummyDeleteMetadata(context.Context, *DeleteNetworkRequest) (*DeleteNetworkMetadata, error)
- func (UnimplementedNetworkServiceServer) GetNetwork(context.Context, *GetNetworkRequest) (*Network, error)
- func (UnimplementedNetworkServiceServer) ListNetworks(context.Context, *ListNetworksRequest) (*ListNetworksResponse, error)
- type UnimplementedOperationServiceServer
- type UnsafeClusterServiceServer
- type UnsafeDummyServiceServer
- type UnsafeNamespaceServiceServer
- type UnsafeNetworkServiceServer
- type UnsafeOperationServiceServer
- type UpdateClusterMetadata
- type UpdateClusterRequest
- func (*UpdateClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateClusterRequest) GetCluster() *Cluster
- func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateClusterRequest) ProtoMessage()
- func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateClusterRequest) Reset()
- func (x *UpdateClusterRequest) String() string
- type UpdateClusterResponse
- func (*UpdateClusterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateClusterResponse) GetCluster() *Cluster
- func (*UpdateClusterResponse) ProtoMessage()
- func (x *UpdateClusterResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateClusterResponse) Reset()
- func (x *UpdateClusterResponse) String() string
- type UpdateNamespaceRequest
- func (*UpdateNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNamespaceRequest) GetNamespace() *Namespace
- func (*UpdateNamespaceRequest) ProtoMessage()
- func (x *UpdateNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateNamespaceRequest) Reset()
- func (x *UpdateNamespaceRequest) String() string
- type UpdateNamespaceResponse
- func (*UpdateNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNamespaceResponse) GetNamespace() *Namespace
- func (*UpdateNamespaceResponse) ProtoMessage()
- func (x *UpdateNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateNamespaceResponse) Reset()
- func (x *UpdateNamespaceResponse) String() string
- type UpdateNetworkRequest
- func (*UpdateNetworkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNetworkRequest) GetNetwork() *Network
- func (x *UpdateNetworkRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateNetworkRequest) ProtoMessage()
- func (x *UpdateNetworkRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateNetworkRequest) Reset()
- func (x *UpdateNetworkRequest) String() string
- type UpdateNetworkResponse
- func (*UpdateNetworkResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNetworkResponse) GetNetwork() *Network
- func (*UpdateNetworkResponse) ProtoMessage()
- func (x *UpdateNetworkResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateNetworkResponse) Reset()
- func (x *UpdateNetworkResponse) String() string
Constants ¶
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" )
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" )
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" )
const (
DummyService_DummyMethod_FullMethodName = "/redpanda.api.controlplane.v1beta1.DummyService/DummyMethod"
)
const (
OperationService_GetOperation_FullMethodName = "/redpanda.api.controlplane.v1beta1.OperationService/GetOperation"
)
Variables ¶
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.
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.
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.
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.
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.
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.
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.
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)
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)
var File_redpanda_api_controlplane_v1beta1_cluster_proto protoreflect.FileDescriptor
var File_redpanda_api_controlplane_v1beta1_common_proto protoreflect.FileDescriptor
var File_redpanda_api_controlplane_v1beta1_dummy_proto protoreflect.FileDescriptor
var File_redpanda_api_controlplane_v1beta1_error_proto protoreflect.FileDescriptor
var File_redpanda_api_controlplane_v1beta1_namespace_proto protoreflect.FileDescriptor
var File_redpanda_api_controlplane_v1beta1_network_proto protoreflect.FileDescriptor
var File_redpanda_api_controlplane_v1beta1_operation_proto protoreflect.FileDescriptor
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)
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)
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) Descriptor() protoreflect.EnumDescriptor
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 (x CloudProvider) Number() protoreflect.EnumNumber
func (CloudProvider) String ¶
func (x CloudProvider) String() string
func (CloudProvider) Type ¶
func (CloudProvider) Type() protoreflect.EnumType
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) GetCloudProvider ¶
func (x *Cluster) GetCloudProvider() CloudProvider
func (*Cluster) GetCloudTags ¶
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) GetKafkaApi ¶
func (x *Cluster) GetKafkaApi() *Cluster_KafkaAPI
func (*Cluster) GetNamespaceId ¶
func (*Cluster) GetNetworkId ¶
func (*Cluster) GetPrivateLink ¶
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 (*Cluster) GetSchemaRegistry ¶
func (x *Cluster) GetSchemaRegistry() *Cluster_SchemaRegistry
func (*Cluster) GetState ¶
func (x *Cluster) GetState() Cluster_State
func (*Cluster) GetStateDescription ¶
func (*Cluster) GetThroughputTier ¶
func (*Cluster) GetType ¶
func (x *Cluster) GetType() Cluster_Type
func (*Cluster) GetUpdatedAt ¶
func (x *Cluster) GetUpdatedAt() *timestamppb.Timestamp
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
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.
func NewClusterServiceClient ¶
func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient
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) Descriptor() protoreflect.EnumDescriptor
func (Cluster_ConnectionType) Enum ¶
func (x Cluster_ConnectionType) Enum() *Cluster_ConnectionType
func (Cluster_ConnectionType) EnumDescriptor
deprecated
func (Cluster_ConnectionType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Cluster_ConnectionType.Descriptor instead.
func (Cluster_ConnectionType) Number ¶
func (x Cluster_ConnectionType) Number() protoreflect.EnumNumber
func (Cluster_ConnectionType) String ¶
func (x Cluster_ConnectionType) String() string
func (Cluster_ConnectionType) Type ¶
func (Cluster_ConnectionType) Type() protoreflect.EnumType
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 (x *Cluster_CustomerManagedResources) GetGcp() *Cluster_CustomerManagedResources_GCP
func (*Cluster_CustomerManagedResources) ProtoMessage ¶
func (*Cluster_CustomerManagedResources) ProtoMessage()
func (*Cluster_CustomerManagedResources) ProtoReflect ¶
func (x *Cluster_CustomerManagedResources) ProtoReflect() protoreflect.Message
func (*Cluster_CustomerManagedResources) Reset ¶
func (x *Cluster_CustomerManagedResources) Reset()
func (*Cluster_CustomerManagedResources) String ¶
func (x *Cluster_CustomerManagedResources) String() 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 (x *Cluster_CustomerManagedResources_GCP) GetAgentServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
func (*Cluster_CustomerManagedResources_GCP) GetConnectorServiceAccount ¶
func (x *Cluster_CustomerManagedResources_GCP) GetConnectorServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
func (*Cluster_CustomerManagedResources_GCP) GetConsoleServiceAccount ¶
func (x *Cluster_CustomerManagedResources_GCP) GetConsoleServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
func (*Cluster_CustomerManagedResources_GCP) GetGkeServiceAccount ¶
func (x *Cluster_CustomerManagedResources_GCP) GetGkeServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
func (*Cluster_CustomerManagedResources_GCP) GetRedpandaClusterServiceAccount ¶
func (x *Cluster_CustomerManagedResources_GCP) GetRedpandaClusterServiceAccount() *Cluster_CustomerManagedResources_GCP_ServiceAccount
func (*Cluster_CustomerManagedResources_GCP) GetSubnet ¶
func (x *Cluster_CustomerManagedResources_GCP) GetSubnet() *Cluster_CustomerManagedResources_GCP_Subnet
func (*Cluster_CustomerManagedResources_GCP) GetTieredStorageBucket ¶
func (x *Cluster_CustomerManagedResources_GCP) GetTieredStorageBucket() *CustomerManagedGoogleCloudStorageBucket
func (*Cluster_CustomerManagedResources_GCP) ProtoMessage ¶
func (*Cluster_CustomerManagedResources_GCP) ProtoMessage()
func (*Cluster_CustomerManagedResources_GCP) ProtoReflect ¶
func (x *Cluster_CustomerManagedResources_GCP) ProtoReflect() protoreflect.Message
func (*Cluster_CustomerManagedResources_GCP) Reset ¶
func (x *Cluster_CustomerManagedResources_GCP) Reset()
func (*Cluster_CustomerManagedResources_GCP) String ¶
func (x *Cluster_CustomerManagedResources_GCP) String() 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
func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_CustomerManagedResources_GCP_ServiceAccount.ProtoReflect.Descriptor instead.
func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) GetEmail ¶
func (x *Cluster_CustomerManagedResources_GCP_ServiceAccount) GetEmail() string
func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) ProtoMessage ¶
func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) ProtoMessage()
func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) ProtoReflect ¶
func (x *Cluster_CustomerManagedResources_GCP_ServiceAccount) ProtoReflect() protoreflect.Message
func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) Reset ¶
func (x *Cluster_CustomerManagedResources_GCP_ServiceAccount) Reset()
func (*Cluster_CustomerManagedResources_GCP_ServiceAccount) String ¶
func (x *Cluster_CustomerManagedResources_GCP_ServiceAccount) String() 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
func (*Cluster_CustomerManagedResources_GCP_Subnet) Descriptor() ([]byte, []int)
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 (x *Cluster_CustomerManagedResources_GCP_Subnet) GetName() string
func (*Cluster_CustomerManagedResources_GCP_Subnet) GetSecondaryIpv4RangePods ¶
func (x *Cluster_CustomerManagedResources_GCP_Subnet) GetSecondaryIpv4RangePods() *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range
func (*Cluster_CustomerManagedResources_GCP_Subnet) GetSecondaryIpv4RangeServices ¶
func (x *Cluster_CustomerManagedResources_GCP_Subnet) GetSecondaryIpv4RangeServices() *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range
func (*Cluster_CustomerManagedResources_GCP_Subnet) ProtoMessage ¶
func (*Cluster_CustomerManagedResources_GCP_Subnet) ProtoMessage()
func (*Cluster_CustomerManagedResources_GCP_Subnet) ProtoReflect ¶
func (x *Cluster_CustomerManagedResources_GCP_Subnet) ProtoReflect() protoreflect.Message
func (*Cluster_CustomerManagedResources_GCP_Subnet) Reset ¶
func (x *Cluster_CustomerManagedResources_GCP_Subnet) Reset()
func (*Cluster_CustomerManagedResources_GCP_Subnet) String ¶
func (x *Cluster_CustomerManagedResources_GCP_Subnet) String() 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
func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range.ProtoReflect.Descriptor instead.
func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) GetName ¶
func (x *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) GetName() string
func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) ProtoMessage ¶
func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) ProtoMessage()
func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) ProtoReflect ¶
func (x *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) ProtoReflect() protoreflect.Message
func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) Reset ¶
func (x *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) Reset()
func (*Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) String ¶
func (x *Cluster_CustomerManagedResources_GCP_Subnet_SecondaryIPv4Range) String() 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 (x *Cluster_PrivateLinkSpec) GetAws() *Cluster_PrivateLinkSpec_AWS
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 (x *Cluster_PrivateLinkSpec) GetGcp() *Cluster_PrivateLinkSpec_GCP
func (*Cluster_PrivateLinkSpec) GetStatus ¶
func (x *Cluster_PrivateLinkSpec) GetStatus() *Cluster_PrivateLinkSpec_PrivateLinkStatus
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 (x *Cluster_PrivateLinkSpec_AWS) ProtoReflect() protoreflect.Message
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 (x *Cluster_PrivateLinkSpec_GCP) ProtoReflect() protoreflect.Message
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) GetCloudProvider ¶
func (m *Cluster_PrivateLinkSpec_PrivateLinkStatus) GetCloudProvider() isCluster_PrivateLinkSpec_PrivateLinkStatus_CloudProvider
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) ProtoMessage ¶
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) ProtoMessage()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) ProtoReflect ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus) ProtoReflect() protoreflect.Message
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) Reset ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus) Reset()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus) String ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus) String() 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
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS.ProtoReflect.Descriptor instead.
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetCreatedAt ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetCreatedAt() *timestamppb.Timestamp
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetDeletedAt ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetDeletedAt() *timestamppb.Timestamp
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 (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceId() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceName ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceName() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceState ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetServiceState() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetVpcEndpointConnections ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) GetVpcEndpointConnections() []*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) ProtoMessage ¶
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) ProtoMessage()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) ProtoReflect ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) ProtoReflect() protoreflect.Message
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) Reset ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) Reset()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) String ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS) String() 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
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection.ProtoReflect.Descriptor instead.
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetConnectionId ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetConnectionId() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetCreatedAt ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetCreatedAt() *timestamppb.Timestamp
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetDnsEntries ¶
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetId ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetId() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetLoadBalancerArns ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetLoadBalancerArns() []string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetOwner ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetOwner() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetState ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) GetState() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) ProtoMessage ¶
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) ProtoMessage()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) ProtoReflect ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) ProtoReflect() protoreflect.Message
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) Reset ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) Reset()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) String ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection) String() 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
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry.ProtoReflect.Descriptor instead.
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) GetDnsName ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) GetDnsName() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) GetHostedZoneId ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) GetHostedZoneId() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) ProtoMessage ¶
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) ProtoMessage()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) ProtoReflect ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_AWS_VPCEndpointConnection_DNSEntry) ProtoReflect() protoreflect.Message
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
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP.ProtoReflect.Descriptor instead.
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetCreatedAt ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetCreatedAt() *timestamppb.Timestamp
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetDeletedAt ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetDeletedAt() *timestamppb.Timestamp
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetEndpointConnections ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) GetEndpointConnections() []*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection
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) ProtoMessage()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) ProtoReflect ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) ProtoReflect() protoreflect.Message
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) Reset ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) Reset()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) String ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP) String() 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
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection.ProtoReflect.Descriptor instead.
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetConnectionId ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetConnectionId() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetConsumerNetwork ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetConsumerNetwork() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetEndpoint ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetEndpoint() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetState ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) GetState() string
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) ProtoMessage ¶
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) ProtoMessage()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) ProtoReflect ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) ProtoReflect() protoreflect.Message
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) Reset ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) Reset()
func (*Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) String ¶
func (x *Cluster_PrivateLinkSpec_PrivateLinkStatus_GCP_EndpointConnection) String() 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) Descriptor() protoreflect.EnumDescriptor
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 (x Cluster_State) Number() protoreflect.EnumNumber
func (Cluster_State) String ¶
func (x Cluster_State) String() string
func (Cluster_State) Type ¶
func (Cluster_State) Type() protoreflect.EnumType
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) Descriptor() protoreflect.EnumDescriptor
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 (x Cluster_Type) Number() protoreflect.EnumNumber
func (Cluster_Type) String ¶
func (x Cluster_Type) String() string
func (Cluster_Type) Type ¶
func (Cluster_Type) Type() protoreflect.EnumType
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 (x *CustomerManagedGoogleCloudStorageBucket) GetName() string
func (*CustomerManagedGoogleCloudStorageBucket) ProtoMessage ¶
func (*CustomerManagedGoogleCloudStorageBucket) ProtoMessage()
func (*CustomerManagedGoogleCloudStorageBucket) ProtoReflect ¶
func (x *CustomerManagedGoogleCloudStorageBucket) ProtoReflect() protoreflect.Message
func (*CustomerManagedGoogleCloudStorageBucket) Reset ¶
func (x *CustomerManagedGoogleCloudStorageBucket) Reset()
func (*CustomerManagedGoogleCloudStorageBucket) String ¶
func (x *CustomerManagedGoogleCloudStorageBucket) String() 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.
func NewDummyServiceClient ¶
func NewDummyServiceClient(cc grpc.ClientConnInterface) DummyServiceClient
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 (x *ListClustersRequest) GetFilter() *ListClustersRequest_Filter
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 (x *ListClustersRequest_Filter) ProtoReflect() protoreflect.Message
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 (x *ListNamespacesRequest) GetFilter() *ListNamespacesRequest_Filter
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 (x *ListNamespacesRequest_Filter) ProtoReflect() protoreflect.Message
func (*ListNamespacesRequest_Filter) Reset ¶
func (x *ListNamespacesRequest_Filter) Reset()
func (*ListNamespacesRequest_Filter) String ¶
func (x *ListNamespacesRequest_Filter) String() 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 (x *ListNetworksRequest) GetFilter() *ListNetworksRequest_Filter
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 (x *ListNetworksRequest_Filter) ProtoReflect() protoreflect.Message
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) GetCaCertificatesPem ¶
func (*MTLSSpec) GetEnabled ¶
func (*MTLSSpec) ProtoMessage ¶
func (*MTLSSpec) ProtoMessage()
func (*MTLSSpec) ProtoReflect ¶
func (x *MTLSSpec) ProtoReflect() protoreflect.Message
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) GetCreatedAt ¶
func (x *Namespace) GetCreatedAt() *timestamppb.Timestamp
func (*Namespace) GetUpdatedAt ¶
func (x *Namespace) GetUpdatedAt() *timestamppb.Timestamp
func (*Namespace) ProtoMessage ¶
func (*Namespace) ProtoMessage()
func (*Namespace) ProtoReflect ¶
func (x *Namespace) ProtoReflect() protoreflect.Message
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.
func NewNamespaceServiceClient ¶
func NewNamespaceServiceClient(cc grpc.ClientConnInterface) NamespaceServiceClient
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) GetCidrBlock ¶
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) GetNamespaceId ¶
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
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.
func NewNetworkServiceClient ¶
func NewNetworkServiceClient(cc grpc.ClientConnInterface) NetworkServiceClient
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 (x *Network_CustomerManagedResources) GetGcp() *Network_CustomerManagedResources_GCP
func (*Network_CustomerManagedResources) ProtoMessage ¶
func (*Network_CustomerManagedResources) ProtoMessage()
func (*Network_CustomerManagedResources) ProtoReflect ¶
func (x *Network_CustomerManagedResources) ProtoReflect() protoreflect.Message
func (*Network_CustomerManagedResources) Reset ¶
func (x *Network_CustomerManagedResources) Reset()
func (*Network_CustomerManagedResources) String ¶
func (x *Network_CustomerManagedResources) String() 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 (x *Network_CustomerManagedResources_GCP) GetManagementBucket() *CustomerManagedGoogleCloudStorageBucket
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 (x *Network_CustomerManagedResources_GCP) ProtoReflect() protoreflect.Message
func (*Network_CustomerManagedResources_GCP) Reset ¶
func (x *Network_CustomerManagedResources_GCP) Reset()
func (*Network_CustomerManagedResources_GCP) String ¶
func (x *Network_CustomerManagedResources_GCP) String() 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) Descriptor() protoreflect.EnumDescriptor
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 (x Network_State) Number() protoreflect.EnumNumber
func (Network_State) String ¶
func (x Network_State) String() string
func (Network_State) Type ¶
func (Network_State) Type() protoreflect.EnumType
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) GetFinishedAt ¶
func (x *Operation) GetFinishedAt() *timestamppb.Timestamp
func (*Operation) GetMetadata ¶
func (*Operation) GetResponse ¶
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
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.
func NewOperationServiceClient ¶
func NewOperationServiceClient(cc grpc.ClientConnInterface) OperationServiceClient
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_Response ¶
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) Descriptor() protoreflect.EnumDescriptor
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 (x Operation_State) Number() protoreflect.EnumNumber
func (Operation_State) String ¶
func (x Operation_State) String() string
func (Operation_State) Type ¶
func (Operation_State) Type() protoreflect.EnumType
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) EnumDescriptor
deprecated
func (Reason) Number ¶
func (x Reason) Number() protoreflect.EnumNumber
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) CreateCluster(context.Context, *CreateClusterRequest) (*Operation, error)
func (UnimplementedClusterServiceServer) DeleteCluster ¶
func (UnimplementedClusterServiceServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*Operation, error)
func (UnimplementedClusterServiceServer) DummyCreateMetadata ¶
func (UnimplementedClusterServiceServer) DummyCreateMetadata(context.Context, *CreateClusterRequest) (*CreateClusterMetadata, error)
func (UnimplementedClusterServiceServer) DummyDeleteMetadata ¶
func (UnimplementedClusterServiceServer) DummyDeleteMetadata(context.Context, *DeleteClusterRequest) (*DeleteClusterMetadata, error)
func (UnimplementedClusterServiceServer) DummyUpdateMetadata ¶
func (UnimplementedClusterServiceServer) DummyUpdateMetadata(context.Context, *UpdateClusterRequest) (*UpdateClusterMetadata, error)
func (UnimplementedClusterServiceServer) GetCluster ¶
func (UnimplementedClusterServiceServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
func (UnimplementedClusterServiceServer) ListClusters ¶
func (UnimplementedClusterServiceServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
func (UnimplementedClusterServiceServer) UpdateCluster ¶
func (UnimplementedClusterServiceServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*Operation, error)
type UnimplementedDummyServiceServer ¶
type UnimplementedDummyServiceServer struct { }
UnimplementedDummyServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedDummyServiceServer) DummyMethod ¶
func (UnimplementedDummyServiceServer) DummyMethod(context.Context, *emptypb.Empty) (*DummyMethodResponse, error)
type UnimplementedNamespaceServiceServer ¶
type UnimplementedNamespaceServiceServer struct { }
UnimplementedNamespaceServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedNamespaceServiceServer) CreateNamespace ¶
func (UnimplementedNamespaceServiceServer) CreateNamespace(context.Context, *CreateNamespaceRequest) (*Namespace, error)
func (UnimplementedNamespaceServiceServer) DeleteNamespace ¶
func (UnimplementedNamespaceServiceServer) DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
func (UnimplementedNamespaceServiceServer) GetNamespace ¶
func (UnimplementedNamespaceServiceServer) GetNamespace(context.Context, *GetNamespaceRequest) (*Namespace, error)
func (UnimplementedNamespaceServiceServer) ListNamespaces ¶
func (UnimplementedNamespaceServiceServer) ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)
func (UnimplementedNamespaceServiceServer) UpdateNamespace ¶
func (UnimplementedNamespaceServiceServer) UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*Namespace, error)
type UnimplementedNetworkServiceServer ¶
type UnimplementedNetworkServiceServer struct { }
UnimplementedNetworkServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedNetworkServiceServer) CreateNetwork ¶
func (UnimplementedNetworkServiceServer) CreateNetwork(context.Context, *CreateNetworkRequest) (*Operation, error)
func (UnimplementedNetworkServiceServer) DeleteNetwork ¶
func (UnimplementedNetworkServiceServer) DeleteNetwork(context.Context, *DeleteNetworkRequest) (*Operation, error)
func (UnimplementedNetworkServiceServer) DummyCreateMetadata ¶
func (UnimplementedNetworkServiceServer) DummyCreateMetadata(context.Context, *CreateNetworkRequest) (*CreateNetworkMetadata, error)
func (UnimplementedNetworkServiceServer) DummyDeleteMetadata ¶
func (UnimplementedNetworkServiceServer) DummyDeleteMetadata(context.Context, *DeleteNetworkRequest) (*DeleteNetworkMetadata, error)
func (UnimplementedNetworkServiceServer) GetNetwork ¶
func (UnimplementedNetworkServiceServer) GetNetwork(context.Context, *GetNetworkRequest) (*Network, error)
func (UnimplementedNetworkServiceServer) ListNetworks ¶
func (UnimplementedNetworkServiceServer) ListNetworks(context.Context, *ListNetworksRequest) (*ListNetworksResponse, error)
type UnimplementedOperationServiceServer ¶
type UnimplementedOperationServiceServer struct { }
UnimplementedOperationServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedOperationServiceServer) GetOperation ¶
func (UnimplementedOperationServiceServer) GetOperation(context.Context, *GetOperationRequest) (*Operation, error)
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