Versions in this module Expand all Collapse all v1 v1.31.0 Nov 16, 2021 Changes in this version + var File_streammachine_api_kafka_clusters_v1_kafka_clusters_v1_proto protoreflect.FileDescriptor + var KafkaClustersService_ServiceDesc = grpc.ServiceDesc + func RegisterKafkaClustersServiceServer(s grpc.ServiceRegistrar, srv KafkaClustersServiceServer) + type CreateKafkaClusterRequest struct + KafkaCluster *v1.KafkaCluster + func (*CreateKafkaClusterRequest) Descriptor() ([]byte, []int) + func (*CreateKafkaClusterRequest) ProtoMessage() + func (x *CreateKafkaClusterRequest) GetKafkaCluster() *v1.KafkaCluster + func (x *CreateKafkaClusterRequest) ProtoReflect() protoreflect.Message + func (x *CreateKafkaClusterRequest) Reset() + func (x *CreateKafkaClusterRequest) String() string + type CreateKafkaClusterResponse struct + KafkaCluster *v1.KafkaCluster + func (*CreateKafkaClusterResponse) Descriptor() ([]byte, []int) + func (*CreateKafkaClusterResponse) ProtoMessage() + func (x *CreateKafkaClusterResponse) GetKafkaCluster() *v1.KafkaCluster + func (x *CreateKafkaClusterResponse) ProtoReflect() protoreflect.Message + func (x *CreateKafkaClusterResponse) Reset() + func (x *CreateKafkaClusterResponse) String() string + type DeleteKafkaClusterRequest struct + BillingId string + Ref *v1.KafkaClusterRef + func (*DeleteKafkaClusterRequest) Descriptor() ([]byte, []int) + func (*DeleteKafkaClusterRequest) ProtoMessage() + func (x *DeleteKafkaClusterRequest) GetBillingId() string + func (x *DeleteKafkaClusterRequest) GetRef() *v1.KafkaClusterRef + func (x *DeleteKafkaClusterRequest) ProtoReflect() protoreflect.Message + func (x *DeleteKafkaClusterRequest) Reset() + func (x *DeleteKafkaClusterRequest) String() string + type DeleteKafkaClusterResponse struct + func (*DeleteKafkaClusterResponse) Descriptor() ([]byte, []int) + func (*DeleteKafkaClusterResponse) ProtoMessage() + func (x *DeleteKafkaClusterResponse) ProtoReflect() protoreflect.Message + func (x *DeleteKafkaClusterResponse) Reset() + func (x *DeleteKafkaClusterResponse) String() string + type GetKafkaClusterRequest struct + BillingId string + Ref *v1.KafkaClusterRef + func (*GetKafkaClusterRequest) Descriptor() ([]byte, []int) + func (*GetKafkaClusterRequest) ProtoMessage() + func (x *GetKafkaClusterRequest) GetBillingId() string + func (x *GetKafkaClusterRequest) GetRef() *v1.KafkaClusterRef + func (x *GetKafkaClusterRequest) ProtoReflect() protoreflect.Message + func (x *GetKafkaClusterRequest) Reset() + func (x *GetKafkaClusterRequest) String() string + type GetKafkaClusterResponse struct + KafkaCluster *v1.KafkaCluster + func (*GetKafkaClusterResponse) Descriptor() ([]byte, []int) + func (*GetKafkaClusterResponse) ProtoMessage() + func (x *GetKafkaClusterResponse) GetKafkaCluster() *v1.KafkaCluster + func (x *GetKafkaClusterResponse) ProtoReflect() protoreflect.Message + func (x *GetKafkaClusterResponse) Reset() + func (x *GetKafkaClusterResponse) String() string + type KafkaClustersServiceClient interface + CreateKafkaCluster func(ctx context.Context, in *CreateKafkaClusterRequest, opts ...grpc.CallOption) (*CreateKafkaClusterResponse, error) + DeleteKafkaCluster func(ctx context.Context, in *DeleteKafkaClusterRequest, opts ...grpc.CallOption) (*DeleteKafkaClusterResponse, error) + GetKafkaCluster func(ctx context.Context, in *GetKafkaClusterRequest, opts ...grpc.CallOption) (*GetKafkaClusterResponse, error) + ListKafkaClusters func(ctx context.Context, in *ListKafkaClustersRequest, opts ...grpc.CallOption) (*ListKafkaClustersResponse, error) + func NewKafkaClustersServiceClient(cc grpc.ClientConnInterface) KafkaClustersServiceClient + type KafkaClustersServiceServer interface + CreateKafkaCluster func(context.Context, *CreateKafkaClusterRequest) (*CreateKafkaClusterResponse, error) + DeleteKafkaCluster func(context.Context, *DeleteKafkaClusterRequest) (*DeleteKafkaClusterResponse, error) + GetKafkaCluster func(context.Context, *GetKafkaClusterRequest) (*GetKafkaClusterResponse, error) + ListKafkaClusters func(context.Context, *ListKafkaClustersRequest) (*ListKafkaClustersResponse, error) + type ListKafkaClustersRequest struct + BillingId string + func (*ListKafkaClustersRequest) Descriptor() ([]byte, []int) + func (*ListKafkaClustersRequest) ProtoMessage() + func (x *ListKafkaClustersRequest) GetBillingId() string + func (x *ListKafkaClustersRequest) ProtoReflect() protoreflect.Message + func (x *ListKafkaClustersRequest) Reset() + func (x *ListKafkaClustersRequest) String() string + type ListKafkaClustersResponse struct + KafkaClusters []*v1.KafkaCluster + func (*ListKafkaClustersResponse) Descriptor() ([]byte, []int) + func (*ListKafkaClustersResponse) ProtoMessage() + func (x *ListKafkaClustersResponse) GetKafkaClusters() []*v1.KafkaCluster + func (x *ListKafkaClustersResponse) ProtoReflect() protoreflect.Message + func (x *ListKafkaClustersResponse) Reset() + func (x *ListKafkaClustersResponse) String() string + type UnimplementedKafkaClustersServiceServer struct + func (UnimplementedKafkaClustersServiceServer) CreateKafkaCluster(context.Context, *CreateKafkaClusterRequest) (*CreateKafkaClusterResponse, error) + func (UnimplementedKafkaClustersServiceServer) DeleteKafkaCluster(context.Context, *DeleteKafkaClusterRequest) (*DeleteKafkaClusterResponse, error) + func (UnimplementedKafkaClustersServiceServer) GetKafkaCluster(context.Context, *GetKafkaClusterRequest) (*GetKafkaClusterResponse, error) + func (UnimplementedKafkaClustersServiceServer) ListKafkaClusters(context.Context, *ListKafkaClustersRequest) (*ListKafkaClustersResponse, error) + type UnsafeKafkaClustersServiceServer interface Other modules containing this package github.com/strmprivacy/api-definitions-go/v2 github.com/strmprivacy/api-definitions-go/v3
Go to main page