kafka_clusters

package
v3.12.1 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_strmprivacy_api_kafka_clusters_v1_kafka_clusters_v1_proto protoreflect.FileDescriptor
View Source 
var KafkaClustersService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.kafka_clusters.v1.KafkaClustersService",
	HandlerType: (*KafkaClustersServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListKafkaClusters",
			Handler:    _KafkaClustersService_ListKafkaClusters_Handler,
		},
		{
			MethodName: "GetKafkaCluster",
			Handler:    _KafkaClustersService_GetKafkaCluster_Handler,
		},
		{
			MethodName: "DeleteKafkaCluster",
			Handler:    _KafkaClustersService_DeleteKafkaCluster_Handler,
		},
		{
			MethodName: "CreateKafkaCluster",
			Handler:    _KafkaClustersService_CreateKafkaCluster_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/kafka_clusters/v1/kafka_clusters_v1.proto",
}

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

Functions

func RegisterKafkaClustersServiceServer 

func RegisterKafkaClustersServiceServer(s grpc.ServiceRegistrar, srv KafkaClustersServiceServer)

Types

type CreateKafkaClusterRequest 

type CreateKafkaClusterRequest struct {
	KafkaCluster *v1.KafkaCluster `protobuf:"bytes,1,opt,name=kafka_cluster,json=kafkaCluster,proto3" json:"kafka_cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKafkaClusterRequest) Descriptor deprecated 

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

Deprecated: Use CreateKafkaClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateKafkaClusterRequest) GetKafkaCluster 

func (x *CreateKafkaClusterRequest) GetKafkaCluster() *v1.KafkaCluster

func (*CreateKafkaClusterRequest) ProtoMessage 

func (*CreateKafkaClusterRequest) ProtoMessage()

func (*CreateKafkaClusterRequest) ProtoReflect 

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

func (*CreateKafkaClusterRequest) Reset 

func (x *CreateKafkaClusterRequest) Reset()

func (*CreateKafkaClusterRequest) String 

func (x *CreateKafkaClusterRequest) String() string

type CreateKafkaClusterResponse 

type CreateKafkaClusterResponse struct {
	KafkaCluster *v1.KafkaCluster `protobuf:"bytes,1,opt,name=kafka_cluster,json=kafkaCluster,proto3" json:"kafka_cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKafkaClusterResponse) Descriptor deprecated 

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

Deprecated: Use CreateKafkaClusterResponse.ProtoReflect.Descriptor instead.

func (*CreateKafkaClusterResponse) GetKafkaCluster 

func (x *CreateKafkaClusterResponse) GetKafkaCluster() *v1.KafkaCluster

func (*CreateKafkaClusterResponse) ProtoMessage 

func (*CreateKafkaClusterResponse) ProtoMessage()

func (*CreateKafkaClusterResponse) ProtoReflect 

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

func (*CreateKafkaClusterResponse) Reset 

func (x *CreateKafkaClusterResponse) Reset()

func (*CreateKafkaClusterResponse) String 

func (x *CreateKafkaClusterResponse) String() string

type DeleteKafkaClusterRequest 

type DeleteKafkaClusterRequest struct {

	// Deprecated: Do not use.
	BillingId string              `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	Ref       *v1.KafkaClusterRef `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	ProjectId string              `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKafkaClusterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKafkaClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteKafkaClusterRequest) GetBillingId deprecated 

func (x *DeleteKafkaClusterRequest) GetBillingId() string

Deprecated: Do not use.

func (*DeleteKafkaClusterRequest) GetProjectId 

func (x *DeleteKafkaClusterRequest) GetProjectId() string

func (*DeleteKafkaClusterRequest) GetRef 

func (x *DeleteKafkaClusterRequest) GetRef() *v1.KafkaClusterRef

func (*DeleteKafkaClusterRequest) ProtoMessage 

func (*DeleteKafkaClusterRequest) ProtoMessage()

func (*DeleteKafkaClusterRequest) ProtoReflect 

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

func (*DeleteKafkaClusterRequest) Reset 

func (x *DeleteKafkaClusterRequest) Reset()

func (*DeleteKafkaClusterRequest) String 

func (x *DeleteKafkaClusterRequest) String() string

type DeleteKafkaClusterResponse 

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

func (*DeleteKafkaClusterResponse) Descriptor deprecated 

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

Deprecated: Use DeleteKafkaClusterResponse.ProtoReflect.Descriptor instead.

func (*DeleteKafkaClusterResponse) ProtoMessage 

func (*DeleteKafkaClusterResponse) ProtoMessage()

func (*DeleteKafkaClusterResponse) ProtoReflect 

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

func (*DeleteKafkaClusterResponse) Reset 

func (x *DeleteKafkaClusterResponse) Reset()

func (*DeleteKafkaClusterResponse) String 

func (x *DeleteKafkaClusterResponse) String() string

type GetKafkaClusterRequest 

type GetKafkaClusterRequest struct {

	// Deprecated: Do not use.
	BillingId string              `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	Ref       *v1.KafkaClusterRef `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	ProjectId string              `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKafkaClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetKafkaClusterRequest.ProtoReflect.Descriptor instead.

func (*GetKafkaClusterRequest) GetBillingId deprecated 

func (x *GetKafkaClusterRequest) GetBillingId() string

Deprecated: Do not use.

func (*GetKafkaClusterRequest) GetProjectId 

func (x *GetKafkaClusterRequest) GetProjectId() string

func (*GetKafkaClusterRequest) GetRef 

func (x *GetKafkaClusterRequest) GetRef() *v1.KafkaClusterRef

func (*GetKafkaClusterRequest) ProtoMessage 

func (*GetKafkaClusterRequest) ProtoMessage()

func (*GetKafkaClusterRequest) ProtoReflect 

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

func (*GetKafkaClusterRequest) Reset 

func (x *GetKafkaClusterRequest) Reset()

func (*GetKafkaClusterRequest) String 

func (x *GetKafkaClusterRequest) String() string

type GetKafkaClusterResponse 

type GetKafkaClusterResponse struct {
	KafkaCluster *v1.KafkaCluster `protobuf:"bytes,1,opt,name=kafka_cluster,json=kafkaCluster,proto3" json:"kafka_cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKafkaClusterResponse) Descriptor deprecated 

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

Deprecated: Use GetKafkaClusterResponse.ProtoReflect.Descriptor instead.

func (*GetKafkaClusterResponse) GetKafkaCluster 

func (x *GetKafkaClusterResponse) GetKafkaCluster() *v1.KafkaCluster

func (*GetKafkaClusterResponse) ProtoMessage 

func (*GetKafkaClusterResponse) ProtoMessage()

func (*GetKafkaClusterResponse) ProtoReflect 

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

func (*GetKafkaClusterResponse) Reset 

func (x *GetKafkaClusterResponse) Reset()

func (*GetKafkaClusterResponse) String 

func (x *GetKafkaClusterResponse) String() string

type KafkaClustersServiceClient 

type KafkaClustersServiceClient interface {
	ListKafkaClusters(ctx context.Context, in *ListKafkaClustersRequest, opts ...grpc.CallOption) (*ListKafkaClustersResponse, error)
	GetKafkaCluster(ctx context.Context, in *GetKafkaClusterRequest, opts ...grpc.CallOption) (*GetKafkaClusterResponse, error)
	DeleteKafkaCluster(ctx context.Context, in *DeleteKafkaClusterRequest, opts ...grpc.CallOption) (*DeleteKafkaClusterResponse, error)
	CreateKafkaCluster(ctx context.Context, in *CreateKafkaClusterRequest, opts ...grpc.CallOption) (*CreateKafkaClusterResponse, error)
}

KafkaClustersServiceClient is the client API for KafkaClustersService 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 NewKafkaClustersServiceClient 

func NewKafkaClustersServiceClient(cc grpc.ClientConnInterface) KafkaClustersServiceClient

type KafkaClustersServiceServer 

type KafkaClustersServiceServer interface {
	ListKafkaClusters(context.Context, *ListKafkaClustersRequest) (*ListKafkaClustersResponse, error)
	GetKafkaCluster(context.Context, *GetKafkaClusterRequest) (*GetKafkaClusterResponse, error)
	DeleteKafkaCluster(context.Context, *DeleteKafkaClusterRequest) (*DeleteKafkaClusterResponse, error)
	CreateKafkaCluster(context.Context, *CreateKafkaClusterRequest) (*CreateKafkaClusterResponse, error)
}

KafkaClustersServiceServer is the server API for KafkaClustersService service. All implementations should embed UnimplementedKafkaClustersServiceServer for forward compatibility

type ListKafkaClustersRequest 

type ListKafkaClustersRequest struct {

	// Deprecated: Do not use.
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKafkaClustersRequest) Descriptor deprecated 

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

Deprecated: Use ListKafkaClustersRequest.ProtoReflect.Descriptor instead.

func (*ListKafkaClustersRequest) GetBillingId deprecated 

func (x *ListKafkaClustersRequest) GetBillingId() string

Deprecated: Do not use.

func (*ListKafkaClustersRequest) GetProjectId 

func (x *ListKafkaClustersRequest) GetProjectId() string

func (*ListKafkaClustersRequest) ProtoMessage 

func (*ListKafkaClustersRequest) ProtoMessage()

func (*ListKafkaClustersRequest) ProtoReflect 

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

func (*ListKafkaClustersRequest) Reset 

func (x *ListKafkaClustersRequest) Reset()

func (*ListKafkaClustersRequest) String 

func (x *ListKafkaClustersRequest) String() string

type ListKafkaClustersResponse 

type ListKafkaClustersResponse struct {
	KafkaClusters []*v1.KafkaCluster `protobuf:"bytes,1,rep,name=kafka_clusters,json=kafkaClusters,proto3" json:"kafka_clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKafkaClustersResponse) Descriptor deprecated 

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

Deprecated: Use ListKafkaClustersResponse.ProtoReflect.Descriptor instead.

func (*ListKafkaClustersResponse) GetKafkaClusters 

func (x *ListKafkaClustersResponse) GetKafkaClusters() []*v1.KafkaCluster

func (*ListKafkaClustersResponse) ProtoMessage 

func (*ListKafkaClustersResponse) ProtoMessage()

func (*ListKafkaClustersResponse) ProtoReflect 

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

func (*ListKafkaClustersResponse) Reset 

func (x *ListKafkaClustersResponse) Reset()

func (*ListKafkaClustersResponse) String 

func (x *ListKafkaClustersResponse) String() string

type UnimplementedKafkaClustersServiceServer 

type UnimplementedKafkaClustersServiceServer struct {
}

UnimplementedKafkaClustersServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedKafkaClustersServiceServer) CreateKafkaCluster 

func (UnimplementedKafkaClustersServiceServer) CreateKafkaCluster(context.Context, *CreateKafkaClusterRequest) (*CreateKafkaClusterResponse, error)

func (UnimplementedKafkaClustersServiceServer) DeleteKafkaCluster 

func (UnimplementedKafkaClustersServiceServer) DeleteKafkaCluster(context.Context, *DeleteKafkaClusterRequest) (*DeleteKafkaClusterResponse, error)

func (UnimplementedKafkaClustersServiceServer) GetKafkaCluster 

func (UnimplementedKafkaClustersServiceServer) GetKafkaCluster(context.Context, *GetKafkaClusterRequest) (*GetKafkaClusterResponse, error)

func (UnimplementedKafkaClustersServiceServer) ListKafkaClusters 

func (UnimplementedKafkaClustersServiceServer) ListKafkaClusters(context.Context, *ListKafkaClustersRequest) (*ListKafkaClustersResponse, error)

type UnsafeKafkaClustersServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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