repository

type BaseRepository[T any] struct {
	// contains filtered or unexported fields
}

type DataStore interface {
	// CreateTable creates underlying table if needed.
	CreateTable(
		baseTableName string,
		baseTableSuffix string,
	) (err error)

	// Size of records for tenant.
	Size(
		baseTableName string,
		baseTableSuffix string,
		tenant string,
		namespace string,
	) (size int64, err error)

	// Get finds records by ids.
	Get(
		baseTableName string,
		baseTableSuffix string,
		tenant string,
		namespace string,
		ids ...string,
	) (res map[string][]byte, err error)

	// Query searches records by predicates.
	Query(
		baseTableName string,
		baseTableSuffix string,
		tenant string,
		namespace string,
		predicate map[string]string,
		lastEvaluatedKeyStr string,
		limit int64,
	) (res map[string][]byte, nextKeyStr string, err error)

	// Create adds a new record.
	Create(
		baseTableName string,
		baseTableSuffix string,
		tenant string,
		namespace string,
		id string,
		value []byte,
		expiration time.Duration) (err error)

	// Update changes existing record.
	Update(
		baseTableName string,
		baseTableSuffix string,
		tenant string,
		namespace string,
		id string,
		version int64,
		value []byte,
		expiration time.Duration) (err error)

	// Delete removes existing record.
	Delete(
		baseTableName string,
		baseTableSuffix string,
		tenant string,
		namespace string,
		id string,
	) (err error)

	// ClearTable removes all records for tenant
	ClearTable(
		baseTableName string,
		baseTableSuffix string,
		tenant string,
		namespace string,
	) (err error)
}

type Repository[T any] interface {
	// GetByIDs - finds objects matching ids.
	GetByIDs(
		ctx context.Context,
		organizationID string,
		namespace string,
		ids ...string,
	) (map[string]*T, error)

	// GetByID - finds an object by id.
	GetByID(
		ctx context.Context,
		organizationID string,
		namespace string,
		id string,
	) (*T, error)

	// Create - creates a new object.
	Create(
		ctx context.Context,
		organizationID string,
		namespace string,
		id string,
		obj *T,
		expiration time.Duration,
	) error

	// Update - saves existing object.
	Update(
		ctx context.Context,
		organizationID string,
		namespace string,
		id string,
		version int64,
		obj *T,
		expiration time.Duration,
	) error

	// Query - queries objects
	Query(
		ctx context.Context,
		organizationID string,
		namespace string,
		predicate map[string]string,
		offset string,
		limit int64,
	) (res []*T, nextOffset string, err error)

	// Delete - remove the object
	Delete(
		ctx context.Context,
		organizationID string,
		namespace string,
		id string,
	) error

	// Size of table
	Size(
		ctx context.Context,
		organizationID string,
		namespace string,
	) (int64, error)
}

type ResourceInstanceRepositoryFactory interface {
	CreateResourceInstanceRepository(resourceID string) (Repository[types.ResourceInstance], error)
}