kafkacloudevent

Documentation

Index

• Constants
• Variables
• func AddKafkaCloudEventServiceServer(cb fluffy_dozm_di.ContainerBuilder, ctor any)
• func AddKafkaCloudEventServiceServerWithExternalRegistration(cb fluffy_dozm_di.ContainerBuilder, ctor any, ...)
• func RegisterKafkaCloudEventServiceServer(s grpc.ServiceRegistrar, srv KafkaCloudEventServiceServer)
• type IFluffyCoreKafkaCloudEventServiceServer
• type KafkaCloudEventServiceClient
  • func NewKafkaCloudEventServiceClient(cc grpc.ClientConnInterface) KafkaCloudEventServiceClient
• type KafkaCloudEventServiceFluffyCoreServer
  • func (srv *KafkaCloudEventServiceFluffyCoreServer) RegisterFluffyCoreGRPCService(s *grpc.Server)
  • func (s *KafkaCloudEventServiceFluffyCoreServer) SubmitCloudEvents(ctx context.Context, request *SubmitCloudEventsRequest) (*SubmitCloudEventsResponse, error)
• type KafkaCloudEventServiceServer
• type SubmitCloudEventsRequest
  • func (*SubmitCloudEventsRequest) Descriptor() ([]byte, []int)
  • func (x *SubmitCloudEventsRequest) GetBatch() *cloudevents.CloudEventBatch
  • func (*SubmitCloudEventsRequest) ProtoMessage()
  • func (x *SubmitCloudEventsRequest) ProtoReflect() protoreflect.Message
  • func (x *SubmitCloudEventsRequest) Reset()
  • func (x *SubmitCloudEventsRequest) String() string
• type SubmitCloudEventsResponse
  • func (*SubmitCloudEventsResponse) Descriptor() ([]byte, []int)
  • func (*SubmitCloudEventsResponse) ProtoMessage()
  • func (x *SubmitCloudEventsResponse) ProtoReflect() protoreflect.Message
  • func (x *SubmitCloudEventsResponse) Reset()
  • func (x *SubmitCloudEventsResponse) String() string
• type UnimplementedFluffyCoreKafkaCloudEventServiceServerEndpointRegistration
  • func (UnimplementedFluffyCoreKafkaCloudEventServiceServerEndpointRegistration) RegisterFluffyCoreHandler(gwmux *runtime.ServeMux, conn *grpc.ClientConn)
• type UnimplementedKafkaCloudEventServiceServer
  • func (UnimplementedKafkaCloudEventServiceServer) SubmitCloudEvents(context.Context, *SubmitCloudEventsRequest) (*SubmitCloudEventsResponse, error)
• type UnsafeKafkaCloudEventServiceServer

Constants

const (
	KafkaCloudEventService_SubmitCloudEvents_FullMethodName = "/pkg.proto.kafkacloudevent.KafkaCloudEventService/SubmitCloudEvents"
)

Variables

var File_pkg_proto_kafkacloudevent_kafkacloudevent_proto protoreflect.FileDescriptor

var KafkaCloudEventService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pkg.proto.kafkacloudevent.KafkaCloudEventService",
	HandlerType: (*KafkaCloudEventServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitCloudEvents",
			Handler:    _KafkaCloudEventService_SubmitCloudEvents_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/proto/kafkacloudevent/kafkacloudevent.proto",
}

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

Functions

func AddKafkaCloudEventServiceServer

func AddKafkaCloudEventServiceServer(cb fluffy_dozm_di.ContainerBuilder, ctor any)

AddKafkaCloudEventServiceServer adds the fluffycore aware grpc server

func AddKafkaCloudEventServiceServerWithExternalRegistration

func AddKafkaCloudEventServiceServerWithExternalRegistration(cb fluffy_dozm_di.ContainerBuilder, ctor any, register func() endpoint.IEndpointRegistration)

AddKafkaCloudEventServiceServerWithExternalRegistration adds the fluffycore aware grpc server and external registration service. Mainly used for grpc-gateway

func RegisterKafkaCloudEventServiceServer

func RegisterKafkaCloudEventServiceServer(s grpc.ServiceRegistrar, srv KafkaCloudEventServiceServer)

Types

type IFluffyCoreKafkaCloudEventServiceServer

type IFluffyCoreKafkaCloudEventServiceServer interface {
	KafkaCloudEventServiceServer
}

IFluffyCoreKafkaCloudEventServiceServer defines the grpc server

type KafkaCloudEventServiceClient

