durablepb

type JournalEntry struct {

	// Types that are assignable to Entry:
	//	*JournalEntry_Step
	//	*JournalEntry_Signal
	Entry isJournalEntry_Entry `protobuf_oneof:"entry"`
	// contains filtered or unexported fields
}

type JournalEntry_Signal struct {
	Signal *SignalEntry `protobuf:"bytes,2,opt,name=signal,proto3,oneof"`
}

type JournalEntry_Step struct {
	Step *StepEntry `protobuf:"bytes,1,opt,name=step,proto3,oneof"`
}

type SignalEntry struct {

	// signal_id is the step_id of the waiting step this payload completes.
	SignalId string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// payload is the JSON-encoded result delivered by CompleteStep.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// sent_at_ns is Unix time in nanoseconds when CompleteStep was called.
	SentAtNs int64 `protobuf:"varint,3,opt,name=sent_at_ns,json=sentAtNs,proto3" json:"sent_at_ns,omitempty"`
	// contains filtered or unexported fields
}

type StepEntry struct {

	// step_id is the caller-supplied, run-scoped identifier (durable.StepRecord.StepID).
	StepId string `protobuf:"bytes,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// status is the lifecycle state of this step.
	Status StepStatus `protobuf:"varint,3,opt,name=status,proto3,enum=durablepb.StepStatus" json:"status,omitempty"`
	// result is the JSON-marshalled output of a completed step.
	// Empty for waiting/failed entries.
	Result []byte `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	// error is the serialised error string for a failed step.
	Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// panic_trace holds the recovered panic value and stack (if the step panicked).
	PanicTrace string `protobuf:"bytes,6,opt,name=panic_trace,json=panicTrace,proto3" json:"panic_trace,omitempty"`
	// version is the WithStepVersion string for this checkpoint. Empty when
	// the caller did not set a version.
	Version string `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"`
	// started_at_ns is Unix time in nanoseconds when the step function was invoked.
	StartedAtNs int64 `protobuf:"varint,8,opt,name=started_at_ns,json=startedAtNs,proto3" json:"started_at_ns,omitempty"`
	// completed_at_ns is Unix time in nanoseconds when the step reached a terminal state.
	// Zero for waiting entries that have not yet completed.
	CompletedAtNs int64 `protobuf:"varint,9,opt,name=completed_at_ns,json=completedAtNs,proto3" json:"completed_at_ns,omitempty"`
	// input is the JSON-marshalled step input (RunStep's in).
	Input []byte `protobuf:"bytes,10,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type StepStatus int32