Method EncodePersistedObject

core/changeset.go:331–352

(ctx context.Context, cache dagql.PersistedObjectCache)

}

func (ch *Changeset) EncodePersistedObject(ctx context.Context, cache dagql.PersistedObjectCache) (dagql.PersistedObjectEncoding, error) {
	_ = ctx
	if ch == nil {
		return dagql.PersistedObjectEncoding{}, fmt.Errorf("encode persisted changeset: nil changeset")
	}
	beforeID, err := encodePersistedObjectRef(cache, ch.Before, "changeset before")
	if err != nil {
		return dagql.PersistedObjectEncoding{}, err
	}
	afterID, err := encodePersistedObjectRef(cache, ch.After, "changeset after")
	if err != nil {
		return dagql.PersistedObjectEncoding{}, err
	}
	payload, err := json.Marshal(persistedChangesetPayload{
		BeforeResultID: beforeID,
		AfterResultID:  afterID,
	})
	if err != nil {
		return dagql.PersistedObjectEncoding{}, fmt.Errorf("marshal persisted changeset payload: %w", err)
	}
	return encodePersistedObjectRawJSON(payload), nil
}

func (*Changeset) DecodePersistedObject(
	ctx context.Context,