kafka_users

package
v3.18.4 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_strmprivacy_api_kafka_users_v1_kafka_users_v1_proto protoreflect.FileDescriptor
View Source 
var KafkaUsersService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.kafka_users.v1.KafkaUsersService",
	HandlerType: (*KafkaUsersServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListKafkaUsers",
			Handler:    _KafkaUsersService_ListKafkaUsers_Handler,
		},
		{
			MethodName: "GetKafkaUser",
			Handler:    _KafkaUsersService_GetKafkaUser_Handler,
		},
		{
			MethodName: "DeleteKafkaUser",
			Handler:    _KafkaUsersService_DeleteKafkaUser_Handler,
		},
		{
			MethodName: "CreateKafkaUser",
			Handler:    _KafkaUsersService_CreateKafkaUser_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/kafka_users/v1/kafka_users_v1.proto",
}

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

Functions

func RegisterKafkaUsersServiceServer 

func RegisterKafkaUsersServiceServer(s grpc.ServiceRegistrar, srv KafkaUsersServiceServer)

Types

type CreateKafkaUserRequest 

type CreateKafkaUserRequest struct {
	KafkaUser *v1.KafkaUser `protobuf:"bytes,1,opt,name=kafka_user,json=kafkaUser,proto3" json:"kafka_user,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKafkaUserRequest) Descriptor deprecated 

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

Deprecated: Use CreateKafkaUserRequest.ProtoReflect.Descriptor instead.

func (*CreateKafkaUserRequest) GetKafkaUser 

func (x *CreateKafkaUserRequest) GetKafkaUser() *v1.KafkaUser

func (*CreateKafkaUserRequest) ProtoMessage 

func (*CreateKafkaUserRequest) ProtoMessage()

func (*CreateKafkaUserRequest) ProtoReflect 

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

func (*CreateKafkaUserRequest) Reset 

func (x *CreateKafkaUserRequest) Reset()

func (*CreateKafkaUserRequest) String 

func (x *CreateKafkaUserRequest) String() string

type CreateKafkaUserResponse 

type CreateKafkaUserResponse struct {
	KafkaUser *v1.KafkaUser `protobuf:"bytes,1,opt,name=kafka_user,json=kafkaUser,proto3" json:"kafka_user,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKafkaUserResponse) Descriptor deprecated 

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

Deprecated: Use CreateKafkaUserResponse.ProtoReflect.Descriptor instead.

func (*CreateKafkaUserResponse) GetKafkaUser 

func (x *CreateKafkaUserResponse) GetKafkaUser() *v1.KafkaUser

func (*CreateKafkaUserResponse) ProtoMessage 

func (*CreateKafkaUserResponse) ProtoMessage()

func (*CreateKafkaUserResponse) ProtoReflect 

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

func (*CreateKafkaUserResponse) Reset 

func (x *CreateKafkaUserResponse) Reset()

func (*CreateKafkaUserResponse) String 

func (x *CreateKafkaUserResponse) String() string

type DeleteKafkaUserRequest 

type DeleteKafkaUserRequest struct {
	Ref *v1.KafkaUserRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKafkaUserRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKafkaUserRequest.ProtoReflect.Descriptor instead.

func (*DeleteKafkaUserRequest) GetRef 

func (x *DeleteKafkaUserRequest) GetRef() *v1.KafkaUserRef

func (*DeleteKafkaUserRequest) ProtoMessage 

func (*DeleteKafkaUserRequest) ProtoMessage()

func (*DeleteKafkaUserRequest) ProtoReflect 

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

func (*DeleteKafkaUserRequest) Reset 

func (x *DeleteKafkaUserRequest) Reset()

func (*DeleteKafkaUserRequest) String 

func (x *DeleteKafkaUserRequest) String() string

type DeleteKafkaUserResponse 

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

func (*DeleteKafkaUserResponse) Descriptor deprecated 

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

Deprecated: Use DeleteKafkaUserResponse.ProtoReflect.Descriptor instead.

func (*DeleteKafkaUserResponse) ProtoMessage 

func (*DeleteKafkaUserResponse) ProtoMessage()

func (*DeleteKafkaUserResponse) ProtoReflect 

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

func (*DeleteKafkaUserResponse) Reset 

func (x *DeleteKafkaUserResponse) Reset()

func (*DeleteKafkaUserResponse) String 

func (x *DeleteKafkaUserResponse) String() string

type GetKafkaUserRequest 

type GetKafkaUserRequest struct {
	Ref *v1.KafkaUserRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKafkaUserRequest) Descriptor deprecated 

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

Deprecated: Use GetKafkaUserRequest.ProtoReflect.Descriptor instead.

func (*GetKafkaUserRequest) GetRef 

func (x *GetKafkaUserRequest) GetRef() *v1.KafkaUserRef

func (*GetKafkaUserRequest) ProtoMessage 

func (*GetKafkaUserRequest) ProtoMessage()

func (*GetKafkaUserRequest) ProtoReflect 

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

func (*GetKafkaUserRequest) Reset 

func (x *GetKafkaUserRequest) Reset()

func (*GetKafkaUserRequest) String 

func (x *GetKafkaUserRequest) String() string

type GetKafkaUserResponse 

type GetKafkaUserResponse struct {
	KafkaUser *v1.KafkaUser `protobuf:"bytes,1,opt,name=kafka_user,json=kafkaUser,proto3" json:"kafka_user,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKafkaUserResponse) Descriptor deprecated 

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

Deprecated: Use GetKafkaUserResponse.ProtoReflect.Descriptor instead.

func (*GetKafkaUserResponse) GetKafkaUser 

func (x *GetKafkaUserResponse) GetKafkaUser() *v1.KafkaUser

func (*GetKafkaUserResponse) ProtoMessage 

func (*GetKafkaUserResponse) ProtoMessage()

func (*GetKafkaUserResponse) ProtoReflect 

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

func (*GetKafkaUserResponse) Reset 

func (x *GetKafkaUserResponse) Reset()

func (*GetKafkaUserResponse) String 

func (x *GetKafkaUserResponse) String() string

type KafkaUsersServiceClient 

type KafkaUsersServiceClient interface {
	ListKafkaUsers(ctx context.Context, in *ListKafkaUsersRequest, opts ...grpc.CallOption) (*ListKafkaUsersResponse, error)
	GetKafkaUser(ctx context.Context, in *GetKafkaUserRequest, opts ...grpc.CallOption) (*GetKafkaUserResponse, error)
	DeleteKafkaUser(ctx context.Context, in *DeleteKafkaUserRequest, opts ...grpc.CallOption) (*DeleteKafkaUserResponse, error)
	CreateKafkaUser(ctx context.Context, in *CreateKafkaUserRequest, opts ...grpc.CallOption) (*CreateKafkaUserResponse, error)
}

KafkaUsersServiceClient is the client API for KafkaUsersService 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 NewKafkaUsersServiceClient 

func NewKafkaUsersServiceClient(cc grpc.ClientConnInterface) KafkaUsersServiceClient

type KafkaUsersServiceServer 

type KafkaUsersServiceServer interface {
	ListKafkaUsers(context.Context, *ListKafkaUsersRequest) (*ListKafkaUsersResponse, error)
	GetKafkaUser(context.Context, *GetKafkaUserRequest) (*GetKafkaUserResponse, error)
	DeleteKafkaUser(context.Context, *DeleteKafkaUserRequest) (*DeleteKafkaUserResponse, error)
	CreateKafkaUser(context.Context, *CreateKafkaUserRequest) (*CreateKafkaUserResponse, error)
}

KafkaUsersServiceServer is the server API for KafkaUsersService service. All implementations should embed UnimplementedKafkaUsersServiceServer for forward compatibility

type ListKafkaUsersRequest 

type ListKafkaUsersRequest struct {

	// (-- api-linter: core::0122::name-suffix=disabled
	//
	//	aip.dev/not-precedent: ref is a better name than Google suggests ¯\_(ツ)_/¯ --)
	Ref *v1.KafkaExporterRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKafkaUsersRequest) Descriptor deprecated 

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

Deprecated: Use ListKafkaUsersRequest.ProtoReflect.Descriptor instead.

func (*ListKafkaUsersRequest) GetRef 

func (x *ListKafkaUsersRequest) GetRef() *v1.KafkaExporterRef

func (*ListKafkaUsersRequest) ProtoMessage 

func (*ListKafkaUsersRequest) ProtoMessage()

func (*ListKafkaUsersRequest) ProtoReflect 

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

func (*ListKafkaUsersRequest) Reset 

func (x *ListKafkaUsersRequest) Reset()

func (*ListKafkaUsersRequest) String 

func (x *ListKafkaUsersRequest) String() string

type ListKafkaUsersResponse 

type ListKafkaUsersResponse struct {
	KafkaUsers []*v1.KafkaUser `protobuf:"bytes,1,rep,name=kafka_users,json=kafkaUsers,proto3" json:"kafka_users,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKafkaUsersResponse) Descriptor deprecated 

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

Deprecated: Use ListKafkaUsersResponse.ProtoReflect.Descriptor instead.

func (*ListKafkaUsersResponse) GetKafkaUsers 

func (x *ListKafkaUsersResponse) GetKafkaUsers() []*v1.KafkaUser

func (*ListKafkaUsersResponse) ProtoMessage 

func (*ListKafkaUsersResponse) ProtoMessage()

func (*ListKafkaUsersResponse) ProtoReflect 

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

func (*ListKafkaUsersResponse) Reset 

func (x *ListKafkaUsersResponse) Reset()

func (*ListKafkaUsersResponse) String 

func (x *ListKafkaUsersResponse) String() string

type UnimplementedKafkaUsersServiceServer 

type UnimplementedKafkaUsersServiceServer struct {
}

UnimplementedKafkaUsersServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedKafkaUsersServiceServer) CreateKafkaUser 

func (UnimplementedKafkaUsersServiceServer) CreateKafkaUser(context.Context, *CreateKafkaUserRequest) (*CreateKafkaUserResponse, error)

func (UnimplementedKafkaUsersServiceServer) DeleteKafkaUser 

func (UnimplementedKafkaUsersServiceServer) DeleteKafkaUser(context.Context, *DeleteKafkaUserRequest) (*DeleteKafkaUserResponse, error)

func (UnimplementedKafkaUsersServiceServer) GetKafkaUser 

func (UnimplementedKafkaUsersServiceServer) GetKafkaUser(context.Context, *GetKafkaUserRequest) (*GetKafkaUserResponse, error)

func (UnimplementedKafkaUsersServiceServer) ListKafkaUsers 

func (UnimplementedKafkaUsersServiceServer) ListKafkaUsers(context.Context, *ListKafkaUsersRequest) (*ListKafkaUsersResponse, error)

type UnsafeKafkaUsersServiceServer 

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

UnsafeKafkaUsersServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KafkaUsersServiceServer 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.