type KafkaCloudEventServiceClient interface {
	// submits a batch of cloud events
	SubmitCloudEvents(ctx context.Context, in *SubmitCloudEventsRequest, opts ...grpc.CallOption) (*SubmitCloudEventsResponse, error)
}

KafkaCloudEventServiceClient is the client API for KafkaCloudEventService 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 NewKafkaCloudEventServiceClient

func NewKafkaCloudEventServiceClient(cc grpc.ClientConnInterface) KafkaCloudEventServiceClient

type KafkaCloudEventServiceFluffyCoreServer

type KafkaCloudEventServiceFluffyCoreServer struct {
	UnimplementedKafkaCloudEventServiceServer
	UnimplementedFluffyCoreKafkaCloudEventServiceServerEndpointRegistration
}

KafkaCloudEventServiceFluffyCoreServer defines the grpc server truct

func (*KafkaCloudEventServiceFluffyCoreServer) RegisterFluffyCoreGRPCService

func (srv *KafkaCloudEventServiceFluffyCoreServer) RegisterFluffyCoreGRPCService(s *grpc.Server)

RegisterFluffyCoreGRPCService the server with grpc

func (*KafkaCloudEventServiceFluffyCoreServer) SubmitCloudEvents

func (s *KafkaCloudEventServiceFluffyCoreServer) SubmitCloudEvents(ctx context.Context, request *SubmitCloudEventsRequest) (*SubmitCloudEventsResponse, error)

SubmitCloudEvents...

type KafkaCloudEventServiceServer

type KafkaCloudEventServiceServer interface {
	// submits a batch of cloud events
	SubmitCloudEvents(context.Context, *SubmitCloudEventsRequest) (*SubmitCloudEventsResponse, error)
	// contains filtered or unexported methods
}

KafkaCloudEventServiceServer is the server API for KafkaCloudEventService service. All implementations must embed UnimplementedKafkaCloudEventServiceServer for forward compatibility

type SubmitCloudEventsRequest

type SubmitCloudEventsRequest struct {
	Batch *cloudevents.CloudEventBatch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitCloudEventsRequest) Descriptor

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

Deprecated: Use SubmitCloudEventsRequest.ProtoReflect.Descriptor instead.

func (*SubmitCloudEventsRequest) GetBatch

func (x *SubmitCloudEventsRequest) GetBatch() *cloudevents.CloudEventBatch

func (*SubmitCloudEventsRequest) ProtoMessage

func (*SubmitCloudEventsRequest) ProtoMessage()

func (*SubmitCloudEventsRequest) ProtoReflect

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

func (*SubmitCloudEventsRequest) Reset

func (x *SubmitCloudEventsRequest) Reset()

func (*SubmitCloudEventsRequest) String

func (x *SubmitCloudEventsRequest) String() string

type SubmitCloudEventsResponse

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

func (*SubmitCloudEventsResponse) Descriptor

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

Deprecated: Use SubmitCloudEventsResponse.ProtoReflect.Descriptor instead.

func (*SubmitCloudEventsResponse) ProtoMessage

func (*SubmitCloudEventsResponse) ProtoMessage()

func (*SubmitCloudEventsResponse) ProtoReflect

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

func (*SubmitCloudEventsResponse) Reset

func (x *SubmitCloudEventsResponse) Reset()

func (*SubmitCloudEventsResponse) String

func (x *SubmitCloudEventsResponse) String() string

type UnimplementedFluffyCoreKafkaCloudEventServiceServerEndpointRegistration

type UnimplementedFluffyCoreKafkaCloudEventServiceServerEndpointRegistration struct {
}

func (UnimplementedFluffyCoreKafkaCloudEventServiceServerEndpointRegistration) RegisterFluffyCoreHandler

func (UnimplementedFluffyCoreKafkaCloudEventServiceServerEndpointRegistration) RegisterFluffyCoreHandler(gwmux *runtime.ServeMux, conn *grpc.ClientConn)

type UnimplementedKafkaCloudEventServiceServer

type UnimplementedKafkaCloudEventServiceServer struct {
}

UnimplementedKafkaCloudEventServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedKafkaCloudEventServiceServer) SubmitCloudEvents

func (UnimplementedKafkaCloudEventServiceServer) SubmitCloudEvents(context.Context, *SubmitCloudEventsRequest) (*SubmitCloudEventsResponse, error)

type UnsafeKafkaCloudEventServiceServer

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

UnsafeKafkaCloudEventServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KafkaCloudEventServiceServer will result in compilation errors.