fabriqpb

package
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_fabriq_v1_fabriq_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Ack 

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

--- knowledge retrieval (vector / search / graph projection reads) ---

func (*Ack) Descriptor deprecated 

func (*Ack) Descriptor() ([]byte, []int)

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetError 

func (x *Ack) GetError() *Error

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect 

func (x *Ack) ProtoReflect() protoreflect.Message

func (*Ack) Reset 

func (x *Ack) Reset()

func (*Ack) String 

func (x *Ack) String() string

type BlobAck 

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

func (*BlobAck) Descriptor deprecated 

func (*BlobAck) Descriptor() ([]byte, []int)

Deprecated: Use BlobAck.ProtoReflect.Descriptor instead.

func (*BlobAck) GetError 

func (x *BlobAck) GetError() *Error

func (*BlobAck) ProtoMessage 

func (*BlobAck) ProtoMessage()

func (*BlobAck) ProtoReflect 

func (x *BlobAck) ProtoReflect() protoreflect.Message

func (*BlobAck) Reset 

func (x *BlobAck) Reset()

func (*BlobAck) String 

func (x *BlobAck) String() string

type BlobChunk 

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
}

--- blobs (core/blob.Store) --- PutBlob upload stream: the first frame carries metadata (key, content_type, size), each subsequent frame carries data bytes.

func (*BlobChunk) Descriptor deprecated 

func (*BlobChunk) Descriptor() ([]byte, []int)

Deprecated: Use BlobChunk.ProtoReflect.Descriptor instead.

func (*BlobChunk) GetContentType 

func (x *BlobChunk) GetContentType() string

func (*BlobChunk) GetData 

func (x *BlobChunk) GetData() []byte

func (*BlobChunk) GetKey 

func (x *BlobChunk) GetKey() string

func (*BlobChunk) GetSize 

func (x *BlobChunk) GetSize() int64

func (*BlobChunk) ProtoMessage 

func (*BlobChunk) ProtoMessage()

func (*BlobChunk) ProtoReflect 

func (x *BlobChunk) ProtoReflect() protoreflect.Message

func (*BlobChunk) Reset 

func (x *BlobChunk) Reset()

func (*BlobChunk) String 

func (x *BlobChunk) String() string

type BlobInfoReply 

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
}

func (*BlobInfoReply) Descriptor deprecated 

func (*BlobInfoReply) Descriptor() ([]byte, []int)

Deprecated: Use BlobInfoReply.ProtoReflect.Descriptor instead.

func (*BlobInfoReply) GetError 

func (x *BlobInfoReply) GetError() *Error

func (*BlobInfoReply) GetInfo 

func (x *BlobInfoReply) GetInfo() *BlobObjectInfo

func (*BlobInfoReply) ProtoMessage 

func (*BlobInfoReply) ProtoMessage()

func (*BlobInfoReply) ProtoReflect 

func (x *BlobInfoReply) ProtoReflect() protoreflect.Message

func (*BlobInfoReply) Reset 

func (x *BlobInfoReply) Reset()

func (*BlobInfoReply) String 

func (x *BlobInfoReply) String() string

type BlobKey 

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

func (*BlobKey) Descriptor deprecated 

func (*BlobKey) Descriptor() ([]byte, []int)

Deprecated: Use BlobKey.ProtoReflect.Descriptor instead.

func (*BlobKey) GetKey 

func (x *BlobKey) GetKey() string

func (*BlobKey) ProtoMessage 

func (*BlobKey) ProtoMessage()

func (*BlobKey) ProtoReflect 

func (x *BlobKey) ProtoReflect() protoreflect.Message

func (*BlobKey) Reset 

func (x *BlobKey) Reset()

func (*BlobKey) String 

func (x *BlobKey) String() string

type BlobObjectInfo 

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
}

func (*BlobObjectInfo) Descriptor deprecated 

func (*BlobObjectInfo) Descriptor() ([]byte, []int)

Deprecated: Use BlobObjectInfo.ProtoReflect.Descriptor instead.

func (*BlobObjectInfo) GetChecksum 

func (x *BlobObjectInfo) GetChecksum() string

func (*BlobObjectInfo) GetContentType 

func (x *BlobObjectInfo) GetContentType() string

func (*BlobObjectInfo) GetKey 

func (x *BlobObjectInfo) GetKey() string

func (*BlobObjectInfo) GetModifiedAtUnixNano 

