Documentation
¶
Index ¶
- Variables
- func RegisterIndraDBServer(s grpc.ServiceRegistrar, srv IndraDBServer)
- type BulkInsertItem
- func (*BulkInsertItem) Descriptor() ([]byte, []int)deprecated
- func (x *BulkInsertItem) GetEdge() *EdgeKey
- func (x *BulkInsertItem) GetEdgeProperty() *EdgePropertyBulkInsertItem
- func (m *BulkInsertItem) GetItem() isBulkInsertItem_Item
- func (x *BulkInsertItem) GetVertex() *Vertex
- func (x *BulkInsertItem) GetVertexProperty() *VertexPropertyBulkInsertItem
- func (*BulkInsertItem) ProtoMessage()
- func (x *BulkInsertItem) ProtoReflect() protoreflect.Message
- func (x *BulkInsertItem) Reset()
- func (x *BulkInsertItem) String() string
- type BulkInsertItem_Edge
- type BulkInsertItem_EdgeProperty
- type BulkInsertItem_Vertex
- type BulkInsertItem_VertexProperty
- type CountResponse
- type CreateResponse
- type Edge
- type EdgeDirection
- func (EdgeDirection) Descriptor() protoreflect.EnumDescriptor
- func (x EdgeDirection) Enum() *EdgeDirection
- func (EdgeDirection) EnumDescriptor() ([]byte, []int)deprecated
- func (x EdgeDirection) Number() protoreflect.EnumNumber
- func (x EdgeDirection) String() string
- func (EdgeDirection) Type() protoreflect.EnumType
- type EdgeKey
- func (*EdgeKey) Descriptor() ([]byte, []int)deprecated
- func (x *EdgeKey) GetInboundId() *Uuid
- func (x *EdgeKey) GetOutboundId() *Uuid
- func (x *EdgeKey) GetT() *Identifier
- func (*EdgeKey) ProtoMessage()
- func (x *EdgeKey) ProtoReflect() protoreflect.Message
- func (x *EdgeKey) Reset()
- func (x *EdgeKey) String() string
- type EdgeProperties
- func (*EdgeProperties) Descriptor() ([]byte, []int)deprecated
- func (x *EdgeProperties) GetEdge() *Edge
- func (x *EdgeProperties) GetProps() []*NamedProperty
- func (*EdgeProperties) ProtoMessage()
- func (x *EdgeProperties) ProtoReflect() protoreflect.Message
- func (x *EdgeProperties) Reset()
- func (x *EdgeProperties) String() string
- type EdgeProperty
- func (*EdgeProperty) Descriptor() ([]byte, []int)deprecated
- func (x *EdgeProperty) GetKey() *EdgeKey
- func (x *EdgeProperty) GetValue() *Json
- func (*EdgeProperty) ProtoMessage()
- func (x *EdgeProperty) ProtoReflect() protoreflect.Message
- func (x *EdgeProperty) Reset()
- func (x *EdgeProperty) String() string
- type EdgePropertyBulkInsertItem
- func (*EdgePropertyBulkInsertItem) Descriptor() ([]byte, []int)deprecated
- func (x *EdgePropertyBulkInsertItem) GetKey() *EdgeKey
- func (x *EdgePropertyBulkInsertItem) GetName() *Identifier
- func (x *EdgePropertyBulkInsertItem) GetValue() *Json
- func (*EdgePropertyBulkInsertItem) ProtoMessage()
- func (x *EdgePropertyBulkInsertItem) ProtoReflect() protoreflect.Message
- func (x *EdgePropertyBulkInsertItem) Reset()
- func (x *EdgePropertyBulkInsertItem) String() string
- type EdgePropertyQuery
- func (*EdgePropertyQuery) Descriptor() ([]byte, []int)deprecated
- func (x *EdgePropertyQuery) GetInner() *EdgeQuery
- func (x *EdgePropertyQuery) GetName() *Identifier
- func (*EdgePropertyQuery) ProtoMessage()
- func (x *EdgePropertyQuery) ProtoReflect() protoreflect.Message
- func (x *EdgePropertyQuery) Reset()
- func (x *EdgePropertyQuery) String() string
- type EdgeQuery
- func (*EdgeQuery) Descriptor() ([]byte, []int)deprecated
- func (x *EdgeQuery) GetPipe() *PipeEdgeQuery
- func (x *EdgeQuery) GetPipePropertyPresence() *PipePropertyPresenceEdgeQuery
- func (x *EdgeQuery) GetPipePropertyValue() *PipePropertyValueEdgeQuery
- func (x *EdgeQuery) GetPropertyPresence() *PropertyPresenceEdgeQuery
- func (x *EdgeQuery) GetPropertyValue() *PropertyValueEdgeQuery
- func (m *EdgeQuery) GetQuery() isEdgeQuery_Query
- func (x *EdgeQuery) GetSpecific() *SpecificEdgeQuery
- func (*EdgeQuery) ProtoMessage()
- func (x *EdgeQuery) ProtoReflect() protoreflect.Message
- func (x *EdgeQuery) Reset()
- func (x *EdgeQuery) String() string
- type EdgeQuery_Pipe
- type EdgeQuery_PipePropertyPresence
- type EdgeQuery_PipePropertyValue
- type EdgeQuery_PropertyPresence
- type EdgeQuery_PropertyValue
- type EdgeQuery_Specific
- type ExecutePluginRequest
- func (*ExecutePluginRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutePluginRequest) GetArg() *Json
- func (x *ExecutePluginRequest) GetName() string
- func (*ExecutePluginRequest) ProtoMessage()
- func (x *ExecutePluginRequest) ProtoReflect() protoreflect.Message
- func (x *ExecutePluginRequest) Reset()
- func (x *ExecutePluginRequest) String() string
- type ExecutePluginResponse
- func (*ExecutePluginResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutePluginResponse) GetValue() *Json
- func (*ExecutePluginResponse) ProtoMessage()
- func (x *ExecutePluginResponse) ProtoReflect() protoreflect.Message
- func (x *ExecutePluginResponse) Reset()
- func (x *ExecutePluginResponse) String() string
- type GetEdgeCountRequest
- func (*GetEdgeCountRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEdgeCountRequest) GetDirection() EdgeDirection
- func (x *GetEdgeCountRequest) GetId() *Uuid
- func (x *GetEdgeCountRequest) GetT() *Identifier
- func (*GetEdgeCountRequest) ProtoMessage()
- func (x *GetEdgeCountRequest) ProtoReflect() protoreflect.Message
- func (x *GetEdgeCountRequest) Reset()
- func (x *GetEdgeCountRequest) String() string
- type Identifier
- type IndexEntry
- type IndexPropertyRequest
- func (*IndexPropertyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IndexPropertyRequest) GetName() *Identifier
- func (*IndexPropertyRequest) ProtoMessage()
- func (x *IndexPropertyRequest) ProtoReflect() protoreflect.Message
- func (x *IndexPropertyRequest) Reset()
- func (x *IndexPropertyRequest) String() string
- type IndraDBClient
- type IndraDBServer
- type IndraDB_BulkInsertClient
- type IndraDB_BulkInsertServer
- type IndraDB_GetAllEdgePropertiesClient
- type IndraDB_GetAllEdgePropertiesServer
- type IndraDB_GetAllVertexPropertiesClient
- type IndraDB_GetAllVertexPropertiesServer
- type IndraDB_GetEdgePropertiesClient
- type IndraDB_GetEdgePropertiesServer
- type IndraDB_GetEdgesClient
- type IndraDB_GetEdgesServer
- type IndraDB_GetVertexPropertiesClient
- type IndraDB_GetVertexPropertiesServer
- type IndraDB_GetVerticesClient
- type IndraDB_GetVerticesServer
- type Json
- type NamedProperty
- func (*NamedProperty) Descriptor() ([]byte, []int)deprecated
- func (x *NamedProperty) GetName() *Identifier
- func (x *NamedProperty) GetValue() *Json
- func (*NamedProperty) ProtoMessage()
- func (x *NamedProperty) ProtoReflect() protoreflect.Message
- func (x *NamedProperty) Reset()
- func (x *NamedProperty) String() string
- type PipeEdgeQuery
- func (*PipeEdgeQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PipeEdgeQuery) GetDirection() EdgeDirection
- func (x *PipeEdgeQuery) GetHigh() *timestamppb.Timestamp
- func (x *PipeEdgeQuery) GetInner() *VertexQuery
- func (x *PipeEdgeQuery) GetLimit() uint32
- func (x *PipeEdgeQuery) GetLow() *timestamppb.Timestamp
- func (x *PipeEdgeQuery) GetT() *Identifier
- func (*PipeEdgeQuery) ProtoMessage()
- func (x *PipeEdgeQuery) ProtoReflect() protoreflect.Message
- func (x *PipeEdgeQuery) Reset()
- func (x *PipeEdgeQuery) String() string
- type PipePropertyPresenceEdgeQuery
- func (*PipePropertyPresenceEdgeQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PipePropertyPresenceEdgeQuery) GetExists() bool
- func (x *PipePropertyPresenceEdgeQuery) GetInner() *EdgeQuery
- func (x *PipePropertyPresenceEdgeQuery) GetName() *Identifier
- func (*PipePropertyPresenceEdgeQuery) ProtoMessage()
- func (x *PipePropertyPresenceEdgeQuery) ProtoReflect() protoreflect.Message
- func (x *PipePropertyPresenceEdgeQuery) Reset()
- func (x *PipePropertyPresenceEdgeQuery) String() string
- type PipePropertyPresenceVertexQuery
- func (*PipePropertyPresenceVertexQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PipePropertyPresenceVertexQuery) GetExists() bool
- func (x *PipePropertyPresenceVertexQuery) GetInner() *VertexQuery
- func (x *PipePropertyPresenceVertexQuery) GetName() *Identifier
- func (*PipePropertyPresenceVertexQuery) ProtoMessage()
- func (x *PipePropertyPresenceVertexQuery) ProtoReflect() protoreflect.Message
- func (x *PipePropertyPresenceVertexQuery) Reset()
- func (x *PipePropertyPresenceVertexQuery) String() string
- type PipePropertyValueEdgeQuery
- func (*PipePropertyValueEdgeQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PipePropertyValueEdgeQuery) GetEqual() bool
- func (x *PipePropertyValueEdgeQuery) GetInner() *EdgeQuery
- func (x *PipePropertyValueEdgeQuery) GetName() *Identifier
- func (x *PipePropertyValueEdgeQuery) GetValue() *Json
- func (*PipePropertyValueEdgeQuery) ProtoMessage()
- func (x *PipePropertyValueEdgeQuery) ProtoReflect() protoreflect.Message
- func (x *PipePropertyValueEdgeQuery) Reset()
- func (x *PipePropertyValueEdgeQuery) String() string
- type PipePropertyValueVertexQuery
- func (*PipePropertyValueVertexQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PipePropertyValueVertexQuery) GetEqual() bool
- func (x *PipePropertyValueVertexQuery) GetInner() *VertexQuery
- func (x *PipePropertyValueVertexQuery) GetName() *Identifier
- func (x *PipePropertyValueVertexQuery) GetValue() *Json
- func (*PipePropertyValueVertexQuery) ProtoMessage()
- func (x *PipePropertyValueVertexQuery) ProtoReflect() protoreflect.Message
- func (x *PipePropertyValueVertexQuery) Reset()
- func (x *PipePropertyValueVertexQuery) String() string
- type PipeVertexQuery
- func (*PipeVertexQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PipeVertexQuery) GetDirection() EdgeDirection
- func (x *PipeVertexQuery) GetInner() *EdgeQuery
- func (x *PipeVertexQuery) GetLimit() uint32
- func (x *PipeVertexQuery) GetT() *Identifier
- func (*PipeVertexQuery) ProtoMessage()
- func (x *PipeVertexQuery) ProtoReflect() protoreflect.Message
- func (x *PipeVertexQuery) Reset()
- func (x *PipeVertexQuery) String() string
- type PropertyPresenceEdgeQuery
- func (*PropertyPresenceEdgeQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PropertyPresenceEdgeQuery) GetName() *Identifier
- func (*PropertyPresenceEdgeQuery) ProtoMessage()
- func (x *PropertyPresenceEdgeQuery) ProtoReflect() protoreflect.Message
- func (x *PropertyPresenceEdgeQuery) Reset()
- func (x *PropertyPresenceEdgeQuery) String() string
- type PropertyPresenceVertexQuery
- func (*PropertyPresenceVertexQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PropertyPresenceVertexQuery) GetName() *Identifier
- func (*PropertyPresenceVertexQuery) ProtoMessage()
- func (x *PropertyPresenceVertexQuery) ProtoReflect() protoreflect.Message
- func (x *PropertyPresenceVertexQuery) Reset()
- func (x *PropertyPresenceVertexQuery) String() string
- type PropertyValueEdgeQuery
- func (*PropertyValueEdgeQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PropertyValueEdgeQuery) GetName() *Identifier
- func (x *PropertyValueEdgeQuery) GetValue() *Json
- func (*PropertyValueEdgeQuery) ProtoMessage()
- func (x *PropertyValueEdgeQuery) ProtoReflect() protoreflect.Message
- func (x *PropertyValueEdgeQuery) Reset()
- func (x *PropertyValueEdgeQuery) String() string
- type PropertyValueVertexQuery
- func (*PropertyValueVertexQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PropertyValueVertexQuery) GetName() *Identifier
- func (x *PropertyValueVertexQuery) GetValue() *Json
- func (*PropertyValueVertexQuery) ProtoMessage()
- func (x *PropertyValueVertexQuery) ProtoReflect() protoreflect.Message
- func (x *PropertyValueVertexQuery) Reset()
- func (x *PropertyValueVertexQuery) String() string
- type RangeVertexQuery
- func (*RangeVertexQuery) Descriptor() ([]byte, []int)deprecated
- func (x *RangeVertexQuery) GetLimit() uint32
- func (x *RangeVertexQuery) GetStartId() *Uuid
- func (x *RangeVertexQuery) GetT() *Identifier
- func (*RangeVertexQuery) ProtoMessage()
- func (x *RangeVertexQuery) ProtoReflect() protoreflect.Message
- func (x *RangeVertexQuery) Reset()
- func (x *RangeVertexQuery) String() string
- type SetEdgePropertiesRequest
- func (*SetEdgePropertiesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetEdgePropertiesRequest) GetQ() *EdgePropertyQuery
- func (x *SetEdgePropertiesRequest) GetValue() *Json
- func (*SetEdgePropertiesRequest) ProtoMessage()
- func (x *SetEdgePropertiesRequest) ProtoReflect() protoreflect.Message
- func (x *SetEdgePropertiesRequest) Reset()
- func (x *SetEdgePropertiesRequest) String() string
- type SetVertexPropertiesRequest
- func (*SetVertexPropertiesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetVertexPropertiesRequest) GetQ() *VertexPropertyQuery
- func (x *SetVertexPropertiesRequest) GetValue() *Json
- func (*SetVertexPropertiesRequest) ProtoMessage()
- func (x *SetVertexPropertiesRequest) ProtoReflect() protoreflect.Message
- func (x *SetVertexPropertiesRequest) Reset()
- func (x *SetVertexPropertiesRequest) String() string
- type SpecificEdgeQuery
- type SpecificVertexQuery
- func (*SpecificVertexQuery) Descriptor() ([]byte, []int)deprecated
- func (x *SpecificVertexQuery) GetIds() []*Uuid
- func (*SpecificVertexQuery) ProtoMessage()
- func (x *SpecificVertexQuery) ProtoReflect() protoreflect.Message
- func (x *SpecificVertexQuery) Reset()
- func (x *SpecificVertexQuery) String() string
- type UnimplementedIndraDBServer
- func (UnimplementedIndraDBServer) BulkInsert(IndraDB_BulkInsertServer) error
- func (UnimplementedIndraDBServer) CreateEdge(context.Context, *EdgeKey) (*CreateResponse, error)
- func (UnimplementedIndraDBServer) CreateVertex(context.Context, *Vertex) (*CreateResponse, error)
- func (UnimplementedIndraDBServer) CreateVertexFromType(context.Context, *Identifier) (*Uuid, error)
- func (UnimplementedIndraDBServer) DeleteEdgeProperties(context.Context, *EdgePropertyQuery) (*emptypb.Empty, error)
- func (UnimplementedIndraDBServer) DeleteEdges(context.Context, *EdgeQuery) (*emptypb.Empty, error)
- func (UnimplementedIndraDBServer) DeleteVertexProperties(context.Context, *VertexPropertyQuery) (*emptypb.Empty, error)
- func (UnimplementedIndraDBServer) DeleteVertices(context.Context, *VertexQuery) (*emptypb.Empty, error)
- func (UnimplementedIndraDBServer) ExecutePlugin(context.Context, *ExecutePluginRequest) (*ExecutePluginResponse, error)
- func (UnimplementedIndraDBServer) GetAllEdgeProperties(*EdgeQuery, IndraDB_GetAllEdgePropertiesServer) error
- func (UnimplementedIndraDBServer) GetAllVertexProperties(*VertexQuery, IndraDB_GetAllVertexPropertiesServer) error
- func (UnimplementedIndraDBServer) GetEdgeCount(context.Context, *GetEdgeCountRequest) (*CountResponse, error)
- func (UnimplementedIndraDBServer) GetEdgeProperties(*EdgePropertyQuery, IndraDB_GetEdgePropertiesServer) error
- func (UnimplementedIndraDBServer) GetEdges(*EdgeQuery, IndraDB_GetEdgesServer) error
- func (UnimplementedIndraDBServer) GetVertexCount(context.Context, *emptypb.Empty) (*CountResponse, error)
- func (UnimplementedIndraDBServer) GetVertexProperties(*VertexPropertyQuery, IndraDB_GetVertexPropertiesServer) error
- func (UnimplementedIndraDBServer) GetVertices(*VertexQuery, IndraDB_GetVerticesServer) error
- func (UnimplementedIndraDBServer) IndexProperty(context.Context, *IndexPropertyRequest) (*emptypb.Empty, error)
- func (UnimplementedIndraDBServer) Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedIndraDBServer) SetEdgeProperties(context.Context, *SetEdgePropertiesRequest) (*emptypb.Empty, error)
- func (UnimplementedIndraDBServer) SetVertexProperties(context.Context, *SetVertexPropertiesRequest) (*emptypb.Empty, error)
- func (UnimplementedIndraDBServer) Sync(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- type UnsafeIndraDBServer
- type Uuid
- type Vertex
- type VertexProperties
- func (*VertexProperties) Descriptor() ([]byte, []int)deprecated
- func (x *VertexProperties) GetProps() []*NamedProperty
- func (x *VertexProperties) GetVertex() *Vertex
- func (*VertexProperties) ProtoMessage()
- func (x *VertexProperties) ProtoReflect() protoreflect.Message
- func (x *VertexProperties) Reset()
- func (x *VertexProperties) String() string
- type VertexProperty
- func (*VertexProperty) Descriptor() ([]byte, []int)deprecated
- func (x *VertexProperty) GetId() *Uuid
- func (x *VertexProperty) GetValue() *Json
- func (*VertexProperty) ProtoMessage()
- func (x *VertexProperty) ProtoReflect() protoreflect.Message
- func (x *VertexProperty) Reset()
- func (x *VertexProperty) String() string
- type VertexPropertyBulkInsertItem
- func (*VertexPropertyBulkInsertItem) Descriptor() ([]byte, []int)deprecated
- func (x *VertexPropertyBulkInsertItem) GetId() *Uuid
- func (x *VertexPropertyBulkInsertItem) GetName() *Identifier
- func (x *VertexPropertyBulkInsertItem) GetValue() *Json
- func (*VertexPropertyBulkInsertItem) ProtoMessage()
- func (x *VertexPropertyBulkInsertItem) ProtoReflect() protoreflect.Message
- func (x *VertexPropertyBulkInsertItem) Reset()
- func (x *VertexPropertyBulkInsertItem) String() string
- type VertexPropertyQuery
- func (*VertexPropertyQuery) Descriptor() ([]byte, []int)deprecated
- func (x *VertexPropertyQuery) GetInner() *VertexQuery
- func (x *VertexPropertyQuery) GetName() *Identifier
- func (*VertexPropertyQuery) ProtoMessage()
- func (x *VertexPropertyQuery) ProtoReflect() protoreflect.Message
- func (x *VertexPropertyQuery) Reset()
- func (x *VertexPropertyQuery) String() string
- type VertexQuery
- func (*VertexQuery) Descriptor() ([]byte, []int)deprecated
- func (x *VertexQuery) GetPipe() *PipeVertexQuery
- func (x *VertexQuery) GetPipePropertyPresence() *PipePropertyPresenceVertexQuery
- func (x *VertexQuery) GetPipePropertyValue() *PipePropertyValueVertexQuery
- func (x *VertexQuery) GetPropertyPresence() *PropertyPresenceVertexQuery
- func (x *VertexQuery) GetPropertyValue() *PropertyValueVertexQuery
- func (m *VertexQuery) GetQuery() isVertexQuery_Query
- func (x *VertexQuery) GetRange() *RangeVertexQuery
- func (x *VertexQuery) GetSpecific() *SpecificVertexQuery
- func (*VertexQuery) ProtoMessage()
- func (x *VertexQuery) ProtoReflect() protoreflect.Message
- func (x *VertexQuery) Reset()
- func (x *VertexQuery) String() string
- type VertexQuery_Pipe
- type VertexQuery_PipePropertyPresence
- type VertexQuery_PipePropertyValue
- type VertexQuery_PropertyPresence
- type VertexQuery_PropertyValue
- type VertexQuery_Range
- type VertexQuery_Specific
Constants ¶
This section is empty.
Variables ¶
var ( EdgeDirection_name = map[int32]string{ 0: "OUTBOUND", 1: "INBOUND", } EdgeDirection_value = map[string]int32{ "OUTBOUND": 0, "INBOUND": 1, } )
Enum value maps for EdgeDirection.
var File_citygraph_proto protoreflect.FileDescriptor
var File_index_proto protoreflect.FileDescriptor
var IndraDB_ServiceDesc = grpc.ServiceDesc{ ServiceName: "indradb.IndraDB", HandlerType: (*IndraDBServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _IndraDB_Ping_Handler, }, { MethodName: "Sync", Handler: _IndraDB_Sync_Handler, }, { MethodName: "CreateVertex", Handler: _IndraDB_CreateVertex_Handler, }, { MethodName: "CreateVertexFromType", Handler: _IndraDB_CreateVertexFromType_Handler, }, { MethodName: "DeleteVertices", Handler: _IndraDB_DeleteVertices_Handler, }, { MethodName: "GetVertexCount", Handler: _IndraDB_GetVertexCount_Handler, }, { MethodName: "CreateEdge", Handler: _IndraDB_CreateEdge_Handler, }, { MethodName: "DeleteEdges", Handler: _IndraDB_DeleteEdges_Handler, }, { MethodName: "GetEdgeCount", Handler: _IndraDB_GetEdgeCount_Handler, }, { MethodName: "SetVertexProperties", Handler: _IndraDB_SetVertexProperties_Handler, }, { MethodName: "DeleteVertexProperties", Handler: _IndraDB_DeleteVertexProperties_Handler, }, { MethodName: "SetEdgeProperties", Handler: _IndraDB_SetEdgeProperties_Handler, }, { MethodName: "DeleteEdgeProperties", Handler: _IndraDB_DeleteEdgeProperties_Handler, }, { MethodName: "IndexProperty", Handler: _IndraDB_IndexProperty_Handler, }, { MethodName: "ExecutePlugin", Handler: _IndraDB_ExecutePlugin_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetVertices", Handler: _IndraDB_GetVertices_Handler, ServerStreams: true, }, { StreamName: "GetEdges", Handler: _IndraDB_GetEdges_Handler, ServerStreams: true, }, { StreamName: "GetVertexProperties", Handler: _IndraDB_GetVertexProperties_Handler, ServerStreams: true, }, { StreamName: "GetAllVertexProperties", Handler: _IndraDB_GetAllVertexProperties_Handler, ServerStreams: true, }, { StreamName: "GetEdgeProperties", Handler: _IndraDB_GetEdgeProperties_Handler, ServerStreams: true, }, { StreamName: "GetAllEdgeProperties", Handler: _IndraDB_GetAllEdgeProperties_Handler, ServerStreams: true, }, { StreamName: "BulkInsert", Handler: _IndraDB_BulkInsert_Handler, ClientStreams: true, }, }, Metadata: "citygraph/citygraph.proto", }
IndraDB_ServiceDesc is the grpc.ServiceDesc for IndraDB service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIndraDBServer ¶
func RegisterIndraDBServer(s grpc.ServiceRegistrar, srv IndraDBServer)
Types ¶
type BulkInsertItem ¶
type BulkInsertItem struct { // Types that are assignable to Item: // *BulkInsertItem_Vertex // *BulkInsertItem_Edge // *BulkInsertItem_VertexProperty // *BulkInsertItem_EdgeProperty Item isBulkInsertItem_Item `protobuf_oneof:"item"` // contains filtered or unexported fields }
An item to insert, as part of a bulk insert request.
func (*BulkInsertItem) Descriptor
deprecated
func (*BulkInsertItem) Descriptor() ([]byte, []int)
Deprecated: Use BulkInsertItem.ProtoReflect.Descriptor instead.
func (*BulkInsertItem) GetEdge ¶
func (x *BulkInsertItem) GetEdge() *EdgeKey
func (*BulkInsertItem) GetEdgeProperty ¶
func (x *BulkInsertItem) GetEdgeProperty() *EdgePropertyBulkInsertItem
func (*BulkInsertItem) GetItem ¶
func (m *BulkInsertItem) GetItem() isBulkInsertItem_Item
func (*BulkInsertItem) GetVertex ¶
func (x *BulkInsertItem) GetVertex() *Vertex
func (*BulkInsertItem) GetVertexProperty ¶
func (x *BulkInsertItem) GetVertexProperty() *VertexPropertyBulkInsertItem
func (*BulkInsertItem) ProtoMessage ¶
func (*BulkInsertItem) ProtoMessage()
func (*BulkInsertItem) ProtoReflect ¶
func (x *BulkInsertItem) ProtoReflect() protoreflect.Message
func (*BulkInsertItem) Reset ¶
func (x *BulkInsertItem) Reset()
func (*BulkInsertItem) String ¶
func (x *BulkInsertItem) String() string
type BulkInsertItem_Edge ¶
type BulkInsertItem_Edge struct {
Edge *EdgeKey `protobuf:"bytes,2,opt,name=edge,proto3,oneof"`
}
type BulkInsertItem_EdgeProperty ¶
type BulkInsertItem_EdgeProperty struct {
EdgeProperty *EdgePropertyBulkInsertItem `protobuf:"bytes,4,opt,name=edge_property,json=edgeProperty,proto3,oneof"`
}
type BulkInsertItem_Vertex ¶
type BulkInsertItem_Vertex struct {
Vertex *Vertex `protobuf:"bytes,1,opt,name=vertex,proto3,oneof"`
}
type BulkInsertItem_VertexProperty ¶
type BulkInsertItem_VertexProperty struct {
VertexProperty *VertexPropertyBulkInsertItem `protobuf:"bytes,3,opt,name=vertex_property,json=vertexProperty,proto3,oneof"`
}
type CountResponse ¶
type CountResponse struct { Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*CountResponse) Descriptor
deprecated
func (*CountResponse) Descriptor() ([]byte, []int)
Deprecated: Use CountResponse.ProtoReflect.Descriptor instead.
func (*CountResponse) GetCount ¶
func (x *CountResponse) GetCount() uint64
func (*CountResponse) ProtoMessage ¶
func (*CountResponse) ProtoMessage()
func (*CountResponse) ProtoReflect ¶
func (x *CountResponse) ProtoReflect() protoreflect.Message
func (*CountResponse) Reset ¶
func (x *CountResponse) Reset()
func (*CountResponse) String ¶
func (x *CountResponse) String() string
type CreateResponse ¶
type CreateResponse struct { Created bool `protobuf:"varint,1,opt,name=created,proto3" json:"created,omitempty"` // contains filtered or unexported fields }
func (*CreateResponse) Descriptor
deprecated
func (*CreateResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.
func (*CreateResponse) GetCreated ¶
func (x *CreateResponse) GetCreated() bool
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) ProtoReflect ¶
func (x *CreateResponse) ProtoReflect() protoreflect.Message
func (*CreateResponse) Reset ¶
func (x *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (x *CreateResponse) String() string
type Edge ¶
type Edge struct { // The key to the edge. Key *EdgeKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // When the edge was created. CreatedDatetime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_datetime,json=createdDatetime,proto3" json:"created_datetime,omitempty"` // contains filtered or unexported fields }
An edge.
Edges are how you would represent a verb or a relationship in the datastore. An example might be "liked" or "reviewed". Edges are typed and directed.
func (*Edge) Descriptor
deprecated
func (*Edge) GetCreatedDatetime ¶
func (x *Edge) GetCreatedDatetime() *timestamppb.Timestamp
func (*Edge) ProtoMessage ¶
func (*Edge) ProtoMessage()
func (*Edge) ProtoReflect ¶
func (x *Edge) ProtoReflect() protoreflect.Message
type EdgeDirection ¶
type EdgeDirection int32
Specifies what kind of items should be piped from one type of query to another.
Edge and vertex queries can build off of one another via pipes - e.g. you can get the outbound edges of a set of vertices by piping from a vertex query to an edge query. `EdgeDirection`s are used to specify which end of things you want to pipe - either the outbound items or the inbound items.
const ( EdgeDirection_OUTBOUND EdgeDirection = 0 EdgeDirection_INBOUND EdgeDirection = 1 )
func (EdgeDirection) Descriptor ¶
func (EdgeDirection) Descriptor() protoreflect.EnumDescriptor
func (EdgeDirection) Enum ¶
func (x EdgeDirection) Enum() *EdgeDirection
func (EdgeDirection) EnumDescriptor
deprecated
func (EdgeDirection) EnumDescriptor() ([]byte, []int)
Deprecated: Use EdgeDirection.Descriptor instead.
func (EdgeDirection) Number ¶
func (x EdgeDirection) Number() protoreflect.EnumNumber
func (EdgeDirection) String ¶
func (x EdgeDirection) String() string
func (EdgeDirection) Type ¶
func (EdgeDirection) Type() protoreflect.EnumType
type EdgeKey ¶
type EdgeKey struct { // The id of the outbound vertex. OutboundId *Uuid `protobuf:"bytes,1,opt,name=outbound_id,json=outboundId,proto3" json:"outbound_id,omitempty"` // The type of the edge. T *Identifier `protobuf:"bytes,2,opt,name=t,proto3" json:"t,omitempty"` // The id of the inbound vertex. InboundId *Uuid `protobuf:"bytes,3,opt,name=inbound_id,json=inboundId,proto3" json:"inbound_id,omitempty"` // contains filtered or unexported fields }
Represents a uniquely identifiable key to an edge.
func (*EdgeKey) Descriptor
deprecated
func (*EdgeKey) GetInboundId ¶
func (*EdgeKey) GetOutboundId ¶
func (*EdgeKey) GetT ¶
func (x *EdgeKey) GetT() *Identifier
func (*EdgeKey) ProtoMessage ¶
func (*EdgeKey) ProtoMessage()
func (*EdgeKey) ProtoReflect ¶
func (x *EdgeKey) ProtoReflect() protoreflect.Message
type EdgeProperties ¶
type EdgeProperties struct { // The edge. Edge *Edge `protobuf:"bytes,1,opt,name=edge,proto3" json:"edge,omitempty"` // All of the edge's properties. Props []*NamedProperty `protobuf:"bytes,2,rep,name=props,proto3" json:"props,omitempty"` // contains filtered or unexported fields }
An edge with properties.
func (*EdgeProperties) Descriptor
deprecated
func (*EdgeProperties) Descriptor() ([]byte, []int)
Deprecated: Use EdgeProperties.ProtoReflect.Descriptor instead.
func (*EdgeProperties) GetEdge ¶
func (x *EdgeProperties) GetEdge() *Edge
func (*EdgeProperties) GetProps ¶
func (x *EdgeProperties) GetProps() []*NamedProperty
func (*EdgeProperties) ProtoMessage ¶
func (*EdgeProperties) ProtoMessage()
func (*EdgeProperties) ProtoReflect ¶
func (x *EdgeProperties) ProtoReflect() protoreflect.Message
func (*EdgeProperties) Reset ¶
func (x *EdgeProperties) Reset()
func (*EdgeProperties) String ¶
func (x *EdgeProperties) String() string
type EdgeProperty ¶
type EdgeProperty struct { // The key to the edge. Key *EdgeKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // The property value. Value *Json `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Represents an edge property.
func (*EdgeProperty) Descriptor
deprecated
func (*EdgeProperty) Descriptor() ([]byte, []int)
Deprecated: Use EdgeProperty.ProtoReflect.Descriptor instead.
func (*EdgeProperty) GetKey ¶
func (x *EdgeProperty) GetKey() *EdgeKey
func (*EdgeProperty) GetValue ¶
func (x *EdgeProperty) GetValue() *Json
func (*EdgeProperty) ProtoMessage ¶
func (*EdgeProperty) ProtoMessage()
func (*EdgeProperty) ProtoReflect ¶
func (x *EdgeProperty) ProtoReflect() protoreflect.Message
func (*EdgeProperty) Reset ¶
func (x *EdgeProperty) Reset()
func (*EdgeProperty) String ¶
func (x *EdgeProperty) String() string
type EdgePropertyBulkInsertItem ¶
type EdgePropertyBulkInsertItem struct { Key *EdgeKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Name *Identifier `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Value *Json `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
An edge property to insert.
func (*EdgePropertyBulkInsertItem) Descriptor
deprecated
func (*EdgePropertyBulkInsertItem) Descriptor() ([]byte, []int)
Deprecated: Use EdgePropertyBulkInsertItem.ProtoReflect.Descriptor instead.
func (*EdgePropertyBulkInsertItem) GetKey ¶
func (x *EdgePropertyBulkInsertItem) GetKey() *EdgeKey
func (*EdgePropertyBulkInsertItem) GetName ¶
func (x *EdgePropertyBulkInsertItem) GetName() *Identifier
func (*EdgePropertyBulkInsertItem) GetValue ¶
func (x *EdgePropertyBulkInsertItem) GetValue() *Json
func (*EdgePropertyBulkInsertItem) ProtoMessage ¶
func (*EdgePropertyBulkInsertItem) ProtoMessage()
func (*EdgePropertyBulkInsertItem) ProtoReflect ¶
func (x *EdgePropertyBulkInsertItem) ProtoReflect() protoreflect.Message
func (*EdgePropertyBulkInsertItem) Reset ¶
func (x *EdgePropertyBulkInsertItem) Reset()
func (*EdgePropertyBulkInsertItem) String ¶
func (x *EdgePropertyBulkInsertItem) String() string
type EdgePropertyQuery ¶
type EdgePropertyQuery struct { // The edge query to build off of. Inner *EdgeQuery `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"` // The name of the property to get. Name *Identifier `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Gets property values associated with edges.
func (*EdgePropertyQuery) Descriptor
deprecated
func (*EdgePropertyQuery) Descriptor() ([]byte, []int)
Deprecated: Use EdgePropertyQuery.ProtoReflect.Descriptor instead.
func (*EdgePropertyQuery) GetInner ¶
func (x *EdgePropertyQuery) GetInner() *EdgeQuery
func (*EdgePropertyQuery) GetName ¶
func (x *EdgePropertyQuery) GetName() *Identifier
func (*EdgePropertyQuery) ProtoMessage ¶
func (*EdgePropertyQuery) ProtoMessage()
func (*EdgePropertyQuery) ProtoReflect ¶
func (x *EdgePropertyQuery) ProtoReflect() protoreflect.Message
func (*EdgePropertyQuery) Reset ¶
func (x *EdgePropertyQuery) Reset()
func (*EdgePropertyQuery) String ¶
func (x *EdgePropertyQuery) String() string
type EdgeQuery ¶
type EdgeQuery struct { // Types that are assignable to Query: // *EdgeQuery_Specific // *EdgeQuery_Pipe // *EdgeQuery_PropertyPresence // *EdgeQuery_PropertyValue // *EdgeQuery_PipePropertyPresence // *EdgeQuery_PipePropertyValue Query isEdgeQuery_Query `protobuf_oneof:"query"` // contains filtered or unexported fields }
A query for edges.
func (*EdgeQuery) Descriptor
deprecated
func (*EdgeQuery) GetPipe ¶
func (x *EdgeQuery) GetPipe() *PipeEdgeQuery
func (*EdgeQuery) GetPipePropertyPresence ¶
func (x *EdgeQuery) GetPipePropertyPresence() *PipePropertyPresenceEdgeQuery
func (*EdgeQuery) GetPipePropertyValue ¶
func (x *EdgeQuery) GetPipePropertyValue() *PipePropertyValueEdgeQuery
func (*EdgeQuery) GetPropertyPresence ¶
func (x *EdgeQuery) GetPropertyPresence() *PropertyPresenceEdgeQuery
func (*EdgeQuery) GetPropertyValue ¶
func (x *EdgeQuery) GetPropertyValue() *PropertyValueEdgeQuery
func (*EdgeQuery) GetSpecific ¶
func (x *EdgeQuery) GetSpecific() *SpecificEdgeQuery
func (*EdgeQuery) ProtoMessage ¶
func (*EdgeQuery) ProtoMessage()
func (*EdgeQuery) ProtoReflect ¶
func (x *EdgeQuery) ProtoReflect() protoreflect.Message
type EdgeQuery_Pipe ¶
type EdgeQuery_Pipe struct {
Pipe *PipeEdgeQuery `protobuf:"bytes,2,opt,name=pipe,proto3,oneof"`
}
type EdgeQuery_PipePropertyPresence ¶
type EdgeQuery_PipePropertyPresence struct {
PipePropertyPresence *PipePropertyPresenceEdgeQuery `protobuf:"bytes,5,opt,name=pipe_property_presence,json=pipePropertyPresence,proto3,oneof"`
}
type EdgeQuery_PipePropertyValue ¶
type EdgeQuery_PipePropertyValue struct {
PipePropertyValue *PipePropertyValueEdgeQuery `protobuf:"bytes,6,opt,name=pipe_property_value,json=pipePropertyValue,proto3,oneof"`
}
type EdgeQuery_PropertyPresence ¶
type EdgeQuery_PropertyPresence struct {
PropertyPresence *PropertyPresenceEdgeQuery `protobuf:"bytes,3,opt,name=property_presence,json=propertyPresence,proto3,oneof"`
}
type EdgeQuery_PropertyValue ¶
type EdgeQuery_PropertyValue struct {
PropertyValue *PropertyValueEdgeQuery `protobuf:"bytes,4,opt,name=property_value,json=propertyValue,proto3,oneof"`
}
type EdgeQuery_Specific ¶
type EdgeQuery_Specific struct {
Specific *SpecificEdgeQuery `protobuf:"bytes,1,opt,name=specific,proto3,oneof"`
}
type ExecutePluginRequest ¶
type ExecutePluginRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Arg *Json `protobuf:"bytes,2,opt,name=arg,proto3" json:"arg,omitempty"` // contains filtered or unexported fields }
A request to execute a plugin.
func (*ExecutePluginRequest) Descriptor
deprecated
func (*ExecutePluginRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecutePluginRequest.ProtoReflect.Descriptor instead.
func (*ExecutePluginRequest) GetArg ¶
func (x *ExecutePluginRequest) GetArg() *Json
func (*ExecutePluginRequest) GetName ¶
func (x *ExecutePluginRequest) GetName() string
func (*ExecutePluginRequest) ProtoMessage ¶
func (*ExecutePluginRequest) ProtoMessage()
func (*ExecutePluginRequest) ProtoReflect ¶
func (x *ExecutePluginRequest) ProtoReflect() protoreflect.Message
func (*ExecutePluginRequest) Reset ¶
func (x *ExecutePluginRequest) Reset()
func (*ExecutePluginRequest) String ¶
func (x *ExecutePluginRequest) String() string
type ExecutePluginResponse ¶
type ExecutePluginResponse struct { Value *Json `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
A response to a plugin execution.
func (*ExecutePluginResponse) Descriptor
deprecated
func (*ExecutePluginResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecutePluginResponse.ProtoReflect.Descriptor instead.
func (*ExecutePluginResponse) GetValue ¶
func (x *ExecutePluginResponse) GetValue() *Json
func (*ExecutePluginResponse) ProtoMessage ¶
func (*ExecutePluginResponse) ProtoMessage()
func (*ExecutePluginResponse) ProtoReflect ¶
func (x *ExecutePluginResponse) ProtoReflect() protoreflect.Message
func (*ExecutePluginResponse) Reset ¶
func (x *ExecutePluginResponse) Reset()
func (*ExecutePluginResponse) String ¶
func (x *ExecutePluginResponse) String() string
type GetEdgeCountRequest ¶
type GetEdgeCountRequest struct { Id *Uuid `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` T *Identifier `protobuf:"bytes,2,opt,name=t,proto3" json:"t,omitempty"` Direction EdgeDirection `protobuf:"varint,3,opt,name=direction,proto3,enum=indradb.EdgeDirection" json:"direction,omitempty"` // contains filtered or unexported fields }
func (*GetEdgeCountRequest) Descriptor
deprecated
func (*GetEdgeCountRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEdgeCountRequest.ProtoReflect.Descriptor instead.
func (*GetEdgeCountRequest) GetDirection ¶
func (x *GetEdgeCountRequest) GetDirection() EdgeDirection
func (*GetEdgeCountRequest) GetId ¶
func (x *GetEdgeCountRequest) GetId() *Uuid
func (*GetEdgeCountRequest) GetT ¶
func (x *GetEdgeCountRequest) GetT() *Identifier
func (*GetEdgeCountRequest) ProtoMessage ¶
func (*GetEdgeCountRequest) ProtoMessage()
func (*GetEdgeCountRequest) ProtoReflect ¶
func (x *GetEdgeCountRequest) ProtoReflect() protoreflect.Message
func (*GetEdgeCountRequest) Reset ¶
func (x *GetEdgeCountRequest) Reset()
func (*GetEdgeCountRequest) String ¶
func (x *GetEdgeCountRequest) String() string
type Identifier ¶
type Identifier struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
/ A string that must be less than 256 characters long, and can only contain / letters, numbers, dashes and underscores. This is used for vertex and edge / types, as well as property names.
func (*Identifier) Descriptor
deprecated
func (*Identifier) Descriptor() ([]byte, []int)
Deprecated: Use Identifier.ProtoReflect.Descriptor instead.
func (*Identifier) GetValue ¶
func (x *Identifier) GetValue() string
func (*Identifier) ProtoMessage ¶
func (*Identifier) ProtoMessage()
func (*Identifier) ProtoReflect ¶
func (x *Identifier) ProtoReflect() protoreflect.Message
func (*Identifier) Reset ¶
func (x *Identifier) Reset()
func (*Identifier) String ¶
func (x *Identifier) String() string
type IndexEntry ¶
type IndexEntry struct { // external_id is an outside ID the graph is being indexed on. ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // vertex_id is the graph vertex being referenced in this index entry. VertexId *Uuid `protobuf:"bytes,2,opt,name=vertex_id,json=vertexId,proto3" json:"vertex_id,omitempty"` // contains filtered or unexported fields }
One entry in the index mapping an ID string to a citygraph vertex UUID.
func (*IndexEntry) Descriptor
deprecated
func (*IndexEntry) Descriptor() ([]byte, []int)
Deprecated: Use IndexEntry.ProtoReflect.Descriptor instead.
func (*IndexEntry) GetExternalId ¶
func (x *IndexEntry) GetExternalId() string
func (*IndexEntry) GetVertexId ¶
func (x *IndexEntry) GetVertexId() *Uuid
func (*IndexEntry) ProtoMessage ¶
func (*IndexEntry) ProtoMessage()
func (*IndexEntry) ProtoReflect ¶
func (x *IndexEntry) ProtoReflect() protoreflect.Message
func (*IndexEntry) Reset ¶
func (x *IndexEntry) Reset()
func (*IndexEntry) String ¶
func (x *IndexEntry) String() string
type IndexPropertyRequest ¶
type IndexPropertyRequest struct { Name *Identifier `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
A request to index a property.
func (*IndexPropertyRequest) Descriptor
deprecated
func (*IndexPropertyRequest) Descriptor() ([]byte, []int)
Deprecated: Use IndexPropertyRequest.ProtoReflect.Descriptor instead.
func (*IndexPropertyRequest) GetName ¶
func (x *IndexPropertyRequest) GetName() *Identifier
func (*IndexPropertyRequest) ProtoMessage ¶
func (*IndexPropertyRequest) ProtoMessage()
func (*IndexPropertyRequest) ProtoReflect ¶
func (x *IndexPropertyRequest) ProtoReflect() protoreflect.Message
func (*IndexPropertyRequest) Reset ¶
func (x *IndexPropertyRequest) Reset()
func (*IndexPropertyRequest) String ¶
func (x *IndexPropertyRequest) String() string
type IndraDBClient ¶
type IndraDBClient interface { // Pings the server. Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) // Syncs persisted content. Depending on the datastore implementation, // this has different meanings - including potentially being a no-op. Sync(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) // Creates a new vertex. Returns whether the vertex was successfully // created - if this is false, it's because a vertex with the same UUID // already exists. CreateVertex(ctx context.Context, in *Vertex, opts ...grpc.CallOption) (*CreateResponse, error) // Creates a new vertex with just a type specification. As opposed to // `CreateVertex`, this is used when you do not want to manually specify // the vertex's UUID. Returns the new vertex's UUID. CreateVertexFromType(ctx context.Context, in *Identifier, opts ...grpc.CallOption) (*Uuid, error) // Gets a range of vertices specified by a query. GetVertices(ctx context.Context, in *VertexQuery, opts ...grpc.CallOption) (IndraDB_GetVerticesClient, error) // Deletes existing vertices specified by a query. DeleteVertices(ctx context.Context, in *VertexQuery, opts ...grpc.CallOption) (*emptypb.Empty, error) // Gets the number of vertices in the datastore. GetVertexCount(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CountResponse, error) // Creates a new edge. If the edge already exists, this will update it // with a new update datetime. Returns whether the edge was successfully // created - if this is false, it's because one of the specified vertices // is missing. CreateEdge(ctx context.Context, in *EdgeKey, opts ...grpc.CallOption) (*CreateResponse, error) // Gets a range of edges specified by a query. GetEdges(ctx context.Context, in *EdgeQuery, opts ...grpc.CallOption) (IndraDB_GetEdgesClient, error) // Deletes a set of edges specified by a query. DeleteEdges(ctx context.Context, in *EdgeQuery, opts ...grpc.CallOption) (*emptypb.Empty, error) // Gets the number of edges associated with a vertex. GetEdgeCount(ctx context.Context, in *GetEdgeCountRequest, opts ...grpc.CallOption) (*CountResponse, error) // Gets vertex properties. GetVertexProperties(ctx context.Context, in *VertexPropertyQuery, opts ...grpc.CallOption) (IndraDB_GetVertexPropertiesClient, error) // Gets vertexes and all properties for each vertex. GetAllVertexProperties(ctx context.Context, in *VertexQuery, opts ...grpc.CallOption) (IndraDB_GetAllVertexPropertiesClient, error) // Sets vertex properties. SetVertexProperties(ctx context.Context, in *SetVertexPropertiesRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Deletes vertex properties. DeleteVertexProperties(ctx context.Context, in *VertexPropertyQuery, opts ...grpc.CallOption) (*emptypb.Empty, error) // Gets edge properties. GetEdgeProperties(ctx context.Context, in *EdgePropertyQuery, opts ...grpc.CallOption) (IndraDB_GetEdgePropertiesClient, error) // Sets edge properties. SetEdgeProperties(ctx context.Context, in *SetEdgePropertiesRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Deletes edge properties. DeleteEdgeProperties(ctx context.Context, in *EdgePropertyQuery, opts ...grpc.CallOption) (*emptypb.Empty, error) // Gets edges and all properties for each edge. GetAllEdgeProperties(ctx context.Context, in *EdgeQuery, opts ...grpc.CallOption) (IndraDB_GetAllEdgePropertiesClient, error) // Bulk inserts many vertices, edges, and/or properties. // // Note that datastores have discretion on how to approach safeguard vs // performance tradeoffs. In particular: // * If the datastore is disk-backed, it may or may not flush before // returning. // * The datastore might not verify for correctness; e.g., it might not // ensure that the relevant vertices exist before inserting an edge. BulkInsert(ctx context.Context, opts ...grpc.CallOption) (IndraDB_BulkInsertClient, error) // Enables indexing on a specified property. When indexing is enabled on a // property, it's possible to query on its presence and values. IndexProperty(ctx context.Context, in *IndexPropertyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Executes a plugin and returns back the response from the plugin. ExecutePlugin(ctx context.Context, in *ExecutePluginRequest, opts ...grpc.CallOption) (*ExecutePluginResponse, error) }
IndraDBClient is the client API for IndraDB service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewIndraDBClient ¶
func NewIndraDBClient(cc grpc.ClientConnInterface) IndraDBClient
type IndraDBServer ¶
type IndraDBServer interface { // Pings the server. Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // Syncs persisted content. Depending on the datastore implementation, // this has different meanings - including potentially being a no-op. Sync(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // Creates a new vertex. Returns whether the vertex was successfully // created - if this is false, it's because a vertex with the same UUID // already exists. CreateVertex(context.Context, *Vertex) (*CreateResponse, error) // Creates a new vertex with just a type specification. As opposed to // `CreateVertex`, this is used when you do not want to manually specify // the vertex's UUID. Returns the new vertex's UUID. CreateVertexFromType(context.Context, *Identifier) (*Uuid, error) // Gets a range of vertices specified by a query. GetVertices(*VertexQuery, IndraDB_GetVerticesServer) error // Deletes existing vertices specified by a query. DeleteVertices(context.Context, *VertexQuery) (*emptypb.Empty, error) // Gets the number of vertices in the datastore. GetVertexCount(context.Context, *emptypb.Empty) (*CountResponse, error) // Creates a new edge. If the edge already exists, this will update it // with a new update datetime. Returns whether the edge was successfully // created - if this is false, it's because one of the specified vertices // is missing. CreateEdge(context.Context, *EdgeKey) (*CreateResponse, error) // Gets a range of edges specified by a query. GetEdges(*EdgeQuery, IndraDB_GetEdgesServer) error // Deletes a set of edges specified by a query. DeleteEdges(context.Context, *EdgeQuery) (*emptypb.Empty, error) // Gets the number of edges associated with a vertex. GetEdgeCount(context.Context, *GetEdgeCountRequest) (*CountResponse, error) // Gets vertex properties. GetVertexProperties(*VertexPropertyQuery, IndraDB_GetVertexPropertiesServer) error // Gets vertexes and all properties for each vertex. GetAllVertexProperties(*VertexQuery, IndraDB_GetAllVertexPropertiesServer) error // Sets vertex properties. SetVertexProperties(context.Context, *SetVertexPropertiesRequest) (*emptypb.Empty, error) // Deletes vertex properties. DeleteVertexProperties(context.Context, *VertexPropertyQuery) (*emptypb.Empty, error) // Gets edge properties. GetEdgeProperties(*EdgePropertyQuery, IndraDB_GetEdgePropertiesServer) error // Sets edge properties. SetEdgeProperties(context.Context, *SetEdgePropertiesRequest) (*emptypb.Empty, error) // Deletes edge properties. DeleteEdgeProperties(context.Context, *EdgePropertyQuery) (*emptypb.Empty, error) // Gets edges and all properties for each edge. GetAllEdgeProperties(*EdgeQuery, IndraDB_GetAllEdgePropertiesServer) error // Bulk inserts many vertices, edges, and/or properties. // // Note that datastores have discretion on how to approach safeguard vs // performance tradeoffs. In particular: // * If the datastore is disk-backed, it may or may not flush before // returning. // * The datastore might not verify for correctness; e.g., it might not // ensure that the relevant vertices exist before inserting an edge. BulkInsert(IndraDB_BulkInsertServer) error // Enables indexing on a specified property. When indexing is enabled on a // property, it's possible to query on its presence and values. IndexProperty(context.Context, *IndexPropertyRequest) (*emptypb.Empty, error) // Executes a plugin and returns back the response from the plugin. ExecutePlugin(context.Context, *ExecutePluginRequest) (*ExecutePluginResponse, error) // contains filtered or unexported methods }
IndraDBServer is the server API for IndraDB service. All implementations must embed UnimplementedIndraDBServer for forward compatibility
type IndraDB_BulkInsertClient ¶
type IndraDB_BulkInsertClient interface { Send(*BulkInsertItem) error CloseAndRecv() (*emptypb.Empty, error) grpc.ClientStream }
type IndraDB_BulkInsertServer ¶
type IndraDB_BulkInsertServer interface { SendAndClose(*emptypb.Empty) error Recv() (*BulkInsertItem, error) grpc.ServerStream }
type IndraDB_GetAllEdgePropertiesClient ¶
type IndraDB_GetAllEdgePropertiesClient interface { Recv() (*EdgeProperties, error) grpc.ClientStream }
type IndraDB_GetAllEdgePropertiesServer ¶
type IndraDB_GetAllEdgePropertiesServer interface { Send(*EdgeProperties) error grpc.ServerStream }
type IndraDB_GetAllVertexPropertiesClient ¶
type IndraDB_GetAllVertexPropertiesClient interface { Recv() (*VertexProperties, error) grpc.ClientStream }
type IndraDB_GetAllVertexPropertiesServer ¶
type IndraDB_GetAllVertexPropertiesServer interface { Send(*VertexProperties) error grpc.ServerStream }
type IndraDB_GetEdgePropertiesClient ¶
type IndraDB_GetEdgePropertiesClient interface { Recv() (*EdgeProperty, error) grpc.ClientStream }
type IndraDB_GetEdgePropertiesServer ¶
type IndraDB_GetEdgePropertiesServer interface { Send(*EdgeProperty) error grpc.ServerStream }
type IndraDB_GetEdgesClient ¶
type IndraDB_GetEdgesClient interface { Recv() (*Edge, error) grpc.ClientStream }
type IndraDB_GetEdgesServer ¶
type IndraDB_GetEdgesServer interface { Send(*Edge) error grpc.ServerStream }
type IndraDB_GetVertexPropertiesClient ¶
type IndraDB_GetVertexPropertiesClient interface { Recv() (*VertexProperty, error) grpc.ClientStream }
type IndraDB_GetVertexPropertiesServer ¶
type IndraDB_GetVertexPropertiesServer interface { Send(*VertexProperty) error grpc.ServerStream }
type IndraDB_GetVerticesClient ¶
type IndraDB_GetVerticesClient interface { Recv() (*Vertex, error) grpc.ClientStream }
type IndraDB_GetVerticesServer ¶
type IndraDB_GetVerticesServer interface { Send(*Vertex) error grpc.ServerStream }
type Json ¶
type Json struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
A JSON value.
func (*Json) Descriptor
deprecated
func (*Json) ProtoMessage ¶
func (*Json) ProtoMessage()
func (*Json) ProtoReflect ¶
func (x *Json) ProtoReflect() protoreflect.Message
type NamedProperty ¶
type NamedProperty struct { // The id of the vertex. Name *Identifier `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // The property value. Value *Json `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
A property.
func (*NamedProperty) Descriptor
deprecated
func (*NamedProperty) Descriptor() ([]byte, []int)
Deprecated: Use NamedProperty.ProtoReflect.Descriptor instead.
func (*NamedProperty) GetName ¶
func (x *NamedProperty) GetName() *Identifier
func (*NamedProperty) GetValue ¶
func (x *NamedProperty) GetValue() *Json
func (*NamedProperty) ProtoMessage ¶
func (*NamedProperty) ProtoMessage()
func (*NamedProperty) ProtoReflect ¶
func (x *NamedProperty) ProtoReflect() protoreflect.Message
func (*NamedProperty) Reset ¶
func (x *NamedProperty) Reset()
func (*NamedProperty) String ¶
func (x *NamedProperty) String() string
type PipeEdgeQuery ¶
type PipeEdgeQuery struct { // The vertex query to build off of. Inner *VertexQuery `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"` // Whether to get outbound or inbound edges on the vertices. Direction EdgeDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=indradb.EdgeDirection" json:"direction,omitempty"` // Filters the type of edges returned. T *Identifier `protobuf:"bytes,3,opt,name=t,proto3" json:"t,omitempty"` // Specifies the newest update datetime for returned edges. High *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=high,proto3" json:"high,omitempty"` // Specifies the oldest update datetime for returned edges. Low *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=low,proto3" json:"low,omitempty"` // Limits the number of edges to get. Limit uint32 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
Gets the edges associated with vertices.
func (*PipeEdgeQuery) Descriptor
deprecated
func (*PipeEdgeQuery) Descriptor() ([]byte, []int)
Deprecated: Use PipeEdgeQuery.ProtoReflect.Descriptor instead.
func (*PipeEdgeQuery) GetDirection ¶
func (x *PipeEdgeQuery) GetDirection() EdgeDirection
func (*PipeEdgeQuery) GetHigh ¶
func (x *PipeEdgeQuery) GetHigh() *timestamppb.Timestamp
func (*PipeEdgeQuery) GetInner ¶
func (x *PipeEdgeQuery) GetInner() *VertexQuery
func (*PipeEdgeQuery) GetLimit ¶
func (x *PipeEdgeQuery) GetLimit() uint32
func (*PipeEdgeQuery) GetLow ¶
func (x *PipeEdgeQuery) GetLow() *timestamppb.Timestamp
func (*PipeEdgeQuery) GetT ¶
func (x *PipeEdgeQuery) GetT() *Identifier
func (*PipeEdgeQuery) ProtoMessage ¶
func (*PipeEdgeQuery) ProtoMessage()
func (*PipeEdgeQuery) ProtoReflect ¶
func (x *PipeEdgeQuery) ProtoReflect() protoreflect.Message
func (*PipeEdgeQuery) Reset ¶
func (x *PipeEdgeQuery) Reset()
func (*PipeEdgeQuery) String ¶
func (x *PipeEdgeQuery) String() string
type PipePropertyPresenceEdgeQuery ¶
type PipePropertyPresenceEdgeQuery struct { // The query to filter. Inner *EdgeQuery `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"` // The name of the property. Name *Identifier `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Whether we should look for property presence or lack thereof. Exists bool `protobuf:"varint,3,opt,name=exists,proto3" json:"exists,omitempty"` // contains filtered or unexported fields }
Gets edges with a property.
func (*PipePropertyPresenceEdgeQuery) Descriptor
deprecated
func (*PipePropertyPresenceEdgeQuery) Descriptor() ([]byte, []int)
Deprecated: Use PipePropertyPresenceEdgeQuery.ProtoReflect.Descriptor instead.
func (*PipePropertyPresenceEdgeQuery) GetExists ¶
func (x *PipePropertyPresenceEdgeQuery) GetExists() bool
func (*PipePropertyPresenceEdgeQuery) GetInner ¶
func (x *PipePropertyPresenceEdgeQuery) GetInner() *EdgeQuery
func (*PipePropertyPresenceEdgeQuery) GetName ¶
func (x *PipePropertyPresenceEdgeQuery) GetName() *Identifier
func (*PipePropertyPresenceEdgeQuery) ProtoMessage ¶
func (*PipePropertyPresenceEdgeQuery) ProtoMessage()
func (*PipePropertyPresenceEdgeQuery) ProtoReflect ¶
func (x *PipePropertyPresenceEdgeQuery) ProtoReflect() protoreflect.Message
func (*PipePropertyPresenceEdgeQuery) Reset ¶
func (x *PipePropertyPresenceEdgeQuery) Reset()
func (*PipePropertyPresenceEdgeQuery) String ¶
func (x *PipePropertyPresenceEdgeQuery) String() string
type PipePropertyPresenceVertexQuery ¶
type PipePropertyPresenceVertexQuery struct { // The query to filter. Inner *VertexQuery `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"` // The name of the property. Name *Identifier `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Whether we should look for property presence or lack thereof. Exists bool `protobuf:"varint,3,opt,name=exists,proto3" json:"exists,omitempty"` // contains filtered or unexported fields }
Gets vertices with a property.
func (*PipePropertyPresenceVertexQuery) Descriptor
deprecated
func (*PipePropertyPresenceVertexQuery) Descriptor() ([]byte, []int)
Deprecated: Use PipePropertyPresenceVertexQuery.ProtoReflect.Descriptor instead.
func (*PipePropertyPresenceVertexQuery) GetExists ¶
func (x *PipePropertyPresenceVertexQuery) GetExists() bool
func (*PipePropertyPresenceVertexQuery) GetInner ¶
func (x *PipePropertyPresenceVertexQuery) GetInner() *VertexQuery
func (*PipePropertyPresenceVertexQuery) GetName ¶
func (x *PipePropertyPresenceVertexQuery) GetName() *Identifier
func (*PipePropertyPresenceVertexQuery) ProtoMessage ¶
func (*PipePropertyPresenceVertexQuery) ProtoMessage()
func (*PipePropertyPresenceVertexQuery) ProtoReflect ¶
func (x *PipePropertyPresenceVertexQuery) ProtoReflect() protoreflect.Message
func (*PipePropertyPresenceVertexQuery) Reset ¶
func (x *PipePropertyPresenceVertexQuery) Reset()
func (*PipePropertyPresenceVertexQuery) String ¶
func (x *PipePropertyPresenceVertexQuery) String() string
type PipePropertyValueEdgeQuery ¶
type PipePropertyValueEdgeQuery struct { // The query to filter. Inner *EdgeQuery `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"` // The name of the property. Name *Identifier `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // The value of the property. Value *Json `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // Whether we should look for property equality or non-equality. Equal bool `protobuf:"varint,4,opt,name=equal,proto3" json:"equal,omitempty"` // contains filtered or unexported fields }
Gets edges with a property equal to a given value.
func (*PipePropertyValueEdgeQuery) Descriptor
deprecated
func (*PipePropertyValueEdgeQuery) Descriptor() ([]byte, []int)
Deprecated: Use PipePropertyValueEdgeQuery.ProtoReflect.Descriptor instead.
func (*PipePropertyValueEdgeQuery) GetEqual ¶
func (x *PipePropertyValueEdgeQuery) GetEqual() bool
func (*PipePropertyValueEdgeQuery) GetInner ¶
func (x *PipePropertyValueEdgeQuery) GetInner() *EdgeQuery
func (*PipePropertyValueEdgeQuery) GetName ¶
func (x *PipePropertyValueEdgeQuery) GetName() *Identifier
func (*PipePropertyValueEdgeQuery) GetValue ¶
func (x *PipePropertyValueEdgeQuery) GetValue() *Json
func (*PipePropertyValueEdgeQuery) ProtoMessage ¶
func (*PipePropertyValueEdgeQuery) ProtoMessage()
func (*PipePropertyValueEdgeQuery) ProtoReflect ¶
func (x *PipePropertyValueEdgeQuery) ProtoReflect() protoreflect.Message
func (*PipePropertyValueEdgeQuery) Reset ¶
func (x *PipePropertyValueEdgeQuery) Reset()
func (*PipePropertyValueEdgeQuery) String ¶
func (x *PipePropertyValueEdgeQuery) String() string
type PipePropertyValueVertexQuery ¶
type PipePropertyValueVertexQuery struct { // The query to filter. Inner *VertexQuery `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"` // The name of the property. Name *Identifier `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // The value of the property. Value *Json `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // Whether we should look for property equality or non-equality. Equal bool `protobuf:"varint,4,opt,name=equal,proto3" json:"equal,omitempty"` // contains filtered or unexported fields }
Gets vertices with a property equal to a given value.
func (*PipePropertyValueVertexQuery) Descriptor
deprecated
func (*PipePropertyValueVertexQuery) Descriptor() ([]byte, []int)
Deprecated: Use PipePropertyValueVertexQuery.ProtoReflect.Descriptor instead.
func (*PipePropertyValueVertexQuery) GetEqual ¶
func (x *PipePropertyValueVertexQuery) GetEqual() bool
func (*PipePropertyValueVertexQuery) GetInner ¶
func (x *PipePropertyValueVertexQuery) GetInner() *VertexQuery
func (*PipePropertyValueVertexQuery) GetName ¶
func (x *PipePropertyValueVertexQuery) GetName() *Identifier
func (*PipePropertyValueVertexQuery) GetValue ¶
func (x *PipePropertyValueVertexQuery) GetValue() *Json
func (*PipePropertyValueVertexQuery) ProtoMessage ¶
func (*PipePropertyValueVertexQuery) ProtoMessage()
func (*PipePropertyValueVertexQuery) ProtoReflect ¶
func (x *PipePropertyValueVertexQuery) ProtoReflect() protoreflect.Message
func (*PipePropertyValueVertexQuery) Reset ¶
func (x *PipePropertyValueVertexQuery) Reset()
func (*PipePropertyValueVertexQuery) String ¶
func (x *PipePropertyValueVertexQuery) String() string
type PipeVertexQuery ¶
type PipeVertexQuery struct { // The edge query to build off of. Inner *EdgeQuery `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"` // Whether to get outbound or inbound vertices on the edges. Direction EdgeDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=indradb.EdgeDirection" json:"direction,omitempty"` // Limits the number of vertices to get. Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` // Filters the type of vertices returned. T *Identifier `protobuf:"bytes,4,opt,name=t,proto3" json:"t,omitempty"` // contains filtered or unexported fields }
Gets the vertices associated with edges.
func (*PipeVertexQuery) Descriptor
deprecated
func (*PipeVertexQuery) Descriptor() ([]byte, []int)
Deprecated: Use PipeVertexQuery.ProtoReflect.Descriptor instead.
func (*PipeVertexQuery) GetDirection ¶
func (x *PipeVertexQuery) GetDirection() EdgeDirection
func (*PipeVertexQuery) GetInner ¶
func (x *PipeVertexQuery) GetInner() *EdgeQuery
func (*PipeVertexQuery) GetLimit ¶
func (x *PipeVertexQuery) GetLimit() uint32
func (*PipeVertexQuery) GetT ¶
func (x *PipeVertexQuery) GetT() *Identifier
func (*PipeVertexQuery) ProtoMessage ¶
func (*PipeVertexQuery) ProtoMessage()
func (*PipeVertexQuery) ProtoReflect ¶
func (x *PipeVertexQuery) ProtoReflect() protoreflect.Message
func (*PipeVertexQuery) Reset ¶
func (x *PipeVertexQuery) Reset()
func (*PipeVertexQuery) String ¶
func (x *PipeVertexQuery) String() string
type PropertyPresenceEdgeQuery ¶
type PropertyPresenceEdgeQuery struct { // The name of the property. Name *Identifier `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Gets edges with a property.
func (*PropertyPresenceEdgeQuery) Descriptor
deprecated
func (*PropertyPresenceEdgeQuery) Descriptor() ([]byte, []int)
Deprecated: Use PropertyPresenceEdgeQuery.ProtoReflect.Descriptor instead.
func (*PropertyPresenceEdgeQuery) GetName ¶
func (x *PropertyPresenceEdgeQuery) GetName() *Identifier
func (*PropertyPresenceEdgeQuery) ProtoMessage ¶
func (*PropertyPresenceEdgeQuery) ProtoMessage()
func (*PropertyPresenceEdgeQuery) ProtoReflect ¶
func (x *PropertyPresenceEdgeQuery) ProtoReflect() protoreflect.Message
func (*PropertyPresenceEdgeQuery) Reset ¶
func (x *PropertyPresenceEdgeQuery) Reset()
func (*PropertyPresenceEdgeQuery) String ¶
func (x *PropertyPresenceEdgeQuery) String() string
type PropertyPresenceVertexQuery ¶
type PropertyPresenceVertexQuery struct { // The name of the property. Name *Identifier `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Gets vertices with a property.
func (*PropertyPresenceVertexQuery) Descriptor
deprecated
func (*PropertyPresenceVertexQuery) Descriptor() ([]byte, []int)
Deprecated: Use PropertyPresenceVertexQuery.ProtoReflect.Descriptor instead.
func (*PropertyPresenceVertexQuery) GetName ¶
func (x *PropertyPresenceVertexQuery) GetName() *Identifier
func (*PropertyPresenceVertexQuery) ProtoMessage ¶
func (*PropertyPresenceVertexQuery) ProtoMessage()
func (*PropertyPresenceVertexQuery) ProtoReflect ¶
func (x *PropertyPresenceVertexQuery) ProtoReflect() protoreflect.Message
func (*PropertyPresenceVertexQuery) Reset ¶
func (x *PropertyPresenceVertexQuery) Reset()
func (*PropertyPresenceVertexQuery) String ¶
func (x *PropertyPresenceVertexQuery) String() string
type PropertyValueEdgeQuery ¶
type PropertyValueEdgeQuery struct { // The name of the property. Name *Identifier `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The value of the property. Value *Json `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Gets edges with a property equal to a given value.
func (*PropertyValueEdgeQuery) Descriptor
deprecated
func (*PropertyValueEdgeQuery) Descriptor() ([]byte, []int)
Deprecated: Use PropertyValueEdgeQuery.ProtoReflect.Descriptor instead.
func (*PropertyValueEdgeQuery) GetName ¶
func (x *PropertyValueEdgeQuery) GetName() *Identifier
func (*PropertyValueEdgeQuery) GetValue ¶
func (x *PropertyValueEdgeQuery) GetValue() *Json
func (*PropertyValueEdgeQuery) ProtoMessage ¶
func (*PropertyValueEdgeQuery) ProtoMessage()
func (*PropertyValueEdgeQuery) ProtoReflect ¶
func (x *PropertyValueEdgeQuery) ProtoReflect() protoreflect.Message
func (*PropertyValueEdgeQuery) Reset ¶
func (x *PropertyValueEdgeQuery) Reset()
func (*PropertyValueEdgeQuery) String ¶
func (x *PropertyValueEdgeQuery) String() string
type PropertyValueVertexQuery ¶
type PropertyValueVertexQuery struct { // The name of the property. Name *Identifier `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The value of the property. Value *Json `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Gets vertices with a property equal to a given value.
func (*PropertyValueVertexQuery) Descriptor
deprecated
func (*PropertyValueVertexQuery) Descriptor() ([]byte, []int)
Deprecated: Use PropertyValueVertexQuery.ProtoReflect.Descriptor instead.
func (*PropertyValueVertexQuery) GetName ¶
func (x *PropertyValueVertexQuery) GetName() *Identifier
func (*PropertyValueVertexQuery) GetValue ¶
func (x *PropertyValueVertexQuery) GetValue() *Json
func (*PropertyValueVertexQuery) ProtoMessage ¶
func (*PropertyValueVertexQuery) ProtoMessage()
func (*PropertyValueVertexQuery) ProtoReflect ¶
func (x *PropertyValueVertexQuery) ProtoReflect() protoreflect.Message
func (*PropertyValueVertexQuery) Reset ¶
func (x *PropertyValueVertexQuery) Reset()
func (*PropertyValueVertexQuery) String ¶
func (x *PropertyValueVertexQuery) String() string
type RangeVertexQuery ¶
type RangeVertexQuery struct { // Limits the number of vertices to get. Limit uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"` // Filters the type of vertices returned. T *Identifier `protobuf:"bytes,2,opt,name=t,proto3" json:"t,omitempty"` // Sets the lowest vertex ID to return. StartId *Uuid `protobuf:"bytes,3,opt,name=start_id,json=startId,proto3" json:"start_id,omitempty"` // contains filtered or unexported fields }
Gets a range of vertices.
func (*RangeVertexQuery) Descriptor
deprecated
func (*RangeVertexQuery) Descriptor() ([]byte, []int)
Deprecated: Use RangeVertexQuery.ProtoReflect.Descriptor instead.
func (*RangeVertexQuery) GetLimit ¶
func (x *RangeVertexQuery) GetLimit() uint32
func (*RangeVertexQuery) GetStartId ¶
func (x *RangeVertexQuery) GetStartId() *Uuid
func (*RangeVertexQuery) GetT ¶
func (x *RangeVertexQuery) GetT() *Identifier
func (*RangeVertexQuery) ProtoMessage ¶
func (*RangeVertexQuery) ProtoMessage()
func (*RangeVertexQuery) ProtoReflect ¶
func (x *RangeVertexQuery) ProtoReflect() protoreflect.Message
func (*RangeVertexQuery) Reset ¶
func (x *RangeVertexQuery) Reset()
func (*RangeVertexQuery) String ¶
func (x *RangeVertexQuery) String() string
type SetEdgePropertiesRequest ¶
type SetEdgePropertiesRequest struct { Q *EdgePropertyQuery `protobuf:"bytes,1,opt,name=q,proto3" json:"q,omitempty"` Value *Json `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*SetEdgePropertiesRequest) Descriptor
deprecated
func (*SetEdgePropertiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetEdgePropertiesRequest.ProtoReflect.Descriptor instead.
func (*SetEdgePropertiesRequest) GetQ ¶
func (x *SetEdgePropertiesRequest) GetQ() *EdgePropertyQuery
func (*SetEdgePropertiesRequest) GetValue ¶
func (x *SetEdgePropertiesRequest) GetValue() *Json
func (*SetEdgePropertiesRequest) ProtoMessage ¶
func (*SetEdgePropertiesRequest) ProtoMessage()
func (*SetEdgePropertiesRequest) ProtoReflect ¶
func (x *SetEdgePropertiesRequest) ProtoReflect() protoreflect.Message
func (*SetEdgePropertiesRequest) Reset ¶
func (x *SetEdgePropertiesRequest) Reset()
func (*SetEdgePropertiesRequest) String ¶
func (x *SetEdgePropertiesRequest) String() string
type SetVertexPropertiesRequest ¶
type SetVertexPropertiesRequest struct { Q *VertexPropertyQuery `protobuf:"bytes,1,opt,name=q,proto3" json:"q,omitempty"` Value *Json `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*SetVertexPropertiesRequest) Descriptor
deprecated
func (*SetVertexPropertiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetVertexPropertiesRequest.ProtoReflect.Descriptor instead.
func (*SetVertexPropertiesRequest) GetQ ¶
func (x *SetVertexPropertiesRequest) GetQ() *VertexPropertyQuery
func (*SetVertexPropertiesRequest) GetValue ¶
func (x *SetVertexPropertiesRequest) GetValue() *Json
func (*SetVertexPropertiesRequest) ProtoMessage ¶
func (*SetVertexPropertiesRequest) ProtoMessage()
func (*SetVertexPropertiesRequest) ProtoReflect ¶
func (x *SetVertexPropertiesRequest) ProtoReflect() protoreflect.Message
func (*SetVertexPropertiesRequest) Reset ¶
func (x *SetVertexPropertiesRequest) Reset()
func (*SetVertexPropertiesRequest) String ¶
func (x *SetVertexPropertiesRequest) String() string
type SpecificEdgeQuery ¶
type SpecificEdgeQuery struct { // The keys of the edges to get. Keys []*EdgeKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // contains filtered or unexported fields }
Gets a specific set of edges.
func (*SpecificEdgeQuery) Descriptor
deprecated
func (*SpecificEdgeQuery) Descriptor() ([]byte, []int)
Deprecated: Use SpecificEdgeQuery.ProtoReflect.Descriptor instead.
func (*SpecificEdgeQuery) GetKeys ¶
func (x *SpecificEdgeQuery) GetKeys() []*EdgeKey
func (*SpecificEdgeQuery) ProtoMessage ¶
func (*SpecificEdgeQuery) ProtoMessage()
func (*SpecificEdgeQuery) ProtoReflect ¶
func (x *SpecificEdgeQuery) ProtoReflect() protoreflect.Message
func (*SpecificEdgeQuery) Reset ¶
func (x *SpecificEdgeQuery) Reset()
func (*SpecificEdgeQuery) String ¶
func (x *SpecificEdgeQuery) String() string
type SpecificVertexQuery ¶
type SpecificVertexQuery struct { // The IDs of the vertices to get. Ids []*Uuid `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
Gets a specific set of vertices.
func (*SpecificVertexQuery) Descriptor
deprecated
func (*SpecificVertexQuery) Descriptor() ([]byte, []int)
Deprecated: Use SpecificVertexQuery.ProtoReflect.Descriptor instead.
func (*SpecificVertexQuery) GetIds ¶
func (x *SpecificVertexQuery) GetIds() []*Uuid
func (*SpecificVertexQuery) ProtoMessage ¶
func (*SpecificVertexQuery) ProtoMessage()
func (*SpecificVertexQuery) ProtoReflect ¶
func (x *SpecificVertexQuery) ProtoReflect() protoreflect.Message
func (*SpecificVertexQuery) Reset ¶
func (x *SpecificVertexQuery) Reset()
func (*SpecificVertexQuery) String ¶
func (x *SpecificVertexQuery) String() string
type UnimplementedIndraDBServer ¶
type UnimplementedIndraDBServer struct { }
UnimplementedIndraDBServer must be embedded to have forward compatible implementations.
func (UnimplementedIndraDBServer) BulkInsert ¶
func (UnimplementedIndraDBServer) BulkInsert(IndraDB_BulkInsertServer) error
func (UnimplementedIndraDBServer) CreateEdge ¶
func (UnimplementedIndraDBServer) CreateEdge(context.Context, *EdgeKey) (*CreateResponse, error)
func (UnimplementedIndraDBServer) CreateVertex ¶
func (UnimplementedIndraDBServer) CreateVertex(context.Context, *Vertex) (*CreateResponse, error)
func (UnimplementedIndraDBServer) CreateVertexFromType ¶
func (UnimplementedIndraDBServer) CreateVertexFromType(context.Context, *Identifier) (*Uuid, error)
func (UnimplementedIndraDBServer) DeleteEdgeProperties ¶
func (UnimplementedIndraDBServer) DeleteEdgeProperties(context.Context, *EdgePropertyQuery) (*emptypb.Empty, error)
func (UnimplementedIndraDBServer) DeleteEdges ¶
func (UnimplementedIndraDBServer) DeleteVertexProperties ¶
func (UnimplementedIndraDBServer) DeleteVertexProperties(context.Context, *VertexPropertyQuery) (*emptypb.Empty, error)
func (UnimplementedIndraDBServer) DeleteVertices ¶
func (UnimplementedIndraDBServer) DeleteVertices(context.Context, *VertexQuery) (*emptypb.Empty, error)
func (UnimplementedIndraDBServer) ExecutePlugin ¶
func (UnimplementedIndraDBServer) ExecutePlugin(context.Context, *ExecutePluginRequest) (*ExecutePluginResponse, error)
func (UnimplementedIndraDBServer) GetAllEdgeProperties ¶
func (UnimplementedIndraDBServer) GetAllEdgeProperties(*EdgeQuery, IndraDB_GetAllEdgePropertiesServer) error
func (UnimplementedIndraDBServer) GetAllVertexProperties ¶
func (UnimplementedIndraDBServer) GetAllVertexProperties(*VertexQuery, IndraDB_GetAllVertexPropertiesServer) error
func (UnimplementedIndraDBServer) GetEdgeCount ¶
func (UnimplementedIndraDBServer) GetEdgeCount(context.Context, *GetEdgeCountRequest) (*CountResponse, error)
func (UnimplementedIndraDBServer) GetEdgeProperties ¶
func (UnimplementedIndraDBServer) GetEdgeProperties(*EdgePropertyQuery, IndraDB_GetEdgePropertiesServer) error
func (UnimplementedIndraDBServer) GetEdges ¶
func (UnimplementedIndraDBServer) GetEdges(*EdgeQuery, IndraDB_GetEdgesServer) error
func (UnimplementedIndraDBServer) GetVertexCount ¶
func (UnimplementedIndraDBServer) GetVertexCount(context.Context, *emptypb.Empty) (*CountResponse, error)
func (UnimplementedIndraDBServer) GetVertexProperties ¶
func (UnimplementedIndraDBServer) GetVertexProperties(*VertexPropertyQuery, IndraDB_GetVertexPropertiesServer) error
func (UnimplementedIndraDBServer) GetVertices ¶
func (UnimplementedIndraDBServer) GetVertices(*VertexQuery, IndraDB_GetVerticesServer) error
func (UnimplementedIndraDBServer) IndexProperty ¶
func (UnimplementedIndraDBServer) IndexProperty(context.Context, *IndexPropertyRequest) (*emptypb.Empty, error)
func (UnimplementedIndraDBServer) SetEdgeProperties ¶
func (UnimplementedIndraDBServer) SetEdgeProperties(context.Context, *SetEdgePropertiesRequest) (*emptypb.Empty, error)
func (UnimplementedIndraDBServer) SetVertexProperties ¶
func (UnimplementedIndraDBServer) SetVertexProperties(context.Context, *SetVertexPropertiesRequest) (*emptypb.Empty, error)
type UnsafeIndraDBServer ¶
type UnsafeIndraDBServer interface {
// contains filtered or unexported methods
}
UnsafeIndraDBServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IndraDBServer will result in compilation errors.
type Uuid ¶
type Uuid struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
A UUID.
func (*Uuid) Descriptor
deprecated
func (*Uuid) ProtoMessage ¶
func (*Uuid) ProtoMessage()
func (*Uuid) ProtoReflect ¶
func (x *Uuid) ProtoReflect() protoreflect.Message
type Vertex ¶
type Vertex struct { // The id of the vertex. Id *Uuid `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // The type of the vertex. T *Identifier `protobuf:"bytes,2,opt,name=t,proto3" json:"t,omitempty"` // contains filtered or unexported fields }
A vertex.
Vertices are how you would represent nouns in the datastore. An example might be a user, or a movie. All vertices have a unique ID and a type.
func (*Vertex) Descriptor
deprecated
func (*Vertex) GetT ¶
func (x *Vertex) GetT() *Identifier
func (*Vertex) ProtoMessage ¶
func (*Vertex) ProtoMessage()
func (*Vertex) ProtoReflect ¶
func (x *Vertex) ProtoReflect() protoreflect.Message
type VertexProperties ¶
type VertexProperties struct { // The vertex. Vertex *Vertex `protobuf:"bytes,1,opt,name=vertex,proto3" json:"vertex,omitempty"` // All of the vertex's properties. Props []*NamedProperty `protobuf:"bytes,2,rep,name=props,proto3" json:"props,omitempty"` // contains filtered or unexported fields }
A vertex with properties.
func (*VertexProperties) Descriptor
deprecated
func (*VertexProperties) Descriptor() ([]byte, []int)
Deprecated: Use VertexProperties.ProtoReflect.Descriptor instead.
func (*VertexProperties) GetProps ¶
func (x *VertexProperties) GetProps() []*NamedProperty
func (*VertexProperties) GetVertex ¶
func (x *VertexProperties) GetVertex() *Vertex
func (*VertexProperties) ProtoMessage ¶
func (*VertexProperties) ProtoMessage()
func (*VertexProperties) ProtoReflect ¶
func (x *VertexProperties) ProtoReflect() protoreflect.Message
func (*VertexProperties) Reset ¶
func (x *VertexProperties) Reset()
func (*VertexProperties) String ¶
func (x *VertexProperties) String() string
type VertexProperty ¶
type VertexProperty struct { // The id of the vertex. Id *Uuid `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // The property value. Value *Json `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Represents a vertex property.
func (*VertexProperty) Descriptor
deprecated
func (*VertexProperty) Descriptor() ([]byte, []int)
Deprecated: Use VertexProperty.ProtoReflect.Descriptor instead.
func (*VertexProperty) GetId ¶
func (x *VertexProperty) GetId() *Uuid
func (*VertexProperty) GetValue ¶
func (x *VertexProperty) GetValue() *Json
func (*VertexProperty) ProtoMessage ¶
func (*VertexProperty) ProtoMessage()
func (*VertexProperty) ProtoReflect ¶
func (x *VertexProperty) ProtoReflect() protoreflect.Message
func (*VertexProperty) Reset ¶
func (x *VertexProperty) Reset()
func (*VertexProperty) String ¶
func (x *VertexProperty) String() string
type VertexPropertyBulkInsertItem ¶
type VertexPropertyBulkInsertItem struct { Id *Uuid `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name *Identifier `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Value *Json `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
A vertex property to insert.
func (*VertexPropertyBulkInsertItem) Descriptor
deprecated
func (*VertexPropertyBulkInsertItem) Descriptor() ([]byte, []int)
Deprecated: Use VertexPropertyBulkInsertItem.ProtoReflect.Descriptor instead.
func (*VertexPropertyBulkInsertItem) GetId ¶
func (x *VertexPropertyBulkInsertItem) GetId() *Uuid
func (*VertexPropertyBulkInsertItem) GetName ¶
func (x *VertexPropertyBulkInsertItem) GetName() *Identifier
func (*VertexPropertyBulkInsertItem) GetValue ¶
func (x *VertexPropertyBulkInsertItem) GetValue() *Json
func (*VertexPropertyBulkInsertItem) ProtoMessage ¶
func (*VertexPropertyBulkInsertItem) ProtoMessage()
func (*VertexPropertyBulkInsertItem) ProtoReflect ¶
func (x *VertexPropertyBulkInsertItem) ProtoReflect() protoreflect.Message
func (*VertexPropertyBulkInsertItem) Reset ¶
func (x *VertexPropertyBulkInsertItem) Reset()
func (*VertexPropertyBulkInsertItem) String ¶
func (x *VertexPropertyBulkInsertItem) String() string
type VertexPropertyQuery ¶
type VertexPropertyQuery struct { // The vertex query to build off of. Inner *VertexQuery `protobuf:"bytes,1,opt,name=inner,proto3" json:"inner,omitempty"` // The name of the property to get. Name *Identifier `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Gets property values associated with vertices.
func (*VertexPropertyQuery) Descriptor
deprecated
func (*VertexPropertyQuery) Descriptor() ([]byte, []int)
Deprecated: Use VertexPropertyQuery.ProtoReflect.Descriptor instead.
func (*VertexPropertyQuery) GetInner ¶
func (x *VertexPropertyQuery) GetInner() *VertexQuery
func (*VertexPropertyQuery) GetName ¶
func (x *VertexPropertyQuery) GetName() *Identifier
func (*VertexPropertyQuery) ProtoMessage ¶
func (*VertexPropertyQuery) ProtoMessage()
func (*VertexPropertyQuery) ProtoReflect ¶
func (x *VertexPropertyQuery) ProtoReflect() protoreflect.Message
func (*VertexPropertyQuery) Reset ¶
func (x *VertexPropertyQuery) Reset()
func (*VertexPropertyQuery) String ¶
func (x *VertexPropertyQuery) String() string
type VertexQuery ¶
type VertexQuery struct { // Types that are assignable to Query: // *VertexQuery_Range // *VertexQuery_Specific // *VertexQuery_Pipe // *VertexQuery_PropertyPresence // *VertexQuery_PropertyValue // *VertexQuery_PipePropertyPresence // *VertexQuery_PipePropertyValue Query isVertexQuery_Query `protobuf_oneof:"query"` // contains filtered or unexported fields }
A query for vertices.
func (*VertexQuery) Descriptor
deprecated
func (*VertexQuery) Descriptor() ([]byte, []int)
Deprecated: Use VertexQuery.ProtoReflect.Descriptor instead.
func (*VertexQuery) GetPipe ¶
func (x *VertexQuery) GetPipe() *PipeVertexQuery
func (*VertexQuery) GetPipePropertyPresence ¶
func (x *VertexQuery) GetPipePropertyPresence() *PipePropertyPresenceVertexQuery
func (*VertexQuery) GetPipePropertyValue ¶
func (x *VertexQuery) GetPipePropertyValue() *PipePropertyValueVertexQuery
func (*VertexQuery) GetPropertyPresence ¶
func (x *VertexQuery) GetPropertyPresence() *PropertyPresenceVertexQuery
func (*VertexQuery) GetPropertyValue ¶
func (x *VertexQuery) GetPropertyValue() *PropertyValueVertexQuery
func (*VertexQuery) GetQuery ¶
func (m *VertexQuery) GetQuery() isVertexQuery_Query
func (*VertexQuery) GetRange ¶
func (x *VertexQuery) GetRange() *RangeVertexQuery
func (*VertexQuery) GetSpecific ¶
func (x *VertexQuery) GetSpecific() *SpecificVertexQuery
func (*VertexQuery) ProtoMessage ¶
func (*VertexQuery) ProtoMessage()
func (*VertexQuery) ProtoReflect ¶
func (x *VertexQuery) ProtoReflect() protoreflect.Message
func (*VertexQuery) Reset ¶
func (x *VertexQuery) Reset()
func (*VertexQuery) String ¶
func (x *VertexQuery) String() string
type VertexQuery_Pipe ¶
type VertexQuery_Pipe struct {
Pipe *PipeVertexQuery `protobuf:"bytes,3,opt,name=pipe,proto3,oneof"`
}
type VertexQuery_PipePropertyPresence ¶
type VertexQuery_PipePropertyPresence struct {
PipePropertyPresence *PipePropertyPresenceVertexQuery `protobuf:"bytes,6,opt,name=pipe_property_presence,json=pipePropertyPresence,proto3,oneof"`
}
type VertexQuery_PipePropertyValue ¶
type VertexQuery_PipePropertyValue struct {
PipePropertyValue *PipePropertyValueVertexQuery `protobuf:"bytes,7,opt,name=pipe_property_value,json=pipePropertyValue,proto3,oneof"`
}
type VertexQuery_PropertyPresence ¶
type VertexQuery_PropertyPresence struct {
PropertyPresence *PropertyPresenceVertexQuery `protobuf:"bytes,4,opt,name=property_presence,json=propertyPresence,proto3,oneof"`
}
type VertexQuery_PropertyValue ¶
type VertexQuery_PropertyValue struct {
PropertyValue *PropertyValueVertexQuery `protobuf:"bytes,5,opt,name=property_value,json=propertyValue,proto3,oneof"`
}
type VertexQuery_Range ¶
type VertexQuery_Range struct {
Range *RangeVertexQuery `protobuf:"bytes,1,opt,name=range,proto3,oneof"`
}
type VertexQuery_Specific ¶
type VertexQuery_Specific struct {
Specific *SpecificVertexQuery `protobuf:"bytes,2,opt,name=specific,proto3,oneof"`
}