driver

type Conn interface {
	Load(name string) (Store, error)
	Close() error
}

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

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

type Cursor interface {
	All(ctx context.Context, val any) error
	Next(ctx context.Context) bool
	Decode(val any) error
	Close(ctx context.Context) error
}

type DeleteOptions struct {
}

type Driver interface {
	Open(name string) (Conn, error)
	Close() error
}

type Event struct {
	ID uuid.UUID `json:"id" yaml:"id" validate:"required"`
	OP string    `json:"op" yaml:"op" validate:"required"`
}

type FindOptions struct {
	Limit int
	Skip  int
	Sort  any
}

type IndexOptions struct {
	Unique bool
	Filter any
}

type InsertOptions struct {
}

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

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

type Store interface {
	Watch(ctx context.Context, filter any) (Stream, error)

	Index(ctx context.Context, keys []string, opts ...IndexOptions) error
	Unindex(ctx context.Context, keys []string) error

	Insert(ctx context.Context, docs []any, opts ...InsertOptions) error
	Update(ctx context.Context, filter, update any, opts ...UpdateOptions) (int, error)
	Delete(ctx context.Context, filter any, opts ...DeleteOptions) (int, error)
	Find(ctx context.Context, filter any, opts ...FindOptions) (Cursor, error)
}

type Stream interface {
	Next(ctx context.Context) bool
	Decode(val any) error
	Close(ctx context.Context) error
}

type UpdateOptions struct {
	Upsert bool
}