fabriqpb

type Ack struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type BlobAck struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type BlobChunk struct {
	Key         string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ContentType string `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Size        int64  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` // declared size on the metadata frame, -1 if unknown
	Data        []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`  // data frames
	// contains filtered or unexported fields
}

type BlobInfoReply struct {
	Info  *BlobObjectInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Error *Error          `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type BlobKey struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type BlobObjectInfo struct {
	Key                string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Size               int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Checksum           string `protobuf:"bytes,3,opt,name=checksum,proto3" json:"checksum,omitempty"`
	ContentType        string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	ModifiedAtUnixNano int64  `protobuf:"varint,5,opt,name=modified_at_unix_nano,json=modifiedAtUnixNano,proto3" json:"modified_at_unix_nano,omitempty"`
	// contains filtered or unexported fields
}

type BlobPresign struct {
	Key        string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Method     string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` // "GET" | "PUT"
	TtlSeconds int64  `protobuf:"varint,3,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"`
	// contains filtered or unexported fields
}

type BlobPresignReply struct {
	Url   string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Command struct {
	Entity          string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Op              string `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`
	AggId           string `protobuf:"bytes,3,opt,name=agg_id,json=aggId,proto3" json:"agg_id,omitempty"`
	Payload         []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	ExpectedVersion *int64 `protobuf:"varint,5,opt,name=expected_version,json=expectedVersion,proto3,oneof" json:"expected_version,omitempty"`
	// contains filtered or unexported fields
}

type Cond struct {
	Column string     `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
	Op     string     `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`
	Value  *CondValue `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Or     []*Cond    `protobuf:"bytes,4,rep,name=or,proto3" json:"or,omitempty"`
	// contains filtered or unexported fields
}

type CondValue struct {

	// Types that are assignable to V:
	//
	//	*CondValue_StringVal
	//	*CondValue_DoubleVal
	//	*CondValue_IntVal
	//	*CondValue_BoolVal
	//	*CondValue_ListVal
	V isCondValue_V `protobuf_oneof:"v"`
	// contains filtered or unexported fields
}

type CondValue_BoolVal struct {
	BoolVal bool `protobuf:"varint,4,opt,name=bool_val,json=boolVal,proto3,oneof"`
}

type CondValue_DoubleVal struct {
	DoubleVal float64 `protobuf:"fixed64,2,opt,name=double_val,json=doubleVal,proto3,oneof"`
}

type CondValue_IntVal struct {
	IntVal int64 `protobuf:"varint,3,opt,name=int_val,json=intVal,proto3,oneof"`
}

type CondValue_ListVal struct {
	ListVal *ValueList `protobuf:"bytes,5,opt,name=list_val,json=listVal,proto3,oneof"`
}

type CondValue_StringVal struct {
	StringVal string `protobuf:"bytes,1,opt,name=string_val,json=stringVal,proto3,oneof"`
}

type CopyBlobRequest struct {
	SrcKey string `protobuf:"bytes,1,opt,name=src_key,json=srcKey,proto3" json:"src_key,omitempty"`
	DstKey string `protobuf:"bytes,2,opt,name=dst_key,json=dstKey,proto3" json:"dst_key,omitempty"`
	// contains filtered or unexported fields
}

type Delta struct {
	StreamId   string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Channel    string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	TenantId   string `protobuf:"bytes,3,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Aggregate  string `protobuf:"bytes,4,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
	AggId      string `protobuf:"bytes,5,opt,name=agg_id,json=aggId,proto3" json:"agg_id,omitempty"`
	Version    int64  `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	Type       string `protobuf:"bytes,7,opt,name=type,proto3" json:"type,omitempty"`
	AtUnixNano int64  `protobuf:"varint,8,opt,name=at_unix_nano,json=atUnixNano,proto3" json:"at_unix_nano,omitempty"` // delivery timestamp, unix nanos
	Payload    []byte `protobuf:"bytes,9,opt,name=payload,proto3" json:"payload,omitempty"`                            // opaque JSON
	// contains filtered or unexported fields
}

type DocApplyUpdateRequest struct {
	DocId  string `protobuf:"bytes,1,opt,name=doc_id,json=docId,proto3" json:"doc_id,omitempty"`
	Update []byte `protobuf:"bytes,2,opt,name=update,proto3" json:"update,omitempty"`
	// contains filtered or unexported fields
}

type DocCompactRequest struct {
	DocId string `protobuf:"bytes,1,opt,name=doc_id,json=docId,proto3" json:"doc_id,omitempty"`
	// contains filtered or unexported fields
}

type DocSnapshotRequest struct {
	DocId string `protobuf:"bytes,1,opt,name=doc_id,json=docId,proto3" json:"doc_id,omitempty"`
	// contains filtered or unexported fields
}

type DocSyncReply struct {
	Update []byte `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`
	Error  *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type DocSyncRequest struct {
	DocId       string `protobuf:"bytes,1,opt,name=doc_id,json=docId,proto3" json:"doc_id,omitempty"`
	StateVector []byte `protobuf:"bytes,2,opt,name=state_vector,json=stateVector,proto3" json:"state_vector,omitempty"`
	// contains filtered or unexported fields
}

type Error struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	AggId   string `protobuf:"bytes,3,opt,name=agg_id,json=aggId,proto3" json:"agg_id,omitempty"` // rich variants (version_conflict)
	Version int64  `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type ExecBatchReply struct {
	Results []*Result `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	Error   *Error    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ExecBatchRequest struct {
	Commands []*Command `protobuf:"bytes,1,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

type ExecReply struct {
	Result *Result `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Error  *Error  `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ExecRequest struct {
	Command *Command `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type GetBlobFrame struct {
	Info  *BlobObjectInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Data  []byte          `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Error *Error          `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type GetManyRequest struct {
	Entity string   `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Ids    []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

type GetRequest struct {
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GraphQueryRequest struct {
	Cypher string `protobuf:"bytes,1,opt,name=cypher,proto3" json:"cypher,omitempty"`
	Params []byte `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"` // JSON map[string]any
	Mode   string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`     // "ids" → []string, else → []map
	// contains filtered or unexported fields
}

type ListBlobReply struct {
	Objects []*BlobObjectInfo `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	Error   *Error            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ListBlobRequest struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

type ListQuery struct {
	Where   []*Cond `protobuf:"bytes,1,rep,name=where,proto3" json:"where,omitempty"`
	OrderBy string  `protobuf:"bytes,2,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	Limit   int32   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset  int32   `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type ListRequest struct {
	Entity     string     `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Query      []byte     `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`           // JSON ListQuery (deprecated: numeric fidelity loss)
	Structured *ListQuery `protobuf:"bytes,3,opt,name=structured,proto3" json:"structured,omitempty"` // preferred when non-nil
	// contains filtered or unexported fields
}

type LiveClientFrame struct {
	Query    *LiveQueryRequest `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`       // first frame
	Reanchor *LiveReanchor     `protobuf:"bytes,2,opt,name=reanchor,proto3" json:"reanchor,omitempty"` // subsequent control frames
	// contains filtered or unexported fields
}

type LiveFrame struct {
	Snapshot []byte `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"` // JSON livequery.Snapshot (initial + each reanchor)
	Delta    []byte `protobuf:"bytes,2,opt,name=delta,proto3" json:"delta,omitempty"`       // JSON livequery.LiveDelta
	Error    *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`       // setup error (handshake)
	// contains filtered or unexported fields
}

type LiveQueryRequest struct {
	Query []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

type LiveReanchor struct {
	Cursor []byte `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"` // JSON livequery.Cursor
	Limit  int32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type Result struct {
	AggId   string `protobuf:"bytes,1,opt,name=agg_id,json=aggId,proto3" json:"agg_id,omitempty"`
	Version int64  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	EventId string `protobuf:"bytes,3,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// contains filtered or unexported fields
}

type RowReply struct {
	Row   []byte `protobuf:"bytes,1,opt,name=row,proto3" json:"row,omitempty"`
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type SearchRequest struct {
	Query []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

type SpatialDeleteRequest struct {
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type SpatialGetReply struct {
	Wkt   string `protobuf:"bytes,1,opt,name=wkt,proto3" json:"wkt,omitempty"`
	Srid  int32  `protobuf:"varint,2,opt,name=srid,proto3" json:"srid,omitempty"`
	Meta  []byte `protobuf:"bytes,3,opt,name=meta,proto3" json:"meta,omitempty"` // JSON map[string]any
	Ok    bool   `protobuf:"varint,4,opt,name=ok,proto3" json:"ok,omitempty"`
	Error *Error `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type SpatialGetRequest struct {
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type SpatialUpsertRequest struct {
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Wkt    string `protobuf:"bytes,3,opt,name=wkt,proto3" json:"wkt,omitempty"`
	Srid   int32  `protobuf:"varint,4,opt,name=srid,proto3" json:"srid,omitempty"`
	Meta   []byte `protobuf:"bytes,5,opt,name=meta,proto3" json:"meta,omitempty"` // JSON map[string]any
	// contains filtered or unexported fields
}

type SpatialWithinRequest struct {
	Query []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // JSON query.SpatialQuery
	// contains filtered or unexported fields
}

type SubFrame struct {
	Open  bool   `protobuf:"varint,1,opt,name=open,proto3" json:"open,omitempty"`
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Delta *Delta `protobuf:"bytes,3,opt,name=delta,proto3" json:"delta,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeRequest struct {
	Scope *SubscribeScope `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeScope struct {
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Scope  string `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"` // scope name declared on the entity ("id", "site", "tenant", …)
	Id     string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`       // scope id (ignored for tenant scope)
	// contains filtered or unexported fields
}

type TSBulkWriteRequest struct {
	Series string `protobuf:"bytes,1,opt,name=series,proto3" json:"series,omitempty"`
	Points []byte `protobuf:"bytes,2,opt,name=points,proto3" json:"points,omitempty"` // JSON []query.Point
	// contains filtered or unexported fields
}

type TSRangeRequest struct {
	Query []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // JSON query.RangeQuery
	// contains filtered or unexported fields
}

type ValueList struct {
	Items []*CondValue `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type VectorDeleteByMetaRequest struct {
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Filter []byte `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` // JSON map[string]string
	// contains filtered or unexported fields
}

type VectorDeleteRequest struct {
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type VectorGetReply struct {
	Embedding []float32 `protobuf:"fixed32,1,rep,packed,name=embedding,proto3" json:"embedding,omitempty"`
	Error     *Error    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type VectorGetRequest struct {
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type VectorSimilarRequest struct {
	Entity    string    `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Embedding []float32 `protobuf:"fixed32,2,rep,packed,name=embedding,proto3" json:"embedding,omitempty"`
	K         int32     `protobuf:"varint,3,opt,name=k,proto3" json:"k,omitempty"`
	Filter    []byte    `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // JSON map[string]string
	// contains filtered or unexported fields
}

type VectorUpsertRequest struct {
	Entity    string    `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	Id        string    `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Embedding []float32 `protobuf:"fixed32,3,rep,packed,name=embedding,proto3" json:"embedding,omitempty"`
	Meta      []byte    `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"` // JSON map[string]any
	// contains filtered or unexported fields
}