configstore

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

type ConfigObjectCodec interface {
	Encode(obj any) ([]byte, error)
	Decode(data []byte) (any, error)
}

type ConfigStore interface {
	List(ctx context.Context) ([]any, error)
	ListByTag(ctx context.Context, tag string) ([]any, error)
	ListByTagPrefix(ctx context.Context, tagPrefix string) ([]any, error)

	Create(ctx context.Context, obj any) error
	Update(ctx context.Context, obj any) error
	Delete(ctx context.Context, keyParts ...any) error

	Get(ctx context.Context, keyParts ...any) (any, error)
	GetByIndex(ctx context.Context, indexName string, value any) (any, error)
}

type ConfigStoreBackend interface {
	Register(name string, storeSchema StoreSchema) error
	Get(name string) (ConfigStore, error)
}

type ConfigStoreCreator interface {
	NewStore(storeSchema StoreSchema) (ConfigStore, error)
}

type ConfigStoreCreatorFactory func(context.Context, json.RawMessage, *zap.Logger) (ConfigStoreCreator, error)

type IndexSchema struct {
	Name   string
	Column string
	Unique bool
}

type MetadataFuncs struct {
	PrimaryKeyFunc func(obj any) ([]any, error)
	TagFunc        func(obj any) (string, bool, error)
	IndexesFunc    func(obj any) (map[string]any, error)
}

type ObjectMetadata interface {
	PrimaryKey(obj any) ([]any, error)
	Tag(obj any) (string, bool, error)
	Indexes(obj any) (map[string]any, error)
}

type ObjectUnwrapper interface {
	ConfigStoreObject() any
}

type StoreSchema struct {
	Name  string
	Kind  string
	Table string

	PrimaryKeyColumns []string
	TagColumn         string
	DataColumn        string

	IndexColumns []IndexSchema
	Timestamped  bool

	Codec    ConfigObjectCodec
	Metadata ObjectMetadata
}

type TagCarrier interface {
	ConfigStoreTag() string
}