wideevents

type NamespaceLifecyclePayload struct {
	Phase       string
	Namespace   string
	NamespaceID string
	Details     map[string]any
}

type Payload interface {
	// EventName is the stable name of the event type. It becomes the log record's event name so
	// events are easy to trace/grep by type.
	EventName() string
	// Attributes returns the event's fields as OTEL log key-values.
	Attributes() []log.KeyValue
}

type ReplicationLifecyclePayload struct {
	Phase    ReplicationPhase
	TaskType string
	Shard    int32
	// task identity + cross-phase join key: (namespace_id, workflow_id, run_id, transition_count, task_type)
	Namespace       string
	NamespaceID     string
	WorkflowID      string
	RunID           string
	FailoverVersion int64
	TransitionCount int64
	// parent info: populated at every phase where mutable state is in hand (sent + applied) when
	// this workflow is itself a child. Only the child->parent direction is emitted (a child points
	// at its parent); the parent->children direction is intentionally not recorded here.
	ParentWorkflowID  string
	ParentRunID       string
	ParentInitiatedID int64
	Details           map[string]any
	// sent-only
	NewRunID string
	// SourceTaskID is the sender's replication-queue task id for this event, recorded so a "sent"
	// event can be correlated with the source cluster's replication queue.
	SourceTaskID int64
	IsFirstSync  bool
	FirstEventID int64
	NextEventID  int64
	// received-only
	Attempt int32
	// event_version_history is the (event_id, version) branch. It is emitted on executing (from the
	// task) and applied (from the resulting mutable state); the version disambiguates which history
	// branch the events are on.
	EventVersionHistory []VersionHistoryEntry
	// applied-only: post-apply mutable-state SUMMARY (no blob)
	State               string
	Status              string
	AppliedNextEventID  int64
	TransitionHistory   []VersionedTransitionEntry
	LastEventID         int64
	LastEventVersion    int64
	Outcome             string
	Error               string
	NewExecutionRunID   string
	ResetRunID          string
	SignalCount         int64
	ActivityCount       int64
	UserTimerCount      int64
	ChildExecutionCount int64
	UpdateCount         int64
}

type ReplicationPhase string

type VersionHistoryEntry struct {
	EventID int64 `json:"event_id"`
	Version int64 `json:"version"`
}

type VersionedTransitionEntry struct {
	FailoverVersion int64 `json:"failover_version"`
	TransitionCount int64 `json:"transition_count"`
}