processing

type EventHandlerClientToRuntimeMessage struct {

	// Types that are assignable to Message:
	//	*EventHandlerClientToRuntimeMessage_RegistrationRequest
	//	*EventHandlerClientToRuntimeMessage_HandleResult
	//	*EventHandlerClientToRuntimeMessage_Pong
	Message isEventHandlerClientToRuntimeMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type EventHandlerClientToRuntimeMessage_HandleResult struct {
	HandleResult *EventHandlerResponse `protobuf:"bytes,2,opt,name=handleResult,proto3,oneof"`
}

type EventHandlerClientToRuntimeMessage_Pong struct {
	Pong *services.Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}

type EventHandlerClientToRuntimeMessage_RegistrationRequest struct {
	RegistrationRequest *EventHandlerRegistrationRequest `protobuf:"bytes,1,opt,name=registrationRequest,proto3,oneof"`
}

type EventHandlerRegistrationRequest struct {
	CallContext    *services.ReverseCallArgumentsContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	ScopeId        *protobuf.Uuid                        `protobuf:"bytes,2,opt,name=scopeId,proto3" json:"scopeId,omitempty"`
	EventHandlerId *protobuf.Uuid                        `protobuf:"bytes,3,opt,name=eventHandlerId,proto3" json:"eventHandlerId,omitempty"`
	Types          []*artifacts.Artifact                 `protobuf:"bytes,4,rep,name=types,proto3" json:"types,omitempty"`
	Partitioned    bool                                  `protobuf:"varint,5,opt,name=partitioned,proto3" json:"partitioned,omitempty"`
	// contains filtered or unexported fields
}

type EventHandlerRegistrationResponse struct {
	Failure *protobuf.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

type EventHandlerResponse struct {
	CallContext *services.ReverseCallResponseContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	Failure     *ProcessorFailure                    `protobuf:"bytes,2,opt,name=failure,proto3" json:"failure,omitempty"` // If not set/empty - no failure
	// contains filtered or unexported fields
}

type EventHandlerRuntimeToClientMessage struct {

	// Types that are assignable to Message:
	//	*EventHandlerRuntimeToClientMessage_RegistrationResponse
	//	*EventHandlerRuntimeToClientMessage_HandleRequest
	//	*EventHandlerRuntimeToClientMessage_Ping
	Message isEventHandlerRuntimeToClientMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type EventHandlerRuntimeToClientMessage_HandleRequest struct {
	HandleRequest *HandleEventRequest `protobuf:"bytes,2,opt,name=handleRequest,proto3,oneof"`
}

type EventHandlerRuntimeToClientMessage_Ping struct {
	Ping *services.Ping `protobuf:"bytes,3,opt,name=ping,proto3,oneof"`
}

type EventHandlerRuntimeToClientMessage_RegistrationResponse struct {
	RegistrationResponse *EventHandlerRegistrationResponse `protobuf:"bytes,1,opt,name=registrationResponse,proto3,oneof"`
}

type EventHandlersClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (EventHandlers_ConnectClient, error)
}

type EventHandlersServer interface {
	Connect(EventHandlers_ConnectServer) error
	// contains filtered or unexported methods
}

type EventHandlers_ConnectClient interface {
	Send(*EventHandlerClientToRuntimeMessage) error
	Recv() (*EventHandlerRuntimeToClientMessage, error)
	grpc.ClientStream
}

type EventHandlers_ConnectServer interface {
	Send(*EventHandlerRuntimeToClientMessage) error
	Recv() (*EventHandlerClientToRuntimeMessage, error)
	grpc.ServerStream
}

type EventPropertyKeySelector struct {
	PropertyName string `protobuf:"bytes,1,opt,name=propertyName,proto3" json:"propertyName,omitempty"`
	// contains filtered or unexported fields
}

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

type FilterClientToRuntimeMessage struct {

	// Types that are assignable to Message:
	//	*FilterClientToRuntimeMessage_RegistrationRequest
	//	*FilterClientToRuntimeMessage_FilterResult
	//	*FilterClientToRuntimeMessage_Pong
	Message isFilterClientToRuntimeMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type FilterClientToRuntimeMessage_FilterResult struct {
	FilterResult *FilterResponse `protobuf:"bytes,2,opt,name=filterResult,proto3,oneof"`
}

type FilterClientToRuntimeMessage_Pong struct {
	Pong *services.Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}

type FilterClientToRuntimeMessage_RegistrationRequest struct {
	RegistrationRequest *FilterRegistrationRequest `protobuf:"bytes,1,opt,name=registrationRequest,proto3,oneof"`
}

type FilterEventRequest struct {
	CallContext          *services.ReverseCallRequestContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	Event                *events.CommittedEvent              `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	ScopeId              *protobuf.Uuid                      `protobuf:"bytes,3,opt,name=scopeId,proto3" json:"scopeId,omitempty"`
	RetryProcessingState *RetryProcessingState               `protobuf:"bytes,4,opt,name=retryProcessingState,proto3" json:"retryProcessingState,omitempty"`
	// contains filtered or unexported fields
}

type FilterRegistrationRequest struct {
	CallContext *services.ReverseCallArgumentsContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	ScopeId     *protobuf.Uuid                        `protobuf:"bytes,2,opt,name=scopeId,proto3" json:"scopeId,omitempty"`
	FilterId    *protobuf.Uuid                        `protobuf:"bytes,3,opt,name=filterId,proto3" json:"filterId,omitempty"`
	// contains filtered or unexported fields
}

type FilterRegistrationResponse struct {
	Failure *protobuf.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

type FilterResponse struct {
	CallContext *services.ReverseCallResponseContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	IsIncluded  bool                                 `protobuf:"varint,2,opt,name=isIncluded,proto3" json:"isIncluded,omitempty"`
	Failure     *ProcessorFailure                    `protobuf:"bytes,3,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

type FilterRuntimeToClientMessage struct {

	// Types that are assignable to Message:
	//	*FilterRuntimeToClientMessage_RegistrationResponse
	//	*FilterRuntimeToClientMessage_FilterRequest
	//	*FilterRuntimeToClientMessage_Ping
	Message isFilterRuntimeToClientMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type FilterRuntimeToClientMessage_FilterRequest struct {
	FilterRequest *FilterEventRequest `protobuf:"bytes,2,opt,name=filterRequest,proto3,oneof"`
}

type FilterRuntimeToClientMessage_Ping struct {
	Ping *services.Ping `protobuf:"bytes,3,opt,name=ping,proto3,oneof"`
}

type FilterRuntimeToClientMessage_RegistrationResponse struct {
	RegistrationResponse *FilterRegistrationResponse `protobuf:"bytes,1,opt,name=registrationResponse,proto3,oneof"`
}

type FiltersClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (Filters_ConnectClient, error)
	ConnectPartitioned(ctx context.Context, opts ...grpc.CallOption) (Filters_ConnectPartitionedClient, error)
	ConnectPublic(ctx context.Context, opts ...grpc.CallOption) (Filters_ConnectPublicClient, error)
}

type FiltersServer interface {
	Connect(Filters_ConnectServer) error
	ConnectPartitioned(Filters_ConnectPartitionedServer) error
	ConnectPublic(Filters_ConnectPublicServer) error
	// contains filtered or unexported methods
}

type Filters_ConnectClient interface {
	Send(*FilterClientToRuntimeMessage) error
	Recv() (*FilterRuntimeToClientMessage, error)
	grpc.ClientStream
}

type Filters_ConnectPartitionedClient interface {
	Send(*PartitionedFilterClientToRuntimeMessage) error
	Recv() (*FilterRuntimeToClientMessage, error)
	grpc.ClientStream
}

type Filters_ConnectPartitionedServer interface {
	Send(*FilterRuntimeToClientMessage) error
	Recv() (*PartitionedFilterClientToRuntimeMessage, error)
	grpc.ServerStream
}

type Filters_ConnectPublicClient interface {
	Send(*PublicFilterClientToRuntimeMessage) error
	Recv() (*FilterRuntimeToClientMessage, error)
	grpc.ClientStream
}

type Filters_ConnectPublicServer interface {
	Send(*FilterRuntimeToClientMessage) error
	Recv() (*PublicFilterClientToRuntimeMessage, error)
	grpc.ServerStream
}

type Filters_ConnectServer interface {
	Send(*FilterRuntimeToClientMessage) error
	Recv() (*FilterClientToRuntimeMessage, error)
	grpc.ServerStream
}

type HandleEventRequest struct {
	CallContext          *services.ReverseCallRequestContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	Event                *StreamEvent                        `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	RetryProcessingState *RetryProcessingState               `protobuf:"bytes,3,opt,name=retryProcessingState,proto3" json:"retryProcessingState,omitempty"`
	// contains filtered or unexported fields
}

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

type PartitionedFilterClientToRuntimeMessage struct {

	// Types that are assignable to Message:
	//	*PartitionedFilterClientToRuntimeMessage_RegistrationRequest
	//	*PartitionedFilterClientToRuntimeMessage_FilterResult
	//	*PartitionedFilterClientToRuntimeMessage_Pong
	Message isPartitionedFilterClientToRuntimeMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type PartitionedFilterClientToRuntimeMessage_FilterResult struct {
	FilterResult *PartitionedFilterResponse `protobuf:"bytes,2,opt,name=filterResult,proto3,oneof"`
}

type PartitionedFilterClientToRuntimeMessage_Pong struct {
	Pong *services.Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}

type PartitionedFilterClientToRuntimeMessage_RegistrationRequest struct {
	RegistrationRequest *PartitionedFilterRegistrationRequest `protobuf:"bytes,1,opt,name=registrationRequest,proto3,oneof"`
}

type PartitionedFilterRegistrationRequest struct {
	CallContext *services.ReverseCallArgumentsContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	ScopeId     *protobuf.Uuid                        `protobuf:"bytes,2,opt,name=scopeId,proto3" json:"scopeId,omitempty"`
	FilterId    *protobuf.Uuid                        `protobuf:"bytes,3,opt,name=filterId,proto3" json:"filterId,omitempty"`
	// contains filtered or unexported fields
}

type PartitionedFilterResponse struct {
	CallContext *services.ReverseCallResponseContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	IsIncluded  bool                                 `protobuf:"varint,2,opt,name=isIncluded,proto3" json:"isIncluded,omitempty"`
	PartitionId *protobuf.Uuid                       `protobuf:"bytes,3,opt,name=partitionId,proto3" json:"partitionId,omitempty"`
	Failure     *ProcessorFailure                    `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

type ProcessEventRequest struct {
	CallContext          *services.ReverseCallRequestContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	Event                *StreamEvent                        `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	RetryProcessingState *RetryProcessingState               `protobuf:"bytes,3,opt,name=retryProcessingState,proto3" json:"retryProcessingState,omitempty"`
	// contains filtered or unexported fields
}

type ProcessorClientToRuntimeMessage struct {

	// Types that are assignable to Message:
	//	*ProcessorClientToRuntimeMessage_RegistrationRequest
	//	*ProcessorClientToRuntimeMessage_ProcessingResult
	//	*ProcessorClientToRuntimeMessage_Pong
	Message isProcessorClientToRuntimeMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type ProcessorClientToRuntimeMessage_Pong struct {
	Pong *services.Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}

type ProcessorClientToRuntimeMessage_ProcessingResult struct {
	ProcessingResult *ProcessorResponse `protobuf:"bytes,2,opt,name=processingResult,proto3,oneof"`
}

type ProcessorClientToRuntimeMessage_RegistrationRequest struct {
	RegistrationRequest *ProcessorRegistrationRequest `protobuf:"bytes,1,opt,name=registrationRequest,proto3,oneof"`
}

type ProcessorFailure struct {
	Reason       string               `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	Retry        bool                 `protobuf:"varint,2,opt,name=retry,proto3" json:"retry,omitempty"`
	RetryTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=retryTimeout,proto3" json:"retryTimeout,omitempty"`
	// contains filtered or unexported fields
}

type ProcessorRegistrationRequest struct {
	CallContext    *services.ReverseCallArgumentsContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	ScopeId        *protobuf.Uuid                        `protobuf:"bytes,2,opt,name=scopeId,proto3" json:"scopeId,omitempty"`
	ProcessorId    *protobuf.Uuid                        `protobuf:"bytes,3,opt,name=processorId,proto3" json:"processorId,omitempty"`
	SourceStreamId *protobuf.Uuid                        `protobuf:"bytes,4,opt,name=sourceStreamId,proto3" json:"sourceStreamId,omitempty"`
	// contains filtered or unexported fields
}

type ProcessorRegistrationResponse struct {
	Failure *protobuf.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

type ProcessorResponse struct {
	CallContext *services.ReverseCallResponseContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	Failure     *ProcessorFailure                    `protobuf:"bytes,2,opt,name=failure,proto3" json:"failure,omitempty"` // If not set/empty - no failure
	// contains filtered or unexported fields
}

type ProcessorRuntimeToClientMessage struct {

	// Types that are assignable to Message:
	//	*ProcessorRuntimeToClientMessage_RegistrationResponse
	//	*ProcessorRuntimeToClientMessage_HandleRequest
	//	*ProcessorRuntimeToClientMessage_Ping
	Message isProcessorRuntimeToClientMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type ProcessorRuntimeToClientMessage_HandleRequest struct {
	HandleRequest *ProcessEventRequest `protobuf:"bytes,2,opt,name=handleRequest,proto3,oneof"`
}

type ProcessorRuntimeToClientMessage_Ping struct {
	Ping *services.Ping `protobuf:"bytes,3,opt,name=ping,proto3,oneof"`
}

type ProcessorRuntimeToClientMessage_RegistrationResponse struct {
	RegistrationResponse *ProcessorRegistrationResponse `protobuf:"bytes,1,opt,name=registrationResponse,proto3,oneof"`
}

type ProcessorsClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (Processors_ConnectClient, error)
}

type ProcessorsServer interface {
	Connect(Processors_ConnectServer) error
	// contains filtered or unexported methods
}

type Processors_ConnectClient interface {
	Send(*ProcessorClientToRuntimeMessage) error
	Recv() (*ProcessorRuntimeToClientMessage, error)
	grpc.ClientStream
}

type Processors_ConnectServer interface {
	Send(*ProcessorRuntimeToClientMessage) error
	Recv() (*ProcessorClientToRuntimeMessage, error)
	grpc.ServerStream
}

type ProjectionClientToRuntimeMessage struct {

	// Types that are assignable to Message:
	//	*ProjectionClientToRuntimeMessage_RegistrationRequest
	//	*ProjectionClientToRuntimeMessage_HandleResult
	//	*ProjectionClientToRuntimeMessage_Pong
	Message isProjectionClientToRuntimeMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type ProjectionClientToRuntimeMessage_HandleResult struct {
	HandleResult *ProjectionResponse `protobuf:"bytes,2,opt,name=handleResult,proto3,oneof"`
}

type ProjectionClientToRuntimeMessage_Pong struct {
	Pong *services.Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}

type ProjectionClientToRuntimeMessage_RegistrationRequest struct {
	RegistrationRequest *ProjectionRegistrationRequest `protobuf:"bytes,1,opt,name=registrationRequest,proto3,oneof"`
}

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

type ProjectionEventSelector struct {
	EventType *artifacts.Artifact `protobuf:"bytes,1,opt,name=eventType,proto3" json:"eventType,omitempty"`
	// Types that are assignable to Selector:
	//	*ProjectionEventSelector_EventSourceKeySelector
	//	*ProjectionEventSelector_PartitionKeySelector
	//	*ProjectionEventSelector_EventPropertyKeySelector
	Selector isProjectionEventSelector_Selector `protobuf_oneof:"Selector"`
	// contains filtered or unexported fields
}

type ProjectionEventSelector_EventPropertyKeySelector struct {
	EventPropertyKeySelector *EventPropertyKeySelector `protobuf:"bytes,4,opt,name=eventPropertyKeySelector,proto3,oneof"`
}

type ProjectionEventSelector_EventSourceKeySelector struct {
	EventSourceKeySelector *EventSourceIdKeySelector `protobuf:"bytes,2,opt,name=eventSourceKeySelector,proto3,oneof"`
}

type ProjectionEventSelector_PartitionKeySelector struct {
	PartitionKeySelector *PartitionIdKeySelector `protobuf:"bytes,3,opt,name=partitionKeySelector,proto3,oneof"`
}

type ProjectionRegistrationRequest struct {
	CallContext  *services.ReverseCallArgumentsContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	ScopeId      *protobuf.Uuid                        `protobuf:"bytes,2,opt,name=scopeId,proto3" json:"scopeId,omitempty"`
	ProjectionId *protobuf.Uuid                        `protobuf:"bytes,3,opt,name=projectionId,proto3" json:"projectionId,omitempty"`
	Events       []*ProjectionEventSelector            `protobuf:"bytes,4,rep,name=events,proto3" json:"events,omitempty"`
	InitialState string                                `protobuf:"bytes,5,opt,name=initialState,proto3" json:"initialState,omitempty"`
	// contains filtered or unexported fields
}

type ProjectionRegistrationResponse struct {
	Failure *protobuf.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

type ProjectionReplaceResponse struct {
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type ProjectionRequest struct {
	CallContext          *services.ReverseCallRequestContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	CurrentState         *projections.ProjectionCurrentState `protobuf:"bytes,2,opt,name=currentState,proto3" json:"currentState,omitempty"`
	Event                *StreamEvent                        `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	RetryProcessingState *RetryProcessingState               `protobuf:"bytes,4,opt,name=retryProcessingState,proto3" json:"retryProcessingState,omitempty"`
	// contains filtered or unexported fields
}

type ProjectionResponse struct {
	CallContext *services.ReverseCallResponseContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	// Types that are assignable to Response:
	//	*ProjectionResponse_Replace
	//	*ProjectionResponse_Delete
	Response isProjectionResponse_Response `protobuf_oneof:"Response"`
	Failure  *ProcessorFailure             `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"` // If not set/empty - no failure
	// contains filtered or unexported fields
}

type ProjectionResponse_Delete struct {
	Delete *ProjectionDeleteResponse `protobuf:"bytes,3,opt,name=delete,proto3,oneof"`
}

type ProjectionResponse_Replace struct {
	Replace *ProjectionReplaceResponse `protobuf:"bytes,2,opt,name=replace,proto3,oneof"`
}

type ProjectionRuntimeToClientMessage struct {

	// Types that are assignable to Message:
	//	*ProjectionRuntimeToClientMessage_RegistrationResponse
	//	*ProjectionRuntimeToClientMessage_HandleRequest
	//	*ProjectionRuntimeToClientMessage_Ping
	Message isProjectionRuntimeToClientMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type ProjectionRuntimeToClientMessage_HandleRequest struct {
	HandleRequest *ProjectionRequest `protobuf:"bytes,2,opt,name=handleRequest,proto3,oneof"`
}

type ProjectionRuntimeToClientMessage_Ping struct {
	Ping *services.Ping `protobuf:"bytes,3,opt,name=ping,proto3,oneof"`
}

type ProjectionRuntimeToClientMessage_RegistrationResponse struct {
	RegistrationResponse *ProjectionRegistrationResponse `protobuf:"bytes,1,opt,name=registrationResponse,proto3,oneof"`
}

type ProjectionsClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (Projections_ConnectClient, error)
}

type ProjectionsServer interface {
	Connect(Projections_ConnectServer) error
	// contains filtered or unexported methods
}

type Projections_ConnectClient interface {
	Send(*ProjectionClientToRuntimeMessage) error
	Recv() (*ProjectionRuntimeToClientMessage, error)
	grpc.ClientStream
}

type Projections_ConnectServer interface {
	Send(*ProjectionRuntimeToClientMessage) error
	Recv() (*ProjectionClientToRuntimeMessage, error)
	grpc.ServerStream
}

type PublicFilterClientToRuntimeMessage struct {

	// Types that are assignable to Message:
	//	*PublicFilterClientToRuntimeMessage_RegistrationRequest
	//	*PublicFilterClientToRuntimeMessage_FilterResult
	//	*PublicFilterClientToRuntimeMessage_Pong
	Message isPublicFilterClientToRuntimeMessage_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type PublicFilterClientToRuntimeMessage_FilterResult struct {
	FilterResult *PartitionedFilterResponse `protobuf:"bytes,2,opt,name=filterResult,proto3,oneof"`
}

type PublicFilterClientToRuntimeMessage_Pong struct {
	Pong *services.Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}

type PublicFilterClientToRuntimeMessage_RegistrationRequest struct {
	RegistrationRequest *PublicFilterRegistrationRequest `protobuf:"bytes,1,opt,name=registrationRequest,proto3,oneof"`
}

type PublicFilterRegistrationRequest struct {
	CallContext *services.ReverseCallArgumentsContext `protobuf:"bytes,1,opt,name=callContext,proto3" json:"callContext,omitempty"`
	FilterId    *protobuf.Uuid                        `protobuf:"bytes,2,opt,name=filterId,proto3" json:"filterId,omitempty"`
	// contains filtered or unexported fields
}

type RetryProcessingState struct {
	FailureReason string `protobuf:"bytes,1,opt,name=failureReason,proto3" json:"failureReason,omitempty"`
	RetryCount    uint32 `protobuf:"varint,2,opt,name=retryCount,proto3" json:"retryCount,omitempty"`
	// contains filtered or unexported fields
}

type StreamEvent struct {
	Event       *events.CommittedEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	PartitionId *protobuf.Uuid         `protobuf:"bytes,2,opt,name=partitionId,proto3" json:"partitionId,omitempty"`
	ScopeId     *protobuf.Uuid         `protobuf:"bytes,3,opt,name=scopeId,proto3" json:"scopeId,omitempty"`
	Partitioned bool                   `protobuf:"varint,4,opt,name=partitioned,proto3" json:"partitioned,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventHandlersServer struct {
}

type UnimplementedFiltersServer struct {
}

type UnimplementedProcessorsServer struct {
}

type UnimplementedProjectionsServer struct {
}

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

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

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

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