common

type LeasePolicy struct {

	// base_lease:
	// Initial lease duration for an attempt (L_base).
	// The attempt starts with this much time before timing out, unless extended.
	BaseLease *durationpb.Duration `protobuf:"bytes,1,opt,name=base_lease,json=baseLease,proto3" json:"base_lease,omitempty"`
	// max_extension:
	// Maximum additional time beyond base_lease that an attempt may obtain via
	// heartbeats (L_maxExt).
	//
	// Effective per-attempt cap:
	//
	//	base_lease + max_extension
	MaxExtension *durationpb.Duration `protobuf:"bytes,2,opt,name=max_extension,json=maxExtension,proto3" json:"max_extension,omitempty"`
	// heartbeat_timeout:
	// Maximum allowed gap between heartbeats (H).
	// If zero/unset, heartbeat-based timeout is disabled.
	HeartbeatTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" json:"heartbeat_timeout,omitempty"`
	// extend_step:
	// Amount of time to extend the lease by when a heartbeat is received,
	// until max_extension is exhausted.
	//
	// Example:
	//
	//	base_lease = 3s
	//	max_extension = 10s
	//	extend_step = 2s
	//
	// The attempt can slide its lease by 2s increments up to ~13s total.
	ExtendStep *durationpb.Duration `protobuf:"bytes,4,opt,name=extend_step,json=extendStep,proto3" json:"extend_step,omitempty"`
	// contains filtered or unexported fields
}

type Payload struct {

	// metadata: Custom key-value pairs for message routing, filtering, and tracking.
	// Common uses: correlation IDs, trace context, source system, user ID, tenant ID.
	// These values are indexed and can be queried without deserializing the data field.
	Metadata map[string]*structpb.Value `` /* 143-byte string literal not displayed */
	// data: The actual message payload as structured data (JSON, Protobuf, etc.).
	// This is your business data - orders, events, tasks, notifications, etc.
	// Stored as google.protobuf.Struct for flexibility across different data formats.
	Data *structpb.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// content_type: MIME type indicating the data format.
	// Examples: "application/json", "application/xml", "text/plain", "application/protobuf"
	// Used for automatic deserialization and processing by workers.
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// schema_id: Reference to a registered schema for validation.
	// If provided, ChronoQueue validates the data against this schema before accepting the message.
	// Example: "order.created.v1", "user.profile.v2"
	// Use RegisterSchema API to define schemas.
	SchemaId string `protobuf:"bytes,4,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	// schema_version: Version number of the schema to use.
	// Allows schema evolution while maintaining backward compatibility.
	// If omitted, uses the latest active version of schema_id.
	SchemaVersion int32 `protobuf:"varint,5,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// contains filtered or unexported fields
}