func (x *BlobObjectInfo) GetModifiedAtUnixNano() int64

func (*BlobObjectInfo) GetSize 

func (x *BlobObjectInfo) GetSize() int64

func (*BlobObjectInfo) ProtoMessage 

func (*BlobObjectInfo) ProtoMessage()

func (*BlobObjectInfo) ProtoReflect 

func (x *BlobObjectInfo) ProtoReflect() protoreflect.Message

func (*BlobObjectInfo) Reset 

func (x *BlobObjectInfo) Reset()

func (*BlobObjectInfo) String 

func (x *BlobObjectInfo) String() string

type BlobPresign 

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
}

func (*BlobPresign) Descriptor deprecated 

func (*BlobPresign) Descriptor() ([]byte, []int)

Deprecated: Use BlobPresign.ProtoReflect.Descriptor instead.

func (*BlobPresign) GetKey 

func (x *BlobPresign) GetKey() string

func (*BlobPresign) GetMethod 

func (x *BlobPresign) GetMethod() string

func (*BlobPresign) GetTtlSeconds 

func (x *BlobPresign) GetTtlSeconds() int64

func (*BlobPresign) ProtoMessage 

func (*BlobPresign) ProtoMessage()

func (*BlobPresign) ProtoReflect 

func (x *BlobPresign) ProtoReflect() protoreflect.Message

func (*BlobPresign) Reset 

func (x *BlobPresign) Reset()

func (*BlobPresign) String 

func (x *BlobPresign) String() string

type BlobPresignReply 

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
}

func (*BlobPresignReply) Descriptor deprecated 

func (*BlobPresignReply) Descriptor() ([]byte, []int)

Deprecated: Use BlobPresignReply.ProtoReflect.Descriptor instead.

func (*BlobPresignReply) GetError 

func (x *BlobPresignReply) GetError() *Error

func (*BlobPresignReply) GetUrl 

func (x *BlobPresignReply) GetUrl() string

func (*BlobPresignReply) ProtoMessage 

func (*BlobPresignReply) ProtoMessage()

func (*BlobPresignReply) ProtoReflect 

func (x *BlobPresignReply) ProtoReflect() protoreflect.Message

func (*BlobPresignReply) Reset 

func (x *BlobPresignReply) Reset()

func (*BlobPresignReply) String 

func (x *BlobPresignReply) String() string

type ClientCommand 

