pathdb

type ChangeSet[T any] struct {
	Updates map[string]*Item[*Raw[T]]
	Deletes map[string]bool
}

type DB interface {
	Queryable
	Begin() (TX, error)
	WithSchema(string) DB
	Subscribe(*subscription)
	Unsubscribe(string)
	RegisterType(id int16, example interface{})
}

type Item[T any] struct {
	Path       string
	DetailPath string
	Value      T
}

type PBUFObject struct {
	A string  `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	B float64 `protobuf:"fixed64,2,opt,name=b,proto3" json:"b,omitempty"`
	// contains filtered or unexported fields
}

type QueryParams struct {
	Path                string
	Start               int
	Count               int
	ReverseSort         bool
	JoinDetails         bool
	IncludeEmptyDetails bool
}

type Queryable interface {
	Get(path string) ([]byte, error)
	List(query *QueryParams, search *SearchParams) ([]*item, error)
	// contains filtered or unexported methods
}

type Raw[T any] struct {
	Bytes []byte
	// contains filtered or unexported fields
}

type SearchParams struct {
	Search         string
	HighlightStart string
	HighlightEnd   string
	Ellipses       string
	NumTokens      int
}

type SearchResult[T any] struct {
	Item[T]
	Snippet string
}

type Subscription[T any] struct {
	ID             string
	PathPrefixes   []string
	JoinDetails    bool
	ReceiveInitial bool
	OnUpdate       func(*ChangeSet[T]) error
}

type TX interface {
	Queryable
	Put(path string, value interface{}, serializedValue []byte, fullText string, updateIfPresent bool) error
	Delete(path string) error
	Commit() error
	Rollback() error
}