datastore

type BaseEntity struct {
	CreatedAt time.Time `datastore:"created_at"`
	UpdatedAt time.Time `datastore:"updated_at"`
	Version   int       `datastore:"version"`
}

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

type Filter struct {
	Field    string
	Operator string
	Value    interface{}
}

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

type Order struct {
	Field      string
	Descending bool
}

type Query struct {
	Kind    string
	Filters []Filter
	Orders  []Order
	Limit   int
	Offset  int
}

type Repository interface {
	// Get retrieves an entity by key
	Get(ctx context.Context, kind string, key string, dest interface{}) error

	// Put saves an entity with the given key
	Put(ctx context.Context, kind string, key string, src interface{}) error

	// Delete removes an entity by key
	Delete(ctx context.Context, kind string, key string) error

	// Query executes a query and returns results
	Query(ctx context.Context, query Query) ([]interface{}, error)

	// Transaction executes operations in a transaction
	Transaction(ctx context.Context, fn func(tx Transaction) error) error
}

type Transaction interface {
	Get(kind string, key string, dest interface{}) error
	Put(kind string, key string, src interface{}) error
	Delete(kind string, key string) error
}