type ClientCommand struct {
	Action string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"` // "subscribe" | "reanchor" | "unsubscribe"
	Query  []byte `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`   // JSON LiveQuery (subscribe)
	Cursor []byte `protobuf:"bytes,3,opt,name=cursor,proto3" json:"cursor,omitempty"` // JSON Cursor (reanchor)
	Limit  int32  `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

--- live (mirrors gateway/protocol.go) ---

func (*ClientCommand) Descriptor deprecated 

func (*ClientCommand) Descriptor() ([]byte, []int)

Deprecated: Use ClientCommand.ProtoReflect.Descriptor instead.

func (*ClientCommand) GetAction 

func (x *ClientCommand) GetAction() string

func (*ClientCommand) GetCursor 

func (x *ClientCommand) GetCursor() []byte

func (*ClientCommand) GetLimit 

func (x *ClientCommand) GetLimit() int32

func (*ClientCommand) GetQuery 

func (x *ClientCommand) GetQuery() []byte

func (*ClientCommand) ProtoMessage 

func (*ClientCommand) ProtoMessage()

func (*ClientCommand) ProtoReflect 

func (x *ClientCommand) ProtoReflect() protoreflect.Message

func (*ClientCommand) Reset 

func (x *ClientCommand) Reset()

func (*ClientCommand) String 

func (x *ClientCommand) String() string

type Command 

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
}

Command mirrors core/command.Command. payload is the entity's grove model as OPAQUE bytes (canonical JSON today). The registry — not this schema — owns payload shape, so dynamic entities and map-native writes cross unchanged. op is "create" | "update" | "delete" | "upsert".

func (*Command) Descriptor deprecated 

func (*Command) Descriptor() ([]byte, []int)

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetAggId 

func (x *Command) GetAggId() string

func (*Command) GetEntity 

func (x *Command) GetEntity() string

func (*Command) GetExpectedVersion 

func (x *Command) GetExpectedVersion() int64

func (*Command) GetOp 

func (x *Command) GetOp() string

func (*Command) GetPayload 

func (x *Command) GetPayload() []byte

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

func (x *Command) ProtoReflect() protoreflect.Message

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

type Delta 

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
}

func (*Delta) Descriptor deprecated 

func (*Delta) Descriptor() ([]byte, []int)

Deprecated: Use Delta.ProtoReflect.Descriptor instead.

func (*Delta) GetAggId 

func (x *Delta) GetAggId() string

func (*Delta) GetAggregate 

func (x *Delta) GetAggregate() string

func (*Delta) GetAtUnixNano 

func (x *Delta) GetAtUnixNano() int64

func (*Delta) GetChannel 

func (x *Delta) GetChannel() string

func (*Delta) GetPayload 

func (x *Delta) GetPayload() []byte

func (*Delta) GetStreamId 

func (x *Delta) GetStreamId() string

func (*Delta) GetTenantId 

func (x *Delta) GetTenantId() string

func (*Delta) GetType 

func (x *Delta) GetType() string

func (*Delta) GetVersion 

func (x *Delta) GetVersion() int64

func (*Delta) ProtoMessage 

func (*Delta) ProtoMessage()

func (*Delta) ProtoReflect 

func (x *Delta) ProtoReflect() protoreflect.Message

func (*Delta) Reset 

func (x *Delta) Reset()

func (*Delta) String 

func (x *Delta) String() string

type Error 

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
}

Error carries fabriq's typed-error taxonomy so the client rebuilds errors.Is-matchable sentinels. code is stable: "not_found", "version_conflict", "no_tenant", "not_configured", "internal".

func (*Error) Descriptor deprecated 

func (*Error) Descriptor() ([]byte, []int)

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetAggId 

func (x *Error) GetAggId() string

func (*Error) GetCode 

func (x *Error) GetCode() string

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) GetVersion 

func (x *Error) GetVersion() int64

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type ExecBatchReply 

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
}

func (*ExecBatchReply) Descriptor deprecated 

func (*ExecBatchReply) Descriptor() ([]byte, []int)

Deprecated: Use ExecBatchReply.ProtoReflect.Descriptor instead.

func (*ExecBatchReply) GetError 

func (x *ExecBatchReply) GetError() *Error

func (*ExecBatchReply) GetResults 

func (x *ExecBatchReply) GetResults() []*Result

func (*ExecBatchReply) ProtoMessage 

func (*ExecBatchReply) ProtoMessage()

func (*ExecBatchReply) ProtoReflect 

func (x *ExecBatchReply) ProtoReflect() protoreflect.Message

func (*ExecBatchReply) Reset 

func (x *ExecBatchReply) Reset()

func (*ExecBatchReply) String 

func (x *ExecBatchReply) String() string

type ExecBatchRequest 

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

func (*ExecBatchRequest) Descriptor deprecated 

func (*ExecBatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecBatchRequest.ProtoReflect.Descriptor instead.

func (*ExecBatchRequest) GetCommands 

func (x *ExecBatchRequest) GetCommands() []*Command

func (*ExecBatchRequest) ProtoMessage 

func (*ExecBatchRequest) ProtoMessage()

func (*ExecBatchRequest) ProtoReflect 

func (x *ExecBatchRequest) ProtoReflect() protoreflect.Message

func (*ExecBatchRequest) Reset 

func (x *ExecBatchRequest) Reset()

func (*ExecBatchRequest) String 

func (x *ExecBatchRequest) String() string

type ExecReply 

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
}

func (*ExecReply) Descriptor deprecated 

func (*ExecReply) Descriptor() ([]byte, []int)

Deprecated: Use ExecReply.ProtoReflect.Descriptor instead.

func (*ExecReply) GetError 

func (x *ExecReply) GetError() *Error

func (*ExecReply) GetResult 

func (x *ExecReply) GetResult() *Result

func (*ExecReply) ProtoMessage 

func (*ExecReply) ProtoMessage()

func (*ExecReply) ProtoReflect 

func (x *ExecReply) ProtoReflect() protoreflect.Message

func (*ExecReply) Reset 

func (x *ExecReply) Reset()

func (*ExecReply) String 

func (x *ExecReply) String() string

type ExecRequest 

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

func (*ExecRequest) Descriptor deprecated 

func (*ExecRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.

func (*ExecRequest) GetCommand 

func (x *ExecRequest) GetCommand() *Command

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) ProtoReflect 

func (x *ExecRequest) ProtoReflect() protoreflect.Message

func (*ExecRequest) Reset 

func (x *ExecRequest) Reset()

func (*ExecRequest) String 

func (x *ExecRequest) String() string

type Frame 

type Frame struct {
	Op       string `protobuf:"bytes,1,opt,name=op,proto3" json:"op,omitempty"` // "enter" | "leave" | "move" | "update" | "reset"
	AggId    string `protobuf:"bytes,2,opt,name=agg_id,json=aggId,proto3" json:"agg_id,omitempty"`
	Version  int64  `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Row      []byte `protobuf:"bytes,4,opt,name=row,proto3" json:"row,omitempty"`
	OldIndex int32  `protobuf:"varint,5,opt,name=old_index,json=oldIndex,proto3" json:"old_index,omitempty"`
	NewIndex int32  `protobuf:"varint,6,opt,name=new_index,json=newIndex,proto3" json:"new_index,omitempty"`
	Cursor   []byte `protobuf:"bytes,7,opt,name=cursor,proto3" json:"cursor,omitempty"`
	StreamId string `protobuf:"bytes,8,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Frame) Descriptor deprecated 

func (*Frame) Descriptor() ([]byte, []int)

Deprecated: Use Frame.ProtoReflect.Descriptor instead.

func (*Frame) GetAggId 

func (x *Frame) GetAggId() string

func (*Frame) GetCursor 

func (x *Frame) GetCursor() []byte

func (*Frame) GetNewIndex 

func (x *Frame) GetNewIndex() int32

func (*Frame) GetOldIndex 

func (x *Frame) GetOldIndex() int32

func (*Frame) GetOp 

func (x *Frame) GetOp() string

func (*Frame) GetRow 

func (x *Frame) GetRow() []byte

func (*Frame) GetStreamId 

func (x *Frame) GetStreamId() string

func (*Frame) GetVersion 

func (x *Frame) GetVersion() int64

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) ProtoReflect 

func (x *Frame) ProtoReflect() protoreflect.Message

func (*Frame) Reset 

func (x *Frame) Reset()

func (*Frame) String 

func (x *Frame) String() string

type GetBlobFrame 

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
}

GetBlob download stream: the first frame carries the object metadata (or a setup error such as not_found); each subsequent frame carries data bytes.

func (*GetBlobFrame) Descriptor deprecated 

func (*GetBlobFrame) Descriptor() ([]byte, []int)

Deprecated: Use GetBlobFrame.ProtoReflect.Descriptor instead.

func (*GetBlobFrame) GetData 

func (x *GetBlobFrame) GetData() []byte

func (*GetBlobFrame) GetError 

func (x *GetBlobFrame) GetError() *Error

func (*GetBlobFrame) GetInfo 

func (x *GetBlobFrame) GetInfo() *BlobObjectInfo

func (*GetBlobFrame) ProtoMessage 

func (*GetBlobFrame) ProtoMessage()

func (*GetBlobFrame) ProtoReflect 

func (x *GetBlobFrame) ProtoReflect() protoreflect.Message

func (*GetBlobFrame) Reset 

func (x *GetBlobFrame) Reset()

func (*GetBlobFrame) String 

func (x *GetBlobFrame) String() string

type GetManyRequest 

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
}

func (*GetManyRequest) Descriptor deprecated 

func (*GetManyRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetManyRequest.ProtoReflect.Descriptor instead.

func (*GetManyRequest) GetEntity 

func (x *GetManyRequest) GetEntity() string

func (*GetManyRequest) GetIds 

func (x *GetManyRequest) GetIds() []string

func (*GetManyRequest) ProtoMessage 

func (*GetManyRequest) ProtoMessage()

func (*GetManyRequest) ProtoReflect 

func (x *GetManyRequest) ProtoReflect() protoreflect.Message

func (*GetManyRequest) Reset 

func (x *GetManyRequest) Reset()

func (*GetManyRequest) String 

func (x *GetManyRequest) String() string

type GetRequest 

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
}

--- reads (body is opaque JSON, like Command.payload) ---

func (*GetRequest) Descriptor deprecated 

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetEntity 

func (x *GetRequest) GetEntity() string

func (*GetRequest) GetId 

func (x *GetRequest) GetId() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GraphQueryRequest 

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
}

func (*GraphQueryRequest) Descriptor deprecated 

func (*GraphQueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use GraphQueryRequest.ProtoReflect.Descriptor instead.

func (*GraphQueryRequest) GetCypher 

func (x *GraphQueryRequest) GetCypher() string

func (*GraphQueryRequest) GetMode 

func (x *GraphQueryRequest) GetMode() string

func (*GraphQueryRequest) GetParams 

func (x *GraphQueryRequest) GetParams() []byte

func (*GraphQueryRequest) ProtoMessage 

func (*GraphQueryRequest) ProtoMessage()

func (*GraphQueryRequest) ProtoReflect 

func (x *GraphQueryRequest) ProtoReflect() protoreflect.Message

func (*GraphQueryRequest) Reset 

func (x *GraphQueryRequest) Reset()

func (*GraphQueryRequest) String 

func (x *GraphQueryRequest) String() string

type ListRequest 

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"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

func (*ListRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetEntity 

func (x *ListRequest) GetEntity() string

func (*ListRequest) GetQuery 

func (x *ListRequest) GetQuery() []byte

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

func (x *ListRequest) ProtoReflect() protoreflect.Message

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type LiveFrame 

type LiveFrame struct {
	Snapshot []byte `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"` // JSON livequery.Snapshot (first frame)
	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
}

