Versions in this module Expand all Collapse all v1 v1.31.0 Nov 16, 2021 Changes in this version + var File_streammachine_api_kafka_exporters_v1_kafka_exporters_v1_proto protoreflect.FileDescriptor + var KafkaExportersService_ServiceDesc = grpc.ServiceDesc + func RegisterKafkaExportersServiceServer(s grpc.ServiceRegistrar, srv KafkaExportersServiceServer) + type CreateKafkaExporterRequest struct + KafkaExporter *v1.KafkaExporter + func (*CreateKafkaExporterRequest) Descriptor() ([]byte, []int) + func (*CreateKafkaExporterRequest) ProtoMessage() + func (x *CreateKafkaExporterRequest) GetKafkaExporter() *v1.KafkaExporter + func (x *CreateKafkaExporterRequest) ProtoReflect() protoreflect.Message + func (x *CreateKafkaExporterRequest) Reset() + func (x *CreateKafkaExporterRequest) String() string + type CreateKafkaExporterResponse struct + KafkaExporter *v1.KafkaExporter + func (*CreateKafkaExporterResponse) Descriptor() ([]byte, []int) + func (*CreateKafkaExporterResponse) ProtoMessage() + func (x *CreateKafkaExporterResponse) GetKafkaExporter() *v1.KafkaExporter + func (x *CreateKafkaExporterResponse) ProtoReflect() protoreflect.Message + func (x *CreateKafkaExporterResponse) Reset() + func (x *CreateKafkaExporterResponse) String() string + type DeleteKafkaExporterRequest struct + Recursive bool + Ref *v1.KafkaExporterRef + func (*DeleteKafkaExporterRequest) Descriptor() ([]byte, []int) + func (*DeleteKafkaExporterRequest) ProtoMessage() + func (x *DeleteKafkaExporterRequest) GetRecursive() bool + func (x *DeleteKafkaExporterRequest) GetRef() *v1.KafkaExporterRef + func (x *DeleteKafkaExporterRequest) ProtoReflect() protoreflect.Message + func (x *DeleteKafkaExporterRequest) Reset() + func (x *DeleteKafkaExporterRequest) String() string + type DeleteKafkaExporterResponse struct + func (*DeleteKafkaExporterResponse) Descriptor() ([]byte, []int) + func (*DeleteKafkaExporterResponse) ProtoMessage() + func (x *DeleteKafkaExporterResponse) ProtoReflect() protoreflect.Message + func (x *DeleteKafkaExporterResponse) Reset() + func (x *DeleteKafkaExporterResponse) String() string + type GetKafkaExporterRequest struct + Ref *v1.KafkaExporterRef + func (*GetKafkaExporterRequest) Descriptor() ([]byte, []int) + func (*GetKafkaExporterRequest) ProtoMessage() + func (x *GetKafkaExporterRequest) GetRef() *v1.KafkaExporterRef + func (x *GetKafkaExporterRequest) ProtoReflect() protoreflect.Message + func (x *GetKafkaExporterRequest) Reset() + func (x *GetKafkaExporterRequest) String() string + type GetKafkaExporterResponse struct + KafkaExporter *v1.KafkaExporter + func (*GetKafkaExporterResponse) Descriptor() ([]byte, []int) + func (*GetKafkaExporterResponse) ProtoMessage() + func (x *GetKafkaExporterResponse) GetKafkaExporter() *v1.KafkaExporter + func (x *GetKafkaExporterResponse) ProtoReflect() protoreflect.Message + func (x *GetKafkaExporterResponse) Reset() + func (x *GetKafkaExporterResponse) String() string + type KafkaExportersServiceClient interface + CreateKafkaExporter func(ctx context.Context, in *CreateKafkaExporterRequest, opts ...grpc.CallOption) (*CreateKafkaExporterResponse, error) + DeleteKafkaExporter func(ctx context.Context, in *DeleteKafkaExporterRequest, opts ...grpc.CallOption) (*DeleteKafkaExporterResponse, error) + GetKafkaExporter func(ctx context.Context, in *GetKafkaExporterRequest, opts ...grpc.CallOption) (*GetKafkaExporterResponse, error) + ListKafkaExporters func(ctx context.Context, in *ListKafkaExportersRequest, opts ...grpc.CallOption) (*ListKafkaExportersResponse, error) + func NewKafkaExportersServiceClient(cc grpc.ClientConnInterface) KafkaExportersServiceClient + type KafkaExportersServiceServer interface + CreateKafkaExporter func(context.Context, *CreateKafkaExporterRequest) (*CreateKafkaExporterResponse, error) + DeleteKafkaExporter func(context.Context, *DeleteKafkaExporterRequest) (*DeleteKafkaExporterResponse, error) + GetKafkaExporter func(context.Context, *GetKafkaExporterRequest) (*GetKafkaExporterResponse, error) + ListKafkaExporters func(context.Context, *ListKafkaExportersRequest) (*ListKafkaExportersResponse, error) + type ListKafkaExportersRequest struct + BillingId string + func (*ListKafkaExportersRequest) Descriptor() ([]byte, []int) + func (*ListKafkaExportersRequest) ProtoMessage() + func (x *ListKafkaExportersRequest) GetBillingId() string + func (x *ListKafkaExportersRequest) ProtoReflect() protoreflect.Message + func (x *ListKafkaExportersRequest) Reset() + func (x *ListKafkaExportersRequest) String() string + type ListKafkaExportersResponse struct + KafkaExporters []*v1.KafkaExporter + func (*ListKafkaExportersResponse) Descriptor() ([]byte, []int) + func (*ListKafkaExportersResponse) ProtoMessage() + func (x *ListKafkaExportersResponse) GetKafkaExporters() []*v1.KafkaExporter + func (x *ListKafkaExportersResponse) ProtoReflect() protoreflect.Message + func (x *ListKafkaExportersResponse) Reset() + func (x *ListKafkaExportersResponse) String() string + type UnimplementedKafkaExportersServiceServer struct + func (UnimplementedKafkaExportersServiceServer) CreateKafkaExporter(context.Context, *CreateKafkaExporterRequest) (*CreateKafkaExporterResponse, error) + func (UnimplementedKafkaExportersServiceServer) DeleteKafkaExporter(context.Context, *DeleteKafkaExporterRequest) (*DeleteKafkaExporterResponse, error) + func (UnimplementedKafkaExportersServiceServer) GetKafkaExporter(context.Context, *GetKafkaExporterRequest) (*GetKafkaExporterResponse, error) + func (UnimplementedKafkaExportersServiceServer) ListKafkaExporters(context.Context, *ListKafkaExportersRequest) (*ListKafkaExportersResponse, error) + type UnsafeKafkaExportersServiceServer interface Other modules containing this package github.com/strmprivacy/api-definitions-go/v2 github.com/strmprivacy/api-definitions-go/v3
Go to main page