pb

package
v0.0.0-...-8a1e6a1 Latest Latest
Warning

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

Go to latest
Published: Aug 10, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	EdgeDirection_name = map[int32]string{
		0: "OUTBOUND",
		1: "INBOUND",
	}
	EdgeDirection_value = map[string]int32{
		"OUTBOUND": 0,
		"INBOUND":  1,
	}
)

Enum value maps for EdgeDirection.

View Source
var File_citygraph_proto protoreflect.FileDescriptor
View Source
var File_index_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Edge.ProtoReflect.Descriptor instead.

func (*Edge) GetCreatedDatetime

func (x *Edge) GetCreatedDatetime() *timestamppb.Timestamp

func (*Edge) GetKey

func (x *Edge) GetKey() *EdgeKey

func (*Edge) ProtoMessage

func (*Edge) ProtoMessage()

func (*Edge) ProtoReflect

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

func (*Edge) Reset

func (x *Edge) Reset()

func (*Edge) String

func (x *Edge) String() string

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) Enum

func (x EdgeDirection) Enum() *EdgeDirection

func (EdgeDirection) EnumDescriptor deprecated

func (EdgeDirection) EnumDescriptor() ([]byte, []int)

Deprecated: Use EdgeDirection.Descriptor instead.

func (EdgeDirection) Number

func (EdgeDirection) String

func (x EdgeDirection) String() string

func (EdgeDirection) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use EdgeKey.ProtoReflect.Descriptor instead.

func (*EdgeKey) GetInboundId

func (x *EdgeKey) GetInboundId() *Uuid

func (*EdgeKey) GetOutboundId

func (x *EdgeKey) GetOutboundId() *Uuid

func (*EdgeKey) GetT

func (x *EdgeKey) GetT() *Identifier

func (*EdgeKey) ProtoMessage

func (*EdgeKey) ProtoMessage()

func (*EdgeKey) ProtoReflect

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

func (*EdgeKey) Reset

func (x *EdgeKey) Reset()

func (*EdgeKey) String

func (x *EdgeKey) String() string

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 (*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) Descriptor() ([]byte, []int)

Deprecated: Use EdgeQuery.ProtoReflect.Descriptor instead.

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) GetQuery

func (m *EdgeQuery) GetQuery() isEdgeQuery_Query

func (*EdgeQuery) GetSpecific

func (x *EdgeQuery) GetSpecific() *SpecificEdgeQuery

func (*EdgeQuery) ProtoMessage

func (*EdgeQuery) ProtoMessage()

func (*EdgeQuery) ProtoReflect

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

func (*EdgeQuery) Reset

func (x *EdgeQuery) Reset()

func (*EdgeQuery) String

func (x *EdgeQuery) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Json.ProtoReflect.Descriptor instead.

func (*Json) GetValue

func (x *Json) GetValue() string

func (*Json) ProtoMessage

func (*Json) ProtoMessage()

func (*Json) ProtoReflect

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

func (*Json) Reset

func (x *Json) Reset()

func (*Json) String

func (x *Json) String() string

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 (*PipePropertyPresenceEdgeQuery) GetName

func (*PipePropertyPresenceEdgeQuery) ProtoMessage

func (*PipePropertyPresenceEdgeQuery) ProtoMessage()

func (*PipePropertyPresenceEdgeQuery) ProtoReflect

func (*PipePropertyPresenceEdgeQuery) Reset

func (x *PipePropertyPresenceEdgeQuery) Reset()

func (*PipePropertyPresenceEdgeQuery) 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 (*PipePropertyPresenceVertexQuery) GetName

func (*PipePropertyPresenceVertexQuery) ProtoMessage

func (*PipePropertyPresenceVertexQuery) ProtoMessage()

func (*PipePropertyPresenceVertexQuery) ProtoReflect

func (*PipePropertyPresenceVertexQuery) Reset

