eventbusv1

type AckPolicy int32

type AckRequest struct {

	// ack_token is the opaque acknowledgement token from Message.ack_token.
	AckToken string `protobuf:"bytes,1,opt,name=ack_token,json=ackToken,proto3" json:"ack_token,omitempty"`
	// broker_ref names the broker module instance to dispatch this ack through.
	// Required for routing via RuntimeBroker; the step factory uses this to look up
	// the registered broker runtime + connection.
	BrokerRef string `protobuf:"bytes,2,opt,name=broker_ref,json=brokerRef,proto3" json:"broker_ref,omitempty"`
	// contains filtered or unexported fields
}

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

type ClusterConfig struct {

	// provider selects the message-broker backend: "nats" | "kafka" | "kinesis".
	Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
	// deploy_target selects the deployment platform:
	// "digitalocean.app_platform" | "aws.ecs" | "aws.eks" | "kubernetes" | etc.
	DeployTarget string `protobuf:"bytes,2,opt,name=deploy_target,json=deployTarget,proto3" json:"deploy_target,omitempty"`
	// version is the broker version to deploy (e.g. "2.10" for NATS).
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// replicas is the number of broker replicas.
	Replicas int32 `protobuf:"varint,4,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// jetstream holds NATS JetStream-specific configuration; ignored for other providers.
	Jetstream *JetStreamConfig `protobuf:"bytes,5,opt,name=jetstream,proto3" json:"jetstream,omitempty"`
	// kafka holds Kafka-specific cluster configuration; ignored for other providers.
	Kafka *KafkaConfig `protobuf:"bytes,6,opt,name=kafka,proto3" json:"kafka,omitempty"`
	// kinesis holds Kinesis-specific configuration; ignored for other providers.
	Kinesis *KinesisConfig `protobuf:"bytes,7,opt,name=kinesis,proto3" json:"kinesis,omitempty"`
	// limits sets compute/storage resource limits for the cluster containers.
	Limits *ResourceLimits `protobuf:"bytes,8,opt,name=limits,proto3" json:"limits,omitempty"`
	// dsn is the provider-specific connection string for the runtime broker:
	//   - provider="pgchannel": Postgres DSN (required).
	//   - provider="nats":      NATS URL (e.g., "nats://host:4222"); when empty
	//     falls back to env-resolved URIs in busURIRegistry
	//     (legacy NATS_URL / EVENTBUS_<NAME>_URI flow).
	//   - other providers:      ignored.
	Dsn string `protobuf:"bytes,10,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// poll_interval is the polling fallback interval for the pg-backed provider
	// (Go duration string, default "1s"). Ignored for non-pgchannel providers.
	PollInterval string `protobuf:"bytes,11,opt,name=poll_interval,json=pollInterval,proto3" json:"poll_interval,omitempty"`
	// broker_target is the broker deployment target. Replaces deploy_target's
	// role for non-IaC providers. Valid values: "in_process" (pgchannel only),
	// or any existing deploy_target value for IaC-managed providers (NATS, etc.).
	BrokerTarget string `protobuf:"bytes,12,opt,name=broker_target,json=brokerTarget,proto3" json:"broker_target,omitempty"`
	// max_conns is the pgxpool MaxConns ceiling for the pg-backed provider
	// (default 16). Each Subscribe holds 2 connections persistently (advisory
	// lock + LISTEN); for N consumers the recommended setting is >= 2*N + 4
	// to leave headroom for Publish/Ack/Ensure transients. Ignored for
	// non-pgchannel providers.
	MaxConns int32 `protobuf:"varint,13,opt,name=max_conns,json=maxConns,proto3" json:"max_conns,omitempty"`
	// contains filtered or unexported fields
}

type ConsumeRequest struct {

	// consumer is the durable consumer name to pull from.
	Consumer string `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// batch_size is the maximum number of messages to return in one call.
	BatchSize int32 `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// max_wait is the maximum time to block waiting for messages.
	MaxWait *durationpb.Duration `protobuf:"bytes,3,opt,name=max_wait,json=maxWait,proto3" json:"max_wait,omitempty"`
	// broker_ref names the broker module instance to dispatch this consume through.
	// Required for routing via RuntimeBroker; the step factory uses this to look up
	// the registered broker runtime + connection.
	BrokerRef string `protobuf:"bytes,4,opt,name=broker_ref,json=brokerRef,proto3" json:"broker_ref,omitempty"`
	// contains filtered or unexported fields
}

type ConsumeResponse struct {

	// messages contains the delivered messages (up to batch_size).
	Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

type ConsumerConfig struct {

	// name is the durable consumer name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// stream_name is the stream this consumer attaches to.
	StreamName string `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// filter_subject narrows delivery to messages matching this subject pattern.
	FilterSubject string `protobuf:"bytes,3,opt,name=filter_subject,json=filterSubject,proto3" json:"filter_subject,omitempty"`
	// deliver_policy controls which messages are delivered on first attach.
	DeliverPolicy DeliverPolicy `` /* 148-byte string literal not displayed */
	// ack_policy controls how acknowledgements are required.
	AckPolicy AckPolicy `` /* 132-byte string literal not displayed */
	// max_deliver is the maximum number of delivery attempts before NACKing (0 = unlimited).
	MaxDeliver int32 `protobuf:"varint,6,opt,name=max_deliver,json=maxDeliver,proto3" json:"max_deliver,omitempty"`
	// broker_ref names the broker module instance this consumer binds to.
	// Required for runtime routing through RuntimeBroker; validated by the
	// consumerModule at Start time (not proto-required to keep wire format compatible).
	BrokerRef string `protobuf:"bytes,10,opt,name=broker_ref,json=brokerRef,proto3" json:"broker_ref,omitempty"`
	// contains filtered or unexported fields
}

type DeliverPolicy int32

type JetStreamConfig struct {

	// enabled activates JetStream on the NATS cluster (required for durability).
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// max_storage_bytes caps total on-disk storage for all streams (0 = unlimited).
	MaxStorageBytes int64 `protobuf:"varint,2,opt,name=max_storage_bytes,json=maxStorageBytes,proto3" json:"max_storage_bytes,omitempty"`
	// max_memory_bytes caps in-memory storage (0 = unlimited).
	MaxMemoryBytes int64 `protobuf:"varint,3,opt,name=max_memory_bytes,json=maxMemoryBytes,proto3" json:"max_memory_bytes,omitempty"`
	// max_age is the default maximum age for messages across all streams.
	MaxAge *durationpb.Duration `protobuf:"bytes,4,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"`
	// contains filtered or unexported fields
}

type KafkaConfig struct {

	// bootstrap_servers is the initial broker address list (comma-separated).
	// Used when connecting to an existing Kafka cluster rather than provisioning one.
	BootstrapServers string `protobuf:"bytes,1,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	// security_protocol specifies the protocol for client-broker communication.
	SecurityProtocol KafkaSecurityProtocol `` /* 165-byte string literal not displayed */
	// sasl_mechanism for SASL authentication.
	SaslMechanism KafkaSaslMechanism `` /* 153-byte string literal not displayed */
	// default_replication_factor for new topics (0 = use broker default).
	DefaultReplicationFactor int32 `` /* 136-byte string literal not displayed */
	// min_insync_replicas is the minimum number of in-sync replicas required for acks.
	MinInsyncReplicas int32 `protobuf:"varint,5,opt,name=min_insync_replicas,json=minInsyncReplicas,proto3" json:"min_insync_replicas,omitempty"`
	// contains filtered or unexported fields
}

type KafkaSaslMechanism int32

type KafkaSecurityProtocol int32

type KinesisConfig struct {

	// region is the AWS region for the Kinesis stream (e.g. "us-east-1").
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// shard_count is the initial number of shards (throughput units).
	ShardCount int32 `protobuf:"varint,2,opt,name=shard_count,json=shardCount,proto3" json:"shard_count,omitempty"`
	// retention_period_hours is the message retention window (24–8760 hours).
	RetentionPeriodHours int32 `protobuf:"varint,3,opt,name=retention_period_hours,json=retentionPeriodHours,proto3" json:"retention_period_hours,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {

	// subject is the NATS subject (or Kafka topic/partition key) the message was published on.
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	// payload is the raw message bytes.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// headers are key/value metadata attached to the message.
	Headers map[string]string `` /* 141-byte string literal not displayed */
	// sequence is the stream sequence number assigned by the broker.
	Sequence string `protobuf:"bytes,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// published_at is the broker-assigned publish timestamp (RFC3339).
	PublishedAt string `protobuf:"bytes,5,opt,name=published_at,json=publishedAt,proto3" json:"published_at,omitempty"`
	// ack_token is the opaque token used to acknowledge this message via step.eventbus.ack.
	AckToken string `protobuf:"bytes,6,opt,name=ack_token,json=ackToken,proto3" json:"ack_token,omitempty"`
	// contains filtered or unexported fields
}

type PublishRequest struct {

	// subject is the NATS subject (or Kafka topic) to publish to.
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	// payload is the raw message bytes.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// headers are optional key/value metadata attached to the message.
	Headers map[string]string `` /* 141-byte string literal not displayed */
	// correlation_id is an opaque identifier for request/reply correlation or tracing.
	CorrelationId string `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	// broker_ref names the broker module instance to dispatch this publish through.
	// Required for routing via RuntimeBroker; the step factory uses this to look up
	// the registered broker runtime + connection.
	BrokerRef string `protobuf:"bytes,5,opt,name=broker_ref,json=brokerRef,proto3" json:"broker_ref,omitempty"`
	// contains filtered or unexported fields
}

type PublishResponse struct {

	// sequence is the JetStream stream sequence number; empty for non-JetStream brokers.
	Sequence string `protobuf:"bytes,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// acked_at is the timestamp when the broker acknowledged the message (RFC3339).
	AckedAt string `protobuf:"bytes,2,opt,name=acked_at,json=ackedAt,proto3" json:"acked_at,omitempty"`
	// contains filtered or unexported fields
}

type ResourceLimits struct {

	// cpu is the CPU limit in Kubernetes notation (e.g. "500m", "2").
	Cpu string `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// memory is the memory limit (e.g. "512Mi", "2Gi").
	Memory string `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	// storage is the persistent-volume size (e.g. "10Gi").
	Storage string `protobuf:"bytes,3,opt,name=storage,proto3" json:"storage,omitempty"`
	// contains filtered or unexported fields
}

type RetentionPolicy int32

type StreamConfig struct {

	// name is the stream name (e.g. "BMW_FULFILLMENT").
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// subjects lists the NATS subject filter patterns bound to this stream.
	Subjects []string `protobuf:"bytes,2,rep,name=subjects,proto3" json:"subjects,omitempty"`
	// retention_policy controls message retention semantics.
	RetentionPolicy RetentionPolicy `` /* 156-byte string literal not displayed */
	// num_replicas is the number of stream replicas within the cluster.
	NumReplicas int32 `protobuf:"varint,4,opt,name=num_replicas,json=numReplicas,proto3" json:"num_replicas,omitempty"`
	// max_bytes caps total on-disk storage for this stream (0 = unlimited).
	MaxBytes int64 `protobuf:"varint,5,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
	// max_age is the maximum age for messages in this stream.
	MaxAge *durationpb.Duration `protobuf:"bytes,6,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"`
	// ack_wait is the default acknowledgement deadline for consumers on this stream.
	AckWait *durationpb.Duration `protobuf:"bytes,7,opt,name=ack_wait,json=ackWait,proto3" json:"ack_wait,omitempty"`
	// broker_ref names the broker module instance this stream binds to.
	// Required for runtime routing through RuntimeBroker; validated by the
	// streamModule at Start time (not proto-required to keep wire format compatible).
	BrokerRef string `protobuf:"bytes,10,opt,name=broker_ref,json=brokerRef,proto3" json:"broker_ref,omitempty"`
	// contains filtered or unexported fields
}