kafka_users

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_users_v1_kafka_users_v1_proto protoreflect.FileDescriptor
View Source
var KafkaUsersService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "streammachine.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: "streammachine/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.

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)
	// contains filtered or unexported methods
}

KafkaUsersServiceServer is the server API for KafkaUsersService service. All implementations must 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 (*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 must be embedded to have forward compatible implementations.

func (UnimplementedKafkaUsersServiceServer) CreateKafkaUser

func (UnimplementedKafkaUsersServiceServer) DeleteKafkaUser

func (UnimplementedKafkaUsersServiceServer) GetKafkaUser

func (UnimplementedKafkaUsersServiceServer) ListKafkaUsers

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL