metadatadb

type Backend interface {
	// Apply applies one or more write operations to the given namespace.
	Apply(ctx context.Context, namespace string, ops ...Op) error
	// Query executes a read query and unmarshals the result into target.
	// Target must be a pointer to the expected result type.
	Query(ctx context.Context, namespace string, q ReadOp, target any) error
	// Flush forces pending state to be persisted for the given namespace.
	Flush(ctx context.Context, namespace string) error
	// Close shuts down the backend, flushing any pending state.
	Close(ctx context.Context) error
}

type Factory[Config any, B Backend] func(ctx context.Context, config Config) (B, error)

type Int struct {
	// contains filtered or unexported fields
}

type IntAdd struct {
	Key   string
	Delta int64
}

type IntDiv struct {
	Key     string
	Divisor int64
}

type IntGet struct{ Key string }

type IntMap[K comparable] struct {
	// contains filtered or unexported fields
}

type IntMapAdd struct {
	Key    string
	MapKey any
	Delta  int64
}

type IntMapDelete struct {
	Key    string
	MapKey any
}

type IntMapDiv struct {
	Key     string
	MapKey  any
	Divisor int64
}

type IntMapEntries struct{ Key string }

type IntMapGet struct {
	Key    string
	MapKey any
}

type IntMapKeys struct{ Key string }

type IntMapMul struct {
	Key    string
	MapKey any
	Factor int64
}

type IntMapSet struct {
	Key    string
	MapKey any
	Value  int64
}

type IntMul struct {
	Key    string
	Factor int64
}

type IntSet struct {
	Key   string
	Value int64
}

type List[V any] struct {
	// contains filtered or unexported fields
}

type ListAppend struct {
	Key   string
	Value any
}

type ListEntries struct{ Key string }

type ListLen struct{ Key string }

type Map[K comparable, V any] struct {
	// contains filtered or unexported fields
}

type MapDelete struct {
	Key    string
	MapKey any
}

type MapEntries struct{ Key string }

type MapGet struct {
	Key    string
	MapKey any
}

type MapKeys struct{ Key string }

type MapSet struct {
	Key    string
	MapKey any
	Value  any
}

type MemoryBackend struct {
	// contains filtered or unexported fields
}

type MemoryConfig struct{}

type Namespace struct {
	// contains filtered or unexported fields
}

type Op interface {
	// contains filtered or unexported methods
}

type ReadOp interface {
	// contains filtered or unexported methods
}

type Registry struct {
	// contains filtered or unexported fields
}

type S3Backend struct {
	// contains filtered or unexported fields
}

type S3BackendConfig struct {
	Bucket       string        `hcl:"bucket" help:"S3 bucket name."`
	LockTTL      time.Duration `hcl:"lock-ttl,optional" help:"TTL for namespace locks." default:"30s"`
	SyncInterval time.Duration `hcl:"sync-interval,optional" help:"Interval between periodic syncs." default:"30s"`
}

type Scalar[V any] struct {
	// contains filtered or unexported fields
}

type ScalarDelete struct{ Key string }

type ScalarGet struct{ Key string }

type ScalarSet struct {
	Key   string
	Value any
}

type Set[V comparable] struct {
	// contains filtered or unexported fields
}

type SetAdd struct {
	Key    string
	Member any
}

type SetContains struct {
	Key    string
	Member any
}

type SetMembers struct{ Key string }

type SetRemove struct {
	Key    string
	Member any
}

type Store struct {
	// contains filtered or unexported fields
}