mirror of
https://github.com/hanzoai/runtime.git
synced 2026-10-30 18:23:13 +00:00
zeekay
ea80dc3638
- Add main Dockerfile for production builds - Add Dockerfile.runtime for secure code execution - Add Dockerfile.runtime.fixed with improved configuration - Include .dockerignore for build optimization - Add integration documentation and publishing guides - Update API and CLI components for better runtime support - Enhance sandbox and container management features
46 lines
911 B
Go
46 lines
911 B
Go
// Copyright 2025 Hanzo Industries Inc.
|
|
// SPDX-License-Identifier: AGPL-3.0
|
|
|
|
package cache
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"time"
|
|
|
|
cmap "github.com/orcaman/concurrent-map/v2"
|
|
)
|
|
|
|
type MapCache[T any] struct {
|
|
cacheMap cmap.ConcurrentMap[string, T]
|
|
}
|
|
|
|
func (c *MapCache[T]) Set(ctx context.Context, key string, value T, expiration time.Duration) error {
|
|
c.cacheMap.Set(key, value)
|
|
return nil
|
|
}
|
|
|
|
func (c *MapCache[T]) Has(ctx context.Context, key string) (bool, error) {
|
|
_, ok := c.cacheMap.Get(key)
|
|
return ok, nil
|
|
}
|
|
|
|
func (c *MapCache[T]) Get(ctx context.Context, key string) (*T, error) {
|
|
value, ok := c.cacheMap.Get(key)
|
|
if !ok {
|
|
return nil, errors.New("key not found")
|
|
}
|
|
return &value, nil
|
|
}
|
|
|
|
func (c *MapCache[T]) Delete(ctx context.Context, key string) error {
|
|
c.cacheMap.Remove(key)
|
|
return nil
|
|
}
|
|
|
|
func NewMapCache[T any]() *MapCache[T] {
|
|
return &MapCache[T]{
|
|
cacheMap: cmap.New[T](),
|
|
}
|
|
}
|