eventv2

type EventServiceClient interface {
	// Stream Events
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	Stream(ctx context.Context, opts ...grpc.CallOption) (EventService_StreamClient, error)
	// Publish Event
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	Publish(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*PublishEventResponse, error)
}

type EventServiceServer interface {
	// Stream Events
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	Stream(EventService_StreamServer) error
	// Publish Event
	// buf:lint:ignore RPC_REQUEST_STANDARD_NAME
	// buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
	Publish(context.Context, *PublishEventRequest) (*PublishEventResponse, error)
}

type EventService_StreamClient interface {
	Send(*EventsStreamRequest) error
	Recv() (*EventsStreamResponse, error)
	grpc.ClientStream
}

type EventService_StreamServer interface {
	Send(*EventsStreamResponse) error
	Recv() (*EventsStreamRequest, error)
	grpc.ServerStream
}

type EventTarget struct {

	// Subscribe to events in a given collection.
	CollectionId *string `protobuf:"bytes,5,opt,name=collection_id,json=collectionId,proto3,oneof" json:"collection_id,omitempty"`
	// Subscribe to events in a given project.
	ProjectId *string `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3,oneof" json:"project_id,omitempty"`
	// Stream events to a specific layout.
	// Note: when specified, collection_id and project_id are implictly defined. If you choose
	// to define them, you they _must_ match the layout.
	LayoutId *string `protobuf:"bytes,1,opt,name=layout_id,json=layoutId,proto3,oneof" json:"layout_id,omitempty"`
	// contains filtered or unexported fields
}

type EventsStreamError struct {

	// The GRPC error code for the event.
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// A mesasage indicating what the error is.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type EventsStreamMessageType int32

type EventsStreamReconnectRequest struct {

	// Whether the access token needs to be refreshed before reconnecting.
	Reauthenticate bool `protobuf:"varint,1,opt,name=reauthenticate,proto3" json:"reauthenticate,omitempty"`
	// A timestamp indicating when the connection should be reconnected by.
	// If you're maintaining multiple connections, you should reconnect at a random interval within this time range.
	BeforeTimestamp string `protobuf:"bytes,2,opt,name=before_timestamp,json=beforeTimestamp,proto3" json:"before_timestamp,omitempty"`
	// contains filtered or unexported fields
}

type EventsStreamRequest struct {

	// Optional value to tag any return values with. This can be any string-based value
	// that your are able to track.
	CorrelationId *string `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3,oneof" json:"correlation_id,omitempty"`
	// Types that are assignable to EventPayload:
	//
	//	*EventsStreamRequest_Subscribe
	//	*EventsStreamRequest_Unsubscribe
	//	*EventsStreamRequest_Publish
	//	*EventsStreamRequest_Ping
	EventPayload isEventsStreamRequest_EventPayload `protobuf_oneof:"event_payload"`
	// contains filtered or unexported fields
}

type EventsStreamRequest_Ping struct {
	// Initiate a ping-pong message.
	Ping string `protobuf:"bytes,103,opt,name=ping,proto3,oneof"`
}

type EventsStreamRequest_Publish struct {
	// Publish a new event.
	Publish *PublishEventRequest `protobuf:"bytes,102,opt,name=publish,proto3,oneof"`
}

type EventsStreamRequest_Subscribe struct {
	// Subscribe to a new event.
	Subscribe *SubscribePayload `protobuf:"bytes,100,opt,name=subscribe,proto3,oneof"`
}

type EventsStreamRequest_Unsubscribe struct {
	// Unsubscribe from an event.
	Unsubscribe *SubscribePayload `protobuf:"bytes,101,opt,name=unsubscribe,proto3,oneof"`
}

type EventsStreamResponse struct {

	// Optional value to tag any return values with.
	// Correlation ID should be used to correlate requests sent down the socket,
	// enabling you to tie a `PUBLISH` to a `PUBLISHED“
	CorrelationId *string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3,oneof" json:"correlation_id,omitempty"`
	// Optional session id
	// This is set by sending the `SessionId` header for any HTTP requests
	// and the `sessionId` query parameter for websockets.
	SessionId *string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3,oneof" json:"session_id,omitempty"`
	// Types that are assignable to EventPayload:
	//
	//	*EventsStreamResponse_Event
	//	*EventsStreamResponse_Pong
	//	*EventsStreamResponse_Error
	//	*EventsStreamResponse_Subscribed
	//	*EventsStreamResponse_Unsubscribed
	//	*EventsStreamResponse_Published
	//	*EventsStreamResponse_ReconnectBefore
	EventPayload isEventsStreamResponse_EventPayload `protobuf_oneof:"event_payload"`
	// contains filtered or unexported fields
}

type EventsStreamResponse_Error struct {
	// Non-blocking streaming error
	Error *EventsStreamError `protobuf:"bytes,201,opt,name=error,proto3,oneof"`
}

type EventsStreamResponse_Event struct {
	// Custom event emitted
	Event *PublishEventResponse `protobuf:"bytes,100,opt,name=event,proto3,oneof"`
}

type EventsStreamResponse_Pong struct {
	// Ping payload
	Pong string `protobuf:"bytes,200,opt,name=pong,proto3,oneof"`
}

type EventsStreamResponse_Published struct {
	// Publish a new event.
	Published *PublishEventResponse `protobuf:"bytes,204,opt,name=published,proto3,oneof"`
}

type EventsStreamResponse_ReconnectBefore struct {
	// Inform the client should reoconnect before a timestamp.
	ReconnectBefore *EventsStreamReconnectRequest `protobuf:"bytes,205,opt,name=reconnect_before,json=reconnectBefore,proto3,oneof"`
}

type EventsStreamResponse_Subscribed struct {
	// Subscribe to a new event.
	Subscribed *SubscribePayload `protobuf:"bytes,202,opt,name=subscribed,proto3,oneof"`
}

type EventsStreamResponse_Unsubscribed struct {
	// Unsubscribe from an event.
	Unsubscribed *SubscribePayload `protobuf:"bytes,203,opt,name=unsubscribed,proto3,oneof"`
}

type PublishEventRequest struct {

	// Name of the event.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value of the event. This can be a free-form value which we do not inspect.
	Payload *structpb.Struct `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// Metadata associated with the publishing of the event.
	// Typically this is information about _why_ the event happened. Use `payload` for
	// _what_ the event is.
	RequestMetadata *structpb.Value `protobuf:"bytes,4,opt,name=request_metadata,json=requestMetadata,proto3,oneof" json:"request_metadata,omitempty"`
	// Scope the event to a specific target
	Target *EventTarget `protobuf:"bytes,3,opt,name=target,proto3,oneof" json:"target,omitempty"`
	// contains filtered or unexported fields
}

type PublishEventResponse struct {

	// Name of the event.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value of the event.
	Payload *structpb.Struct `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// Custom scoping parameters.
	Target *EventTarget `protobuf:"bytes,3,opt,name=target,proto3,oneof" json:"target,omitempty"`
	// Metadata associated with the publishing of the event
	RequestMetadata *structpb.Value `protobuf:"bytes,4,opt,name=request_metadata,json=requestMetadata,proto3,oneof" json:"request_metadata,omitempty"`
	// Internal ID of the event.
	Id string `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type SubscribePayload struct {

	// Event name to subscribe to for custom events.
	// This can be a wildcard `my_service:*` or multiple events `my_event|my_other_event`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The target to subscribe to.
	Target *EventTarget `protobuf:"bytes,2,opt,name=target,proto3,oneof" json:"target,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventServiceServer struct {
}

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