Method EncodePersistedObject

core/cache.go:307–352

(ctx context.Context, persistedCache dagql.PersistedObjectCache)

}

func (cache *CacheVolume) EncodePersistedObject(ctx context.Context, persistedCache dagql.PersistedObjectCache) (dagql.PersistedObjectEncoding, error) {
	_ = ctx
	if cache == nil {
		return dagql.PersistedObjectEncoding{}, fmt.Errorf("encode persisted cache volume: nil cache volume")
	}
	var sourceResultID uint64
	if cache.Source.Valid {
		encoded, err := encodePersistedObjectRef(persistedCache, cache.Source.Value, "cache volume source")
		if err != nil {
			return dagql.PersistedObjectEncoding{}, err
		}
		sourceResultID = encoded
	}
	cache.mu.Lock()
	selector := cache.selector
	if selector == "" {
		selector = "/"
	}
	snapshotID := cache.snapshotID
	var snapshotLinks []dagql.PersistedSnapshotRefLink
	if cache.snapshot != nil {
		snapshotID = cache.snapshot.SnapshotID()
	}
	if snapshotID != "" {
		snapshotLinks = []dagql.PersistedSnapshotRefLink{{
			RefKey: snapshotID,
			Role:   "snapshot",
		}}
	}
	cache.mu.Unlock()
	payload, err := json.Marshal(persistedCacheVolumePayload{
		Key:            cache.Key,
		Namespace:      cache.Namespace,
		SourceResultID: sourceResultID,
		Sharing:        cache.Sharing,
		Owner:          cache.Owner,
		Selector:       selector,
	})
	if err != nil {
		return dagql.PersistedObjectEncoding{}, fmt.Errorf("marshal persisted cache volume payload: %w", err)
	}
	return dagql.PersistedObjectEncoding{
		JSON:          payload,
		SnapshotLinks: snapshotLinks,
	}, nil
}

func (cache *CacheVolume) lockKey() (string, error) {
	if cache == nil {