LiveFrame: the first frame carries the snapshot (or a setup error); each subsequent frame carries one delta. Bodies are opaque JSON.

func (*LiveFrame) Descriptor deprecated 

func (*LiveFrame) Descriptor() ([]byte, []int)

Deprecated: Use LiveFrame.ProtoReflect.Descriptor instead.

func (*LiveFrame) GetDelta 

func (x *LiveFrame) GetDelta() []byte

func (*LiveFrame) GetError 

func (x *LiveFrame) GetError() *Error

func (*LiveFrame) GetSnapshot 

func (x *LiveFrame) GetSnapshot() []byte

func (*LiveFrame) ProtoMessage 

func (*LiveFrame) ProtoMessage()

func (*LiveFrame) ProtoReflect 

func (x *LiveFrame) ProtoReflect() protoreflect.Message

func (*LiveFrame) Reset 

func (x *LiveFrame) Reset()

func (*LiveFrame) String 

func (x *LiveFrame) String() string

type LiveQueryRequest 

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

--- live query (maintained, ordered, filtered window) ---

func (*LiveQueryRequest) Descriptor deprecated 

func (*LiveQueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use LiveQueryRequest.ProtoReflect.Descriptor instead.

func (*LiveQueryRequest) GetQuery 

func (x *LiveQueryRequest) GetQuery() []byte

func (*LiveQueryRequest) ProtoMessage 

func (*LiveQueryRequest) ProtoMessage()

func (*LiveQueryRequest) ProtoReflect 

func (x *LiveQueryRequest) ProtoReflect() protoreflect.Message

func (*LiveQueryRequest) Reset 

func (x *LiveQueryRequest) Reset()

func (*LiveQueryRequest) String 

func (x *LiveQueryRequest) String() string

type Result 

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
}