func (*PipePropertyPresenceVertexQuery) 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 (*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 (*PipePropertyValueVertexQuery) GetName

func (*PipePropertyValueVertexQuery) GetValue

func (x *PipePropertyValueVertexQuery) GetValue() *Json

func (*PipePropertyValueVertexQuery) ProtoMessage

func (*PipePropertyValueVertexQuery) ProtoMessage()

func (*PipePropertyValueVertexQuery) ProtoReflect

func (*PipePropertyValueVertexQuery) Reset

func (x *PipePropertyValueVertexQuery) Reset()

func (*PipePropertyValueVertexQuery) 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 (*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 (*PropertyPresenceVertexQuery) ProtoMessage

func (*PropertyPresenceVertexQuery) ProtoMessage()

func (*PropertyPresenceVertexQuery) ProtoReflect

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 (*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 (*SetVertexPropertiesRequest) GetValue

func (x *SetVertexPropertiesRequest) GetValue() *Json

func (*SetVertexPropertiesRequest) ProtoMessage

func (*SetVertexPropertiesRequest) ProtoMessage()

func (*SetVertexPropertiesRequest) ProtoReflect

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) CreateEdge

func (UnimplementedIndraDBServer) CreateVertex

func (UnimplementedIndraDBServer) CreateVertexFromType

func (UnimplementedIndraDBServer) CreateVertexFromType(context.Context, *Identifier) (*Uuid, error)

func (UnimplementedIndraDBServer) DeleteEdgeProperties

func (UnimplementedIndraDBServer) DeleteEdges

func (UnimplementedIndraDBServer) DeleteVertexProperties

func (UnimplementedIndraDBServer) DeleteVertices

func (UnimplementedIndraDBServer) ExecutePlugin

func (UnimplementedIndraDBServer) GetAllEdgeProperties

func (UnimplementedIndraDBServer) GetAllVertexProperties

func (UnimplementedIndraDBServer) GetEdgeCount

func (UnimplementedIndraDBServer) GetEdgeProperties

func (UnimplementedIndraDBServer) GetEdges

func (UnimplementedIndraDBServer) GetVertexCount

func (UnimplementedIndraDBServer) GetVertexProperties

func (UnimplementedIndraDBServer) GetVertices

func (UnimplementedIndraDBServer) IndexProperty

func (UnimplementedIndraDBServer) Ping

func (UnimplementedIndraDBServer) SetEdgeProperties

func (UnimplementedIndraDBServer) SetVertexProperties

func (UnimplementedIndraDBServer) Sync

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) Descriptor() ([]byte, []int)

Deprecated: Use Uuid.ProtoReflect.Descriptor instead.

func (*Uuid) GetValue

func (x *Uuid) GetValue() []byte

func (*Uuid) ProtoMessage

func (*Uuid) ProtoMessage()

func (*Uuid) ProtoReflect

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

func (*Uuid) Reset

func (x *Uuid) Reset()

func (*Uuid) String

func (x *Uuid) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Vertex.ProtoReflect.Descriptor instead.

func (*Vertex) GetId

func (x *Vertex) GetId() *Uuid

func (*Vertex) GetT

func (x *Vertex) GetT() *Identifier

func (*Vertex) ProtoMessage

func (*Vertex) ProtoMessage()

func (*Vertex) ProtoReflect

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

func (*Vertex) Reset

func (x *Vertex) Reset()

func (*Vertex) String

func (x *Vertex) String() string

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 (*VertexPropertyBulkInsertItem) GetValue

func (x *VertexPropertyBulkInsertItem) GetValue() *Json

func (*VertexPropertyBulkInsertItem) ProtoMessage

func (*VertexPropertyBulkInsertItem) ProtoMessage()

func (*VertexPropertyBulkInsertItem) ProtoReflect

func (*VertexPropertyBulkInsertItem) Reset

func (x *VertexPropertyBulkInsertItem) Reset()

func (*VertexPropertyBulkInsertItem) 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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL