cloudeventprocessor

Mar 22, 2024

Changes in this version

type CloudEventProcessorFluffyCoreServer

+ func (srv *CloudEventProcessorFluffyCoreServer) RegisterFluffyCoreGRPCService(s *grpc.Server)

+ type IFluffyCoreCloudEventProcessorServer interface

+ type UnimplementedFluffyCoreCloudEventProcessorServerEndpointRegistration struct

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

Jan 18, 2024

Changes in this version

type ProcessCloudEventsRequest

+ Channel string

+ func (x *ProcessCloudEventsRequest) GetChannel() string

Nov 11, 2023

Changes in this version

+ const CloudEventProcessor_ProcessCloudEvents_FullMethodName

+ var CloudEventProcessor_ServiceDesc = grpc.ServiceDesc

+ var File_pkg_proto_cloudeventprocessor_cloudeventprocessor_proto protoreflect.FileDescriptor

+ func AddCloudEventProcessorServerWithExternalRegistration[T ICloudEventProcessorServer](cb fluffy_dozm_di.ContainerBuilder, ctor any, ...)

+ func AddCloudEventProcessorServer[T ICloudEventProcessorServer](cb fluffy_dozm_di.ContainerBuilder, ctor any)

+ func RegisterCloudEventProcessorServer(s grpc.ServiceRegistrar, srv CloudEventProcessorServer)

+ type ByteBatch struct

+ Messages [][]byte

+ func (*ByteBatch) Descriptor() ([]byte, []int)

+ func (*ByteBatch) ProtoMessage()

+ func (x *ByteBatch) GetMessages() [][]byte

+ func (x *ByteBatch) ProtoReflect() protoreflect.Message

+ func (x *ByteBatch) Reset()

+ func (x *ByteBatch) String() string

+ type CloudEventProcessorClient interface

+ ProcessCloudEvents func(ctx context.Context, in *ProcessCloudEventsRequest, opts ...grpc.CallOption) (*ProcessCloudEventsResponse, error)

+ func NewCloudEventProcessorClient(cc grpc.ClientConnInterface) CloudEventProcessorClient

+ type CloudEventProcessorFluffyCoreServer struct

+ func (s *CloudEventProcessorFluffyCoreServer) ProcessCloudEvents(ctx context.Context, request *ProcessCloudEventsRequest) (*ProcessCloudEventsResponse, error)

+ func (srv *CloudEventProcessorFluffyCoreServer) Register(s *grpc.Server)

+ type CloudEventProcessorServer interface

+ ProcessCloudEvents func(context.Context, *ProcessCloudEventsRequest) (*ProcessCloudEventsResponse, error)

+ type ICloudEventProcessorServer interface

+ type ProcessCloudEventsRequest struct

+ BadBatch *ByteBatch

+ Batch *cloudevents.CloudEventBatch

+ func (*ProcessCloudEventsRequest) Descriptor() ([]byte, []int)

+ func (*ProcessCloudEventsRequest) ProtoMessage()

+ func (x *ProcessCloudEventsRequest) GetBadBatch() *ByteBatch

+ func (x *ProcessCloudEventsRequest) GetBatch() *cloudevents.CloudEventBatch

+ func (x *ProcessCloudEventsRequest) ProtoReflect() protoreflect.Message

+ func (x *ProcessCloudEventsRequest) Reset()

+ func (x *ProcessCloudEventsRequest) String() string

+ type ProcessCloudEventsResponse struct

+ func (*ProcessCloudEventsResponse) Descriptor() ([]byte, []int)

+ func (*ProcessCloudEventsResponse) ProtoMessage()

+ func (x *ProcessCloudEventsResponse) ProtoReflect() protoreflect.Message

+ func (x *ProcessCloudEventsResponse) Reset()

+ func (x *ProcessCloudEventsResponse) String() string

+ type UnimplementedCloudEventProcessorServer struct

+ func (UnimplementedCloudEventProcessorServer) ProcessCloudEvents(context.Context, *ProcessCloudEventsRequest) (*ProcessCloudEventsResponse, error)

+ type UnimplementedCloudEventProcessorServerEndpointRegistration struct

+ func (UnimplementedCloudEventProcessorServerEndpointRegistration) RegisterHandler(gwmux *runtime.ServeMux, conn *grpc.ClientConn)

+ type UnsafeCloudEventProcessorServer interface