func (*Result) Descriptor deprecated 

func (*Result) Descriptor() ([]byte, []int)

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetAggId 

func (x *Result) GetAggId() string

func (*Result) GetEventId 

func (x *Result) GetEventId() string

func (*Result) GetVersion 

func (x *Result) GetVersion() int64

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) ProtoReflect 

func (x *Result) ProtoReflect() protoreflect.Message

func (*Result) Reset 

func (x *Result) Reset()

func (*Result) String 

func (x *Result) String() string

type RowReply 

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
}

func (*RowReply) Descriptor deprecated 

func (*RowReply) Descriptor() ([]byte, []int)

Deprecated: Use RowReply.ProtoReflect.Descriptor instead.

func (*RowReply) GetError 

func (x *RowReply) GetError() *Error

func (*RowReply) GetRow 

func (x *RowReply) GetRow() []byte

func (*RowReply) ProtoMessage 

func (*RowReply) ProtoMessage()

func (*RowReply) ProtoReflect 

func (x *RowReply) ProtoReflect() protoreflect.Message

func (*RowReply) Reset 

func (x *RowReply) Reset()

func (*RowReply) String 

func (x *RowReply) String() string

type SearchRequest 

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

func (*SearchRequest) Descriptor deprecated 

func (*SearchRequest) Descriptor() ([]byte, []int)

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() []byte

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

func (x *SearchRequest) ProtoReflect() protoreflect.Message

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type SubFrame 

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
}

SubFrame is one frame of the Subscribe stream: the first is the handshake (open, or error on a setup failure such as authz); the rest carry one Delta.

func (*SubFrame) Descriptor deprecated 

func (*SubFrame) Descriptor() ([]byte, []int)

Deprecated: Use SubFrame.ProtoReflect.Descriptor instead.

func (*SubFrame) GetDelta 

func (x *SubFrame) GetDelta() *Delta

func (*SubFrame) GetError 

func (x *SubFrame) GetError() *Error

func (*SubFrame) GetOpen 

func (x *SubFrame) GetOpen() bool

func (*SubFrame) ProtoMessage 

func (*SubFrame) ProtoMessage()

func (*SubFrame) ProtoReflect 

func (x *SubFrame) ProtoReflect() protoreflect.Message

func (*SubFrame) Reset 

func (x *SubFrame) Reset()

func (*SubFrame) String 

func (x *SubFrame) String() string

type SubscribeRequest 

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

--- subscribe (conflated channel deltas) ---

func (*SubscribeRequest) Descriptor deprecated 

func (*SubscribeRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetScope 

func (x *SubscribeRequest) GetScope() *SubscribeScope

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeScope 

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
}

func (*SubscribeScope) Descriptor deprecated 

func (*SubscribeScope) Descriptor() ([]byte, []int)

Deprecated: Use SubscribeScope.ProtoReflect.Descriptor instead.

func (*SubscribeScope) GetEntity 

func (x *SubscribeScope) GetEntity() string

func (*SubscribeScope) GetId 

func (x *SubscribeScope) GetId() string

func (*SubscribeScope) GetScope 

func (x *SubscribeScope) GetScope() string

func (*SubscribeScope) ProtoMessage 

func (*SubscribeScope) ProtoMessage()

func (*SubscribeScope) ProtoReflect 

func (x *SubscribeScope) ProtoReflect() protoreflect.Message

func (*SubscribeScope) Reset 

func (x *SubscribeScope) Reset()

func (*SubscribeScope) String 

func (x *SubscribeScope) String() string

type VectorDeleteByMetaRequest added in v0.0.3 

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
}

func (*VectorDeleteByMetaRequest) Descriptor deprecated added in v0.0.3 

func (*VectorDeleteByMetaRequest) Descriptor() ([]byte, []int)

Deprecated: Use VectorDeleteByMetaRequest.ProtoReflect.Descriptor instead.

func (*VectorDeleteByMetaRequest) GetEntity added in v0.0.3 

func (x *VectorDeleteByMetaRequest) GetEntity() string

func (*VectorDeleteByMetaRequest) GetFilter added in v0.0.3 

func (x *VectorDeleteByMetaRequest) GetFilter() []byte

func (*VectorDeleteByMetaRequest) ProtoMessage added in v0.0.3 

func (*VectorDeleteByMetaRequest) ProtoMessage()

func (*VectorDeleteByMetaRequest) ProtoReflect added in v0.0.3 

func (x *VectorDeleteByMetaRequest) ProtoReflect() protoreflect.Message

func (*VectorDeleteByMetaRequest) Reset added in v0.0.3 

func (x *VectorDeleteByMetaRequest) Reset()

func (*VectorDeleteByMetaRequest) String added in v0.0.3 

func (x *VectorDeleteByMetaRequest) String() string

type VectorDeleteRequest 

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
}

func (*VectorDeleteRequest) Descriptor deprecated 

func (*VectorDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use VectorDeleteRequest.ProtoReflect.Descriptor instead.

func (*VectorDeleteRequest) GetEntity 

func (x *VectorDeleteRequest) GetEntity() string

func (*VectorDeleteRequest) GetId 

func (x *VectorDeleteRequest) GetId() string

func (*VectorDeleteRequest) ProtoMessage 

func (*VectorDeleteRequest) ProtoMessage()

func (*VectorDeleteRequest) ProtoReflect 

func (x *VectorDeleteRequest) ProtoReflect() protoreflect.Message

func (*VectorDeleteRequest) Reset 

func (x *VectorDeleteRequest) Reset()

func (*VectorDeleteRequest) String 

func (x *VectorDeleteRequest) String() string

type VectorGetReply added in v0.0.3 

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
}

