kafka_clusters

package
v1.31.0 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_streammachine_api_kafka_clusters_v1_kafka_clusters_v1_proto protoreflect.FileDescriptor
View Source 
var KafkaClustersService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "streammachine.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: "streammachine/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 {
	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"`
	// contains filtered or unexported fields
}

func (*DeleteKafkaClusterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKafkaClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteKafkaClusterRequest) GetBillingId 

func (x *DeleteKafkaClusterRequest) GetBillingId() 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 {
	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"`
	// contains filtered or unexported fields
}

func (*GetKafkaClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetKafkaClusterRequest.ProtoReflect.Descriptor instead.

func (*GetKafkaClusterRequest) GetBillingId 

func (x *GetKafkaClusterRequest) GetBillingId() 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)
	// contains filtered or unexported methods
}

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

type ListKafkaClustersRequest 

type ListKafkaClustersRequest struct {
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_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 

func (x *ListKafkaClustersRequest) GetBillingId() 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 must 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.