v1

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

type AckRequest struct {
	AckInfo *AckInfo `protobuf:"bytes,1,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// contains filtered or unexported fields
}

type AckResponse struct {
	AckStatus *AckStatus `protobuf:"bytes,1,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"`
	// contains filtered or unexported fields
}

type AckStatus struct {
	StatusCode AckStatus_StatusCode `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AckStatus_StatusCode int32

type DurableQueue struct {

	// Optional: Messages will by default be shared between all connections using the same OAuth 2.0 client
	CustomName string `protobuf:"bytes,1,opt,name=custom_name,json=customName,proto3" json:"custom_name,omitempty"`
	// contains filtered or unexported fields
}

type Identifier struct {
	SubscriptionIdentifier *v1.SubscriptionIdentifier `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Metadata struct {

	// The timestamp this event was generated
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Identity of the subscription this event was generated for.
	Identifier *Identifier `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// Information that must be included in the ack request to identify the event
	AckInfo *AckInfo `protobuf:"bytes,3,opt,name=ack_info,json=ackInfo,proto3" json:"ack_info,omitempty"`
	// True when this is not the first time the message has been sent
	IsRedelivered bool `protobuf:"varint,4,opt,name=is_redelivered,json=isRedelivered,proto3" json:"is_redelivered,omitempty"`
	// contains filtered or unexported fields
}

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

type StreamConfiguration struct {

	// Optional: Will use DurableQueue by default
	//
	// Types that are assignable to StreamType:
	//
	//	*StreamConfiguration_Regular
	//	*StreamConfiguration_DurableQueue
	StreamType isStreamConfiguration_StreamType `protobuf_oneof:"stream_type"`
	// Optional: By default, the client is required to send a ack message and will use a timeout of 30 seconds.
	//
	// Types that are assignable to AcknowledgeOption:
	//
	//	*StreamConfiguration_DisableExplicitAck
	//	*StreamConfiguration_CustomAckTimeout
	AcknowledgeOption isStreamConfiguration_AcknowledgeOption `protobuf_oneof:"acknowledge_option"`
	// Optional: By default, max 50 unacknowledged events may be in-flight
	// Must be between 1 and 200
	MaxInFlight uint32 `protobuf:"varint,5,opt,name=max_in_flight,json=maxInFlight,proto3" json:"max_in_flight,omitempty"`
	// Optional: By default, only new events will be included
	//
	// Types that are assignable to StartPosition:
	//
	//	*StreamConfiguration_StartAtNew
	//	*StreamConfiguration_StartAtId
	//	*StreamConfiguration_StartAtTimestamp
	//	*StreamConfiguration_StartAtOldestPossible
	StartPosition isStreamConfiguration_StartPosition `protobuf_oneof:"start_position"`
	// contains filtered or unexported fields
}

type StreamConfiguration_CustomAckTimeout struct {
	// Must be between 10 seconds and 10 minutes
	CustomAckTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=custom_ack_timeout,json=customAckTimeout,proto3,oneof"`
}

type StreamConfiguration_DisableExplicitAck struct {
	// Disable ack
	DisableExplicitAck *emptypb.Empty `protobuf:"bytes,3,opt,name=disable_explicit_ack,json=disableExplicitAck,proto3,oneof"`
}

type StreamConfiguration_DurableQueue struct {
	DurableQueue *DurableQueue `protobuf:"bytes,2,opt,name=durable_queue,json=durableQueue,proto3,oneof"`
}

type StreamConfiguration_Regular struct {
	Regular *RegularStream `protobuf:"bytes,1,opt,name=regular,proto3,oneof"`
}

type StreamConfiguration_StartAtId struct {
	// Will deliver events from the given ID
	StartAtId uint64 `protobuf:"varint,7,opt,name=start_at_id,json=startAtId,proto3,oneof"`
}

type StreamConfiguration_StartAtNew struct {
	// Will only deliver events generated after this subscription was started
	StartAtNew *emptypb.Empty `protobuf:"bytes,6,opt,name=start_at_new,json=startAtNew,proto3,oneof"`
}

type StreamConfiguration_StartAtOldestPossible struct {
	// Will deliver all available events
	StartAtOldestPossible *emptypb.Empty `protobuf:"bytes,9,opt,name=start_at_oldest_possible,json=startAtOldestPossible,proto3,oneof"`
}

type StreamConfiguration_StartAtTimestamp struct {
	// Will deliver events from the given timestamp
	StartAtTimestamp *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=start_at_timestamp,json=startAtTimestamp,proto3,oneof"`
}