VectorGetReply carries the raw float components of a stored embedding. On miss the server sets error (code "not_found") and leaves embedding empty.

func (*VectorGetReply) Descriptor deprecated added in v0.0.3 

func (*VectorGetReply) Descriptor() ([]byte, []int)

Deprecated: Use VectorGetReply.ProtoReflect.Descriptor instead.

func (*VectorGetReply) GetEmbedding added in v0.0.3 

func (x *VectorGetReply) GetEmbedding() []float32

func (*VectorGetReply) GetError added in v0.0.3 

func (x *VectorGetReply) GetError() *Error

func (*VectorGetReply) ProtoMessage added in v0.0.3 

func (*VectorGetReply) ProtoMessage()

func (*VectorGetReply) ProtoReflect added in v0.0.3 

func (x *VectorGetReply) ProtoReflect() protoreflect.Message

func (*VectorGetReply) Reset added in v0.0.3 

func (x *VectorGetReply) Reset()

func (*VectorGetReply) String added in v0.0.3 

func (x *VectorGetReply) String() string

type VectorGetRequest added in v0.0.3 

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
}

func (*VectorGetRequest) Descriptor deprecated added in v0.0.3 

func (*VectorGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use VectorGetRequest.ProtoReflect.Descriptor instead.

func (*VectorGetRequest) GetEntity added in v0.0.3 

func (x *VectorGetRequest) GetEntity() string

func (*VectorGetRequest) GetId added in v0.0.3 

func (x *VectorGetRequest) GetId() string

func (*VectorGetRequest) ProtoMessage added in v0.0.3 

func (*VectorGetRequest) ProtoMessage()

func (*VectorGetRequest) ProtoReflect added in v0.0.3 

func (x *VectorGetRequest) ProtoReflect() protoreflect.Message

func (*VectorGetRequest) Reset added in v0.0.3 

func (x *VectorGetRequest) Reset()

func (*VectorGetRequest) String added in v0.0.3 

func (x *VectorGetRequest) String() string

type VectorSimilarRequest 

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
}

func (*VectorSimilarRequest) Descriptor deprecated 

func (*VectorSimilarRequest) Descriptor() ([]byte, []int)

Deprecated: Use VectorSimilarRequest.ProtoReflect.Descriptor instead.

func (*VectorSimilarRequest) GetEmbedding 

func (x *VectorSimilarRequest) GetEmbedding() []float32

func (*VectorSimilarRequest) GetEntity 

func (x *VectorSimilarRequest) GetEntity() string

func (*VectorSimilarRequest) GetFilter added in v0.0.3 

func (x *VectorSimilarRequest) GetFilter() []byte

func (*VectorSimilarRequest) GetK 

func (x *VectorSimilarRequest) GetK() int32

func (*VectorSimilarRequest) ProtoMessage 

func (*VectorSimilarRequest) ProtoMessage()

func (*VectorSimilarRequest) ProtoReflect 

func (x *VectorSimilarRequest) ProtoReflect() protoreflect.Message

func (*VectorSimilarRequest) Reset 

func (x *VectorSimilarRequest) Reset()

func (*VectorSimilarRequest) String 

func (x *VectorSimilarRequest) String() string

type VectorUpsertRequest 

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
}

func (*VectorUpsertRequest) Descriptor deprecated 

func (*VectorUpsertRequest) Descriptor() ([]byte, []int)

Deprecated: Use VectorUpsertRequest.ProtoReflect.Descriptor instead.

func (*VectorUpsertRequest) GetEmbedding 

func (x *VectorUpsertRequest) GetEmbedding() []float32

func (*VectorUpsertRequest) GetEntity 

func (x *VectorUpsertRequest) GetEntity() string

func (*VectorUpsertRequest) GetId 

func (x *VectorUpsertRequest) GetId() string

func (*VectorUpsertRequest) GetMeta 

func (x *VectorUpsertRequest) GetMeta() []byte

func (*VectorUpsertRequest) ProtoMessage 

func (*VectorUpsertRequest) ProtoMessage()

func (*VectorUpsertRequest) ProtoReflect 

func (x *VectorUpsertRequest) ProtoReflect() protoreflect.Message

func (*VectorUpsertRequest) Reset 

func (x *VectorUpsertRequest) Reset()

func (*VectorUpsertRequest) String 

func (x *VectorUpsertRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.