Interface EventLog

internal/controller/executor/eventlog.go:27–45

EventLog is the persistent, append-only record of all actions taken in an exec. Every entry is an atomic step: replaying the log in order brings the executor back to a consistent state from which execution can resume.

// exec. Every entry is an atomic step: replaying the log in order brings
// the executor back to a consistent state from which execution can resume.
type EventLog interface {
	// Append adds a conversation event to the end of the log.
	Append(ctx context.Context, event *proto.ConversationEvent) (int32, error)

	// AppendExec adds an execution event to the end of the log.
	AppendExec(ctx context.Context, event *proto.ExecutionEvent) error

	// Events returns all events for the conversation.
	Events(ctx context.Context, conversationID string) ([]*proto.ConversationEvent, error)

	// ExecEvents returns all events for a specific execution ID.
	ExecEvents(ctx context.Context, execID string) ([]*proto.ExecutionEvent, error)

	// DeleteEvents deletes all events for a specific conversation ID.
	DeleteEvents(ctx context.Context, conversationID string) error

	// Close releases the underlying resources and closes the log.
	Close() error
}

var marshalOpts = protojson.MarshalOptions{UseProtoNames: true}
var unmarshalOpts = protojson.UnmarshalOptions{DiscardUnknown: true}