Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterLibrarianMapperServiceServer(s grpc.ServiceRegistrar, srv LibrarianMapperServiceServer)
- type DeleteEdgeRequest
- type DeleteEdgeResponse
- type DeleteVertexRequest
- func (*DeleteVertexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteVertexRequest) GetVidList() []int64
- func (*DeleteVertexRequest) ProtoMessage()
- func (x *DeleteVertexRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteVertexRequest) Reset()
- func (x *DeleteVertexRequest) String() string
- type DeleteVertexResponse
- type Edge
- func (*Edge) Descriptor() ([]byte, []int)deprecated
- func (x *Edge) GetDstVid() int64
- func (x *Edge) GetProp() *EdgeProp
- func (x *Edge) GetSrcVid() int64
- func (x *Edge) GetType() EdgeType
- func (*Edge) ProtoMessage()
- func (x *Edge) ProtoReflect() protoreflect.Message
- func (x *Edge) Reset()
- func (x *Edge) String() string
- type EdgeCommonProp
- func (*EdgeCommonProp) Descriptor() ([]byte, []int)deprecated
- func (x *EdgeCommonProp) GetCreateTime() *timestamppb.Timestamp
- func (x *EdgeCommonProp) GetOccurTime() *timestamppb.Timestamp
- func (x *EdgeCommonProp) GetRank() int64
- func (x *EdgeCommonProp) GetUpdateTime() *timestamppb.Timestamp
- func (*EdgeCommonProp) ProtoMessage()
- func (x *EdgeCommonProp) ProtoReflect() protoreflect.Message
- func (x *EdgeCommonProp) Reset()
- func (x *EdgeCommonProp) String() string
- 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 EdgeProp
- func (*EdgeProp) Descriptor() ([]byte, []int)deprecated
- func (x *EdgeProp) GetAdditional() map[string]int64
- func (x *EdgeProp) GetCommon() *EdgeCommonProp
- func (*EdgeProp) ProtoMessage()
- func (x *EdgeProp) ProtoReflect() protoreflect.Message
- func (x *EdgeProp) Reset()
- func (x *EdgeProp) String() string
- type EdgeType
- type FetchEqualVertexNeighborRequest
- func (*FetchEqualVertexNeighborRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchEqualVertexNeighborRequest) GetEdgeDirection() EdgeDirection
- func (x *FetchEqualVertexNeighborRequest) GetEdgeTypeFilter() []EdgeType
- func (x *FetchEqualVertexNeighborRequest) GetSrcVid() int64
- func (*FetchEqualVertexNeighborRequest) ProtoMessage()
- func (x *FetchEqualVertexNeighborRequest) ProtoReflect() protoreflect.Message
- func (x *FetchEqualVertexNeighborRequest) Reset()
- func (x *FetchEqualVertexNeighborRequest) String() string
- type FetchEqualVertexNeighborResponse
- func (*FetchEqualVertexNeighborResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchEqualVertexNeighborResponse) GetEdgeList() []*Edge
- func (*FetchEqualVertexNeighborResponse) ProtoMessage()
- func (x *FetchEqualVertexNeighborResponse) ProtoReflect() protoreflect.Message
- func (x *FetchEqualVertexNeighborResponse) Reset()
- func (x *FetchEqualVertexNeighborResponse) String() string
- type FetchEqualVertexRequest
- func (*FetchEqualVertexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchEqualVertexRequest) GetSrcVid() int64
- func (*FetchEqualVertexRequest) ProtoMessage()
- func (x *FetchEqualVertexRequest) ProtoReflect() protoreflect.Message
- func (x *FetchEqualVertexRequest) Reset()
- func (x *FetchEqualVertexRequest) String() string
- type FetchEqualVertexResponse
- func (*FetchEqualVertexResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchEqualVertexResponse) GetVertexList() []*Vertex
- func (*FetchEqualVertexResponse) ProtoMessage()
- func (x *FetchEqualVertexResponse) ProtoReflect() protoreflect.Message
- func (x *FetchEqualVertexResponse) Reset()
- func (x *FetchEqualVertexResponse) String() string
- type FindPathRequest
- func (*FindPathRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FindPathRequest) GetDstVid() []int64
- func (x *FindPathRequest) GetEdgeDirection() EdgeDirection
- func (x *FindPathRequest) GetEdgeTypeFilter() []EdgeType
- func (x *FindPathRequest) GetMaxStep() int64
- func (x *FindPathRequest) GetSrcVid() []int64
- func (*FindPathRequest) ProtoMessage()
- func (x *FindPathRequest) ProtoReflect() protoreflect.Message
- func (x *FindPathRequest) Reset()
- func (x *FindPathRequest) String() string
- type FindPathResponse
- func (*FindPathResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FindPathResponse) GetPathList() []*FindPathResponse_SinglePath
- func (*FindPathResponse) ProtoMessage()
- func (x *FindPathResponse) ProtoReflect() protoreflect.Message
- func (x *FindPathResponse) Reset()
- func (x *FindPathResponse) String() string
- type FindPathResponse_SinglePath
- func (*FindPathResponse_SinglePath) Descriptor() ([]byte, []int)deprecated
- func (x *FindPathResponse_SinglePath) GetEdgeList() []*Edge
- func (*FindPathResponse_SinglePath) ProtoMessage()
- func (x *FindPathResponse_SinglePath) ProtoReflect() protoreflect.Message
- func (x *FindPathResponse_SinglePath) Reset()
- func (x *FindPathResponse_SinglePath) String() string
- type GoFromVertexRequest
- func (*GoFromVertexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GoFromVertexRequest) GetEdgeDirection() EdgeDirection
- func (x *GoFromVertexRequest) GetEdgeTypeFilter() []EdgeType
- func (x *GoFromVertexRequest) GetLimit() int64
- func (x *GoFromVertexRequest) GetMaxStep() int64
- func (x *GoFromVertexRequest) GetMinStep() int64
- func (x *GoFromVertexRequest) GetOffset() int64
- func (x *GoFromVertexRequest) GetSrcVid() int64
- func (*GoFromVertexRequest) ProtoMessage()
- func (x *GoFromVertexRequest) ProtoReflect() protoreflect.Message
- func (x *GoFromVertexRequest) Reset()
- func (x *GoFromVertexRequest) String() string
- type GoFromVertexResponse
- func (*GoFromVertexResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GoFromVertexResponse) GetVertexList() []*Vertex
- func (*GoFromVertexResponse) ProtoMessage()
- func (x *GoFromVertexResponse) ProtoReflect() protoreflect.Message
- func (x *GoFromVertexResponse) Reset()
- func (x *GoFromVertexResponse) String() string
- type InsertEdgeRequest
- type InsertEdgeResponse
- type InsertVertexRequest
- func (*InsertVertexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InsertVertexRequest) GetVertexList() []*Vertex
- func (*InsertVertexRequest) ProtoMessage()
- func (x *InsertVertexRequest) ProtoReflect() protoreflect.Message
- func (x *InsertVertexRequest) Reset()
- func (x *InsertVertexRequest) String() string
- type InsertVertexResponse
- type LibrarianMapperServiceClient
- type LibrarianMapperServiceServer
- type UnimplementedLibrarianMapperServiceServer
- func (UnimplementedLibrarianMapperServiceServer) DeleteEdge(context.Context, *DeleteEdgeRequest) (*DeleteEdgeResponse, error)
- func (UnimplementedLibrarianMapperServiceServer) DeleteVertex(context.Context, *DeleteVertexRequest) (*DeleteVertexResponse, error)
- func (UnimplementedLibrarianMapperServiceServer) FetchEqualVertex(context.Context, *FetchEqualVertexRequest) (*FetchEqualVertexResponse, error)
- func (UnimplementedLibrarianMapperServiceServer) FetchEqualVertexNeighbor(context.Context, *FetchEqualVertexNeighborRequest) (*FetchEqualVertexNeighborResponse, error)
- func (UnimplementedLibrarianMapperServiceServer) FindPath(context.Context, *FindPathRequest) (*FindPathResponse, error)
- func (UnimplementedLibrarianMapperServiceServer) GoFromVertex(context.Context, *GoFromVertexRequest) (*GoFromVertexResponse, error)
- func (UnimplementedLibrarianMapperServiceServer) InsertEdge(context.Context, *InsertEdgeRequest) (*InsertEdgeResponse, error)
- func (UnimplementedLibrarianMapperServiceServer) InsertVertex(context.Context, *InsertVertexRequest) (*InsertVertexResponse, error)
- func (UnimplementedLibrarianMapperServiceServer) UpdateEdge(context.Context, *UpdateEdgeRequest) (*UpdateEdgeResponse, error)
- func (UnimplementedLibrarianMapperServiceServer) UpdateVertex(context.Context, *UpdateVertexRequest) (*UpdateVertexResponse, error)
- type UnsafeLibrarianMapperServiceServer
- type UpdateEdgeRequest
- type UpdateEdgeResponse
- type UpdateVertexRequest
- func (*UpdateVertexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateVertexRequest) GetVertexList() []*Vertex
- func (*UpdateVertexRequest) ProtoMessage()
- func (x *UpdateVertexRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateVertexRequest) Reset()
- func (x *UpdateVertexRequest) String() string
- type UpdateVertexResponse
- type Vertex
- func (*Vertex) Descriptor() ([]byte, []int)deprecated
- func (x *Vertex) GetProp() *VertexProp
- func (x *Vertex) GetType() VertexType
- func (x *Vertex) GetVid() int64
- func (*Vertex) ProtoMessage()
- func (x *Vertex) ProtoReflect() protoreflect.Message
- func (x *Vertex) Reset()
- func (x *Vertex) String() string
- type VertexCommonProp
- func (*VertexCommonProp) Descriptor() ([]byte, []int)deprecated
- func (x *VertexCommonProp) GetCreateTime() *timestamppb.Timestamp
- func (x *VertexCommonProp) GetOccurTime() *timestamppb.Timestamp
- func (x *VertexCommonProp) GetUpdateTime() *timestamppb.Timestamp
- func (*VertexCommonProp) ProtoMessage()
- func (x *VertexCommonProp) ProtoReflect() protoreflect.Message
- func (x *VertexCommonProp) Reset()
- func (x *VertexCommonProp) String() string
- type VertexProp
- func (*VertexProp) Descriptor() ([]byte, []int)deprecated
- func (x *VertexProp) GetAdditional() map[string]int64
- func (x *VertexProp) GetCommon() *VertexCommonProp
- func (*VertexProp) ProtoMessage()
- func (x *VertexProp) ProtoReflect() protoreflect.Message
- func (x *VertexProp) Reset()
- func (x *VertexProp) String() string
- type VertexType
Constants ¶
const ( LibrarianMapperService_InsertVertex_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/InsertVertex" LibrarianMapperService_DeleteVertex_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/DeleteVertex" LibrarianMapperService_UpdateVertex_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/UpdateVertex" LibrarianMapperService_InsertEdge_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/InsertEdge" LibrarianMapperService_DeleteEdge_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/DeleteEdge" LibrarianMapperService_UpdateEdge_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/UpdateEdge" LibrarianMapperService_GoFromVertex_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/GoFromVertex" LibrarianMapperService_FetchEqualVertex_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/FetchEqualVertex" LibrarianMapperService_FetchEqualVertexNeighbor_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/FetchEqualVertexNeighbor" LibrarianMapperService_FindPath_FullMethodName = "/librarian.mapper.v1.LibrarianMapperService/FindPath" )
Variables ¶
var ( VertexType_name = map[int32]string{ 0: "VERTEX_TYPE_UNSPECIFIED", 1: "VERTEX_TYPE_ABSTRACT", 2: "VERTEX_TYPE_ENTITY", 3: "VERTEX_TYPE_MESSAGE", 4: "VERTEX_TYPE_OBJECT", 5: "VERTEX_TYPE_METADATA", } VertexType_value = map[string]int32{ "VERTEX_TYPE_UNSPECIFIED": 0, "VERTEX_TYPE_ABSTRACT": 1, "VERTEX_TYPE_ENTITY": 2, "VERTEX_TYPE_MESSAGE": 3, "VERTEX_TYPE_OBJECT": 4, "VERTEX_TYPE_METADATA": 5, } )
Enum value maps for VertexType.
var ( EdgeType_name = map[int32]string{ 0: "EDGE_TYPE_UNSPECIFIED", 1: "EDGE_TYPE_GENERAL", 2: "EDGE_TYPE_EQUAL", 3: "EDGE_TYPE_CREATE", 4: "EDGE_TYPE_ENJOY", 5: "EDGE_TYPE_MENTION", 6: "EDGE_TYPE_DERIVE", 7: "EDGE_TYPE_CONTROL", 8: "EDGE_TYPE_FOLLOW", 9: "EDGE_TYPE_DESCRIBE", } EdgeType_value = map[string]int32{ "EDGE_TYPE_UNSPECIFIED": 0, "EDGE_TYPE_GENERAL": 1, "EDGE_TYPE_EQUAL": 2, "EDGE_TYPE_CREATE": 3, "EDGE_TYPE_ENJOY": 4, "EDGE_TYPE_MENTION": 5, "EDGE_TYPE_DERIVE": 6, "EDGE_TYPE_CONTROL": 7, "EDGE_TYPE_FOLLOW": 8, "EDGE_TYPE_DESCRIBE": 9, } )
Enum value maps for EdgeType.
var ( EdgeDirection_name = map[int32]string{ 0: "EDGE_DIRECTION_UNSPECIFIED", 1: "EDGE_DIRECTION_OUT", 2: "EDGE_DIRECTION_IN", 3: "EDGE_DIRECTION_BOTH", } EdgeDirection_value = map[string]int32{ "EDGE_DIRECTION_UNSPECIFIED": 0, "EDGE_DIRECTION_OUT": 1, "EDGE_DIRECTION_IN": 2, "EDGE_DIRECTION_BOTH": 3, } )
Enum value maps for EdgeDirection.
var File_librarian_mapper_v1_mapper_proto protoreflect.FileDescriptor
var LibrarianMapperService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "librarian.mapper.v1.LibrarianMapperService", HandlerType: (*LibrarianMapperServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "InsertVertex", Handler: _LibrarianMapperService_InsertVertex_Handler, }, { MethodName: "DeleteVertex", Handler: _LibrarianMapperService_DeleteVertex_Handler, }, { MethodName: "UpdateVertex", Handler: _LibrarianMapperService_UpdateVertex_Handler, }, { MethodName: "InsertEdge", Handler: _LibrarianMapperService_InsertEdge_Handler, }, { MethodName: "DeleteEdge", Handler: _LibrarianMapperService_DeleteEdge_Handler, }, { MethodName: "UpdateEdge", Handler: _LibrarianMapperService_UpdateEdge_Handler, }, { MethodName: "GoFromVertex", Handler: _LibrarianMapperService_GoFromVertex_Handler, }, { MethodName: "FetchEqualVertex", Handler: _LibrarianMapperService_FetchEqualVertex_Handler, }, { MethodName: "FetchEqualVertexNeighbor", Handler: _LibrarianMapperService_FetchEqualVertexNeighbor_Handler, }, { MethodName: "FindPath", Handler: _LibrarianMapperService_FindPath_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "librarian/mapper/v1/mapper.proto", }
LibrarianMapperService_ServiceDesc is the grpc.ServiceDesc for LibrarianMapperService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLibrarianMapperServiceServer ¶
func RegisterLibrarianMapperServiceServer(s grpc.ServiceRegistrar, srv LibrarianMapperServiceServer)
Types ¶
type DeleteEdgeRequest ¶
type DeleteEdgeRequest struct { EdgeList []*Edge `protobuf:"bytes,2,rep,name=edge_list,json=edgeList,proto3" json:"edge_list,omitempty"` // contains filtered or unexported fields }
func (*DeleteEdgeRequest) Descriptor
deprecated
func (*DeleteEdgeRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteEdgeRequest.ProtoReflect.Descriptor instead.
func (*DeleteEdgeRequest) GetEdgeList ¶
func (x *DeleteEdgeRequest) GetEdgeList() []*Edge
func (*DeleteEdgeRequest) ProtoMessage ¶
func (*DeleteEdgeRequest) ProtoMessage()
func (*DeleteEdgeRequest) ProtoReflect ¶
func (x *DeleteEdgeRequest) ProtoReflect() protoreflect.Message
func (*DeleteEdgeRequest) Reset ¶
func (x *DeleteEdgeRequest) Reset()
func (*DeleteEdgeRequest) String ¶
func (x *DeleteEdgeRequest) String() string
type DeleteEdgeResponse ¶
type DeleteEdgeResponse struct {
// contains filtered or unexported fields
}
func (*DeleteEdgeResponse) Descriptor
deprecated
func (*DeleteEdgeResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteEdgeResponse.ProtoReflect.Descriptor instead.
func (*DeleteEdgeResponse) ProtoMessage ¶
func (*DeleteEdgeResponse) ProtoMessage()
func (*DeleteEdgeResponse) ProtoReflect ¶
func (x *DeleteEdgeResponse) ProtoReflect() protoreflect.Message
func (*DeleteEdgeResponse) Reset ¶
func (x *DeleteEdgeResponse) Reset()
func (*DeleteEdgeResponse) String ¶
func (x *DeleteEdgeResponse) String() string
type DeleteVertexRequest ¶
type DeleteVertexRequest struct { VidList []int64 `protobuf:"varint,1,rep,packed,name=vid_list,json=vidList,proto3" json:"vid_list,omitempty"` // contains filtered or unexported fields }
func (*DeleteVertexRequest) Descriptor
deprecated
func (*DeleteVertexRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteVertexRequest.ProtoReflect.Descriptor instead.
func (*DeleteVertexRequest) GetVidList ¶
func (x *DeleteVertexRequest) GetVidList() []int64
func (*DeleteVertexRequest) ProtoMessage ¶
func (*DeleteVertexRequest) ProtoMessage()
func (*DeleteVertexRequest) ProtoReflect ¶
func (x *DeleteVertexRequest) ProtoReflect() protoreflect.Message
func (*DeleteVertexRequest) Reset ¶
func (x *DeleteVertexRequest) Reset()
func (*DeleteVertexRequest) String ¶
func (x *DeleteVertexRequest) String() string
type DeleteVertexResponse ¶
type DeleteVertexResponse struct {
// contains filtered or unexported fields
}
func (*DeleteVertexResponse) Descriptor
deprecated
func (*DeleteVertexResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteVertexResponse.ProtoReflect.Descriptor instead.
func (*DeleteVertexResponse) ProtoMessage ¶
func (*DeleteVertexResponse) ProtoMessage()
func (*DeleteVertexResponse) ProtoReflect ¶
func (x *DeleteVertexResponse) ProtoReflect() protoreflect.Message
func (*DeleteVertexResponse) Reset ¶
func (x *DeleteVertexResponse) Reset()
func (*DeleteVertexResponse) String ¶
func (x *DeleteVertexResponse) String() string
type Edge ¶
type Edge struct { SrcVid int64 `protobuf:"varint,1,opt,name=src_vid,json=srcVid,proto3" json:"src_vid,omitempty"` DstVid int64 `protobuf:"varint,2,opt,name=dst_vid,json=dstVid,proto3" json:"dst_vid,omitempty"` Type EdgeType `protobuf:"varint,3,opt,name=type,proto3,enum=librarian.mapper.v1.EdgeType" json:"type,omitempty"` Prop *EdgeProp `protobuf:"bytes,4,opt,name=prop,proto3,oneof" json:"prop,omitempty"` // contains filtered or unexported fields }
func (*Edge) Descriptor
deprecated
func (*Edge) ProtoMessage ¶
func (*Edge) ProtoMessage()
func (*Edge) ProtoReflect ¶
func (x *Edge) ProtoReflect() protoreflect.Message
type EdgeCommonProp ¶
type EdgeCommonProp struct { OccurTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=occur_time,json=occurTime,proto3,oneof" json:"occur_time,omitempty"` CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3,oneof" json:"create_time,omitempty"` UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3,oneof" json:"update_time,omitempty"` Rank *int64 `protobuf:"varint,4,opt,name=rank,proto3,oneof" json:"rank,omitempty"` // contains filtered or unexported fields }
func (*EdgeCommonProp) Descriptor
deprecated
func (*EdgeCommonProp) Descriptor() ([]byte, []int)
Deprecated: Use EdgeCommonProp.ProtoReflect.Descriptor instead.
func (*EdgeCommonProp) GetCreateTime ¶
func (x *EdgeCommonProp) GetCreateTime() *timestamppb.Timestamp
func (*EdgeCommonProp) GetOccurTime ¶
func (x *EdgeCommonProp) GetOccurTime() *timestamppb.Timestamp
func (*EdgeCommonProp) GetRank ¶
func (x *EdgeCommonProp) GetRank() int64
func (*EdgeCommonProp) GetUpdateTime ¶
func (x *EdgeCommonProp) GetUpdateTime() *timestamppb.Timestamp
func (*EdgeCommonProp) ProtoMessage ¶
func (*EdgeCommonProp) ProtoMessage()
func (*EdgeCommonProp) ProtoReflect ¶
func (x *EdgeCommonProp) ProtoReflect() protoreflect.Message
func (*EdgeCommonProp) Reset ¶
func (x *EdgeCommonProp) Reset()
func (*EdgeCommonProp) String ¶
func (x *EdgeCommonProp) String() string
type EdgeDirection ¶
type EdgeDirection int32
const ( EdgeDirection_EDGE_DIRECTION_UNSPECIFIED EdgeDirection = 0 EdgeDirection_EDGE_DIRECTION_OUT EdgeDirection = 1 EdgeDirection_EDGE_DIRECTION_IN EdgeDirection = 2 EdgeDirection_EDGE_DIRECTION_BOTH EdgeDirection = 3 )
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 EdgeProp ¶
type EdgeProp struct { Common *EdgeCommonProp `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"` Additional map[string]int64 `` /* 162-byte string literal not displayed */ // contains filtered or unexported fields }
func (*EdgeProp) Descriptor
deprecated
func (*EdgeProp) GetAdditional ¶
func (*EdgeProp) GetCommon ¶
func (x *EdgeProp) GetCommon() *EdgeCommonProp
func (*EdgeProp) ProtoMessage ¶
func (*EdgeProp) ProtoMessage()
func (*EdgeProp) ProtoReflect ¶
func (x *EdgeProp) ProtoReflect() protoreflect.Message
type EdgeType ¶
type EdgeType int32
const ( EdgeType_EDGE_TYPE_UNSPECIFIED EdgeType = 0 EdgeType_EDGE_TYPE_GENERAL EdgeType = 1 EdgeType_EDGE_TYPE_EQUAL EdgeType = 2 EdgeType_EDGE_TYPE_CREATE EdgeType = 3 EdgeType_EDGE_TYPE_ENJOY EdgeType = 4 EdgeType_EDGE_TYPE_MENTION EdgeType = 5 EdgeType_EDGE_TYPE_DERIVE EdgeType = 6 EdgeType_EDGE_TYPE_CONTROL EdgeType = 7 EdgeType_EDGE_TYPE_FOLLOW EdgeType = 8 EdgeType_EDGE_TYPE_DESCRIBE EdgeType = 9 )
func (EdgeType) Descriptor ¶
func (EdgeType) Descriptor() protoreflect.EnumDescriptor
func (EdgeType) EnumDescriptor
deprecated
func (EdgeType) Number ¶
func (x EdgeType) Number() protoreflect.EnumNumber
func (EdgeType) Type ¶
func (EdgeType) Type() protoreflect.EnumType
type FetchEqualVertexNeighborRequest ¶
type FetchEqualVertexNeighborRequest struct { SrcVid int64 `protobuf:"varint,1,opt,name=src_vid,json=srcVid,proto3" json:"src_vid,omitempty"` EdgeTypeFilter []EdgeType `` /* 147-byte string literal not displayed */ EdgeDirection EdgeDirection `` /* 140-byte string literal not displayed */ // contains filtered or unexported fields }
func (*FetchEqualVertexNeighborRequest) Descriptor
deprecated
func (*FetchEqualVertexNeighborRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchEqualVertexNeighborRequest.ProtoReflect.Descriptor instead.
func (*FetchEqualVertexNeighborRequest) GetEdgeDirection ¶
func (x *FetchEqualVertexNeighborRequest) GetEdgeDirection() EdgeDirection
func (*FetchEqualVertexNeighborRequest) GetEdgeTypeFilter ¶
func (x *FetchEqualVertexNeighborRequest) GetEdgeTypeFilter() []EdgeType
func (*FetchEqualVertexNeighborRequest) GetSrcVid ¶
func (x *FetchEqualVertexNeighborRequest) GetSrcVid() int64
func (*FetchEqualVertexNeighborRequest) ProtoMessage ¶
func (*FetchEqualVertexNeighborRequest) ProtoMessage()
func (*FetchEqualVertexNeighborRequest) ProtoReflect ¶
func (x *FetchEqualVertexNeighborRequest) ProtoReflect() protoreflect.Message
func (*FetchEqualVertexNeighborRequest) Reset ¶
func (x *FetchEqualVertexNeighborRequest) Reset()
func (*FetchEqualVertexNeighborRequest) String ¶
func (x *FetchEqualVertexNeighborRequest) String() string
type FetchEqualVertexNeighborResponse ¶
type FetchEqualVertexNeighborResponse struct { EdgeList []*Edge `protobuf:"bytes,1,rep,name=edge_list,json=edgeList,proto3" json:"edge_list,omitempty"` // contains filtered or unexported fields }
func (*FetchEqualVertexNeighborResponse) Descriptor
deprecated
func (*FetchEqualVertexNeighborResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchEqualVertexNeighborResponse.ProtoReflect.Descriptor instead.
func (*FetchEqualVertexNeighborResponse) GetEdgeList ¶
func (x *FetchEqualVertexNeighborResponse) GetEdgeList() []*Edge
func (*FetchEqualVertexNeighborResponse) ProtoMessage ¶
func (*FetchEqualVertexNeighborResponse) ProtoMessage()
func (*FetchEqualVertexNeighborResponse) ProtoReflect ¶
func (x *FetchEqualVertexNeighborResponse) ProtoReflect() protoreflect.Message
func (*FetchEqualVertexNeighborResponse) Reset ¶
func (x *FetchEqualVertexNeighborResponse) Reset()
func (*FetchEqualVertexNeighborResponse) String ¶
func (x *FetchEqualVertexNeighborResponse) String() string
type FetchEqualVertexRequest ¶
type FetchEqualVertexRequest struct { SrcVid int64 `protobuf:"varint,1,opt,name=src_vid,json=srcVid,proto3" json:"src_vid,omitempty"` // contains filtered or unexported fields }
func (*FetchEqualVertexRequest) Descriptor
deprecated
func (*FetchEqualVertexRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchEqualVertexRequest.ProtoReflect.Descriptor instead.
func (*FetchEqualVertexRequest) GetSrcVid ¶
func (x *FetchEqualVertexRequest) GetSrcVid() int64
func (*FetchEqualVertexRequest) ProtoMessage ¶
func (*FetchEqualVertexRequest) ProtoMessage()
func (*FetchEqualVertexRequest) ProtoReflect ¶
func (x *FetchEqualVertexRequest) ProtoReflect() protoreflect.Message
func (*FetchEqualVertexRequest) Reset ¶
func (x *FetchEqualVertexRequest) Reset()
func (*FetchEqualVertexRequest) String ¶
func (x *FetchEqualVertexRequest) String() string
type FetchEqualVertexResponse ¶
type FetchEqualVertexResponse struct { VertexList []*Vertex `protobuf:"bytes,1,rep,name=vertex_list,json=vertexList,proto3" json:"vertex_list,omitempty"` // contains filtered or unexported fields }
func (*FetchEqualVertexResponse) Descriptor
deprecated
func (*FetchEqualVertexResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchEqualVertexResponse.ProtoReflect.Descriptor instead.
func (*FetchEqualVertexResponse) GetVertexList ¶
func (x *FetchEqualVertexResponse) GetVertexList() []*Vertex
func (*FetchEqualVertexResponse) ProtoMessage ¶
func (*FetchEqualVertexResponse) ProtoMessage()
func (*FetchEqualVertexResponse) ProtoReflect ¶
func (x *FetchEqualVertexResponse) ProtoReflect() protoreflect.Message
func (*FetchEqualVertexResponse) Reset ¶
func (x *FetchEqualVertexResponse) Reset()
func (*FetchEqualVertexResponse) String ¶
func (x *FetchEqualVertexResponse) String() string
type FindPathRequest ¶
type FindPathRequest struct { SrcVid []int64 `protobuf:"varint,1,rep,packed,name=src_vid,json=srcVid,proto3" json:"src_vid,omitempty"` DstVid []int64 `protobuf:"varint,2,rep,packed,name=dst_vid,json=dstVid,proto3" json:"dst_vid,omitempty"` EdgeTypeFilter []EdgeType `` /* 147-byte string literal not displayed */ EdgeDirection EdgeDirection `` /* 140-byte string literal not displayed */ MaxStep int64 `protobuf:"varint,5,opt,name=max_step,json=maxStep,proto3" json:"max_step,omitempty"` // contains filtered or unexported fields }
func (*FindPathRequest) Descriptor
deprecated
func (*FindPathRequest) Descriptor() ([]byte, []int)
Deprecated: Use FindPathRequest.ProtoReflect.Descriptor instead.
func (*FindPathRequest) GetDstVid ¶
func (x *FindPathRequest) GetDstVid() []int64
func (*FindPathRequest) GetEdgeDirection ¶
func (x *FindPathRequest) GetEdgeDirection() EdgeDirection
func (*FindPathRequest) GetEdgeTypeFilter ¶
func (x *FindPathRequest) GetEdgeTypeFilter() []EdgeType
func (*FindPathRequest) GetMaxStep ¶
func (x *FindPathRequest) GetMaxStep() int64
func (*FindPathRequest) GetSrcVid ¶
func (x *FindPathRequest) GetSrcVid() []int64
func (*FindPathRequest) ProtoMessage ¶
func (*FindPathRequest) ProtoMessage()
func (*FindPathRequest) ProtoReflect ¶
func (x *FindPathRequest) ProtoReflect() protoreflect.Message
func (*FindPathRequest) Reset ¶
func (x *FindPathRequest) Reset()
func (*FindPathRequest) String ¶
func (x *FindPathRequest) String() string
type FindPathResponse ¶
type FindPathResponse struct { PathList []*FindPathResponse_SinglePath `protobuf:"bytes,1,rep,name=path_list,json=pathList,proto3" json:"path_list,omitempty"` // contains filtered or unexported fields }
func (*FindPathResponse) Descriptor
deprecated
func (*FindPathResponse) Descriptor() ([]byte, []int)
Deprecated: Use FindPathResponse.ProtoReflect.Descriptor instead.
func (*FindPathResponse) GetPathList ¶
func (x *FindPathResponse) GetPathList() []*FindPathResponse_SinglePath
func (*FindPathResponse) ProtoMessage ¶
func (*FindPathResponse) ProtoMessage()
func (*FindPathResponse) ProtoReflect ¶
func (x *FindPathResponse) ProtoReflect() protoreflect.Message
func (*FindPathResponse) Reset ¶
func (x *FindPathResponse) Reset()
func (*FindPathResponse) String ¶
func (x *FindPathResponse) String() string
type FindPathResponse_SinglePath ¶
type FindPathResponse_SinglePath struct { // Path from edge_list[0].src_vid to edge_list[-1].dst_vid // If reverse edge is allowed, begin vid may not be src_vid but dst_vid, the end vid is the same EdgeList []*Edge `protobuf:"bytes,3,rep,name=edge_list,json=edgeList,proto3" json:"edge_list,omitempty"` // contains filtered or unexported fields }
func (*FindPathResponse_SinglePath) Descriptor
deprecated
func (*FindPathResponse_SinglePath) Descriptor() ([]byte, []int)
Deprecated: Use FindPathResponse_SinglePath.ProtoReflect.Descriptor instead.
func (*FindPathResponse_SinglePath) GetEdgeList ¶
func (x *FindPathResponse_SinglePath) GetEdgeList() []*Edge
func (*FindPathResponse_SinglePath) ProtoMessage ¶
func (*FindPathResponse_SinglePath) ProtoMessage()
func (*FindPathResponse_SinglePath) ProtoReflect ¶
func (x *FindPathResponse_SinglePath) ProtoReflect() protoreflect.Message
func (*FindPathResponse_SinglePath) Reset ¶
func (x *FindPathResponse_SinglePath) Reset()
func (*FindPathResponse_SinglePath) String ¶
func (x *FindPathResponse_SinglePath) String() string
type GoFromVertexRequest ¶
type GoFromVertexRequest struct { SrcVid int64 `protobuf:"varint,1,opt,name=src_vid,json=srcVid,proto3" json:"src_vid,omitempty"` EdgeTypeFilter []EdgeType `` /* 147-byte string literal not displayed */ EdgeDirection EdgeDirection `` /* 140-byte string literal not displayed */ MinStep int64 `protobuf:"varint,4,opt,name=min_step,json=minStep,proto3" json:"min_step,omitempty"` MaxStep int64 `protobuf:"varint,5,opt,name=max_step,json=maxStep,proto3" json:"max_step,omitempty"` Limit int64 `protobuf:"varint,14,opt,name=limit,proto3" json:"limit,omitempty"` Offset int64 `protobuf:"varint,15,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
func (*GoFromVertexRequest) Descriptor
deprecated
func (*GoFromVertexRequest) Descriptor() ([]byte, []int)
Deprecated: Use GoFromVertexRequest.ProtoReflect.Descriptor instead.
func (*GoFromVertexRequest) GetEdgeDirection ¶
func (x *GoFromVertexRequest) GetEdgeDirection() EdgeDirection
func (*GoFromVertexRequest) GetEdgeTypeFilter ¶
func (x *GoFromVertexRequest) GetEdgeTypeFilter() []EdgeType
func (*GoFromVertexRequest) GetLimit ¶
func (x *GoFromVertexRequest) GetLimit() int64
func (*GoFromVertexRequest) GetMaxStep ¶
func (x *GoFromVertexRequest) GetMaxStep() int64
func (*GoFromVertexRequest) GetMinStep ¶
func (x *GoFromVertexRequest) GetMinStep() int64
func (*GoFromVertexRequest) GetOffset ¶
func (x *GoFromVertexRequest) GetOffset() int64
func (*GoFromVertexRequest) GetSrcVid ¶
func (x *GoFromVertexRequest) GetSrcVid() int64
func (*GoFromVertexRequest) ProtoMessage ¶
func (*GoFromVertexRequest) ProtoMessage()
func (*GoFromVertexRequest) ProtoReflect ¶
func (x *GoFromVertexRequest) ProtoReflect() protoreflect.Message
func (*GoFromVertexRequest) Reset ¶
func (x *GoFromVertexRequest) Reset()
func (*GoFromVertexRequest) String ¶
func (x *GoFromVertexRequest) String() string
type GoFromVertexResponse ¶
type GoFromVertexResponse struct { VertexList []*Vertex `protobuf:"bytes,1,rep,name=vertex_list,json=vertexList,proto3" json:"vertex_list,omitempty"` // contains filtered or unexported fields }
func (*GoFromVertexResponse) Descriptor
deprecated
func (*GoFromVertexResponse) Descriptor() ([]byte, []int)
Deprecated: Use GoFromVertexResponse.ProtoReflect.Descriptor instead.
func (*GoFromVertexResponse) GetVertexList ¶
func (x *GoFromVertexResponse) GetVertexList() []*Vertex
func (*GoFromVertexResponse) ProtoMessage ¶
func (*GoFromVertexResponse) ProtoMessage()
func (*GoFromVertexResponse) ProtoReflect ¶
func (x *GoFromVertexResponse) ProtoReflect() protoreflect.Message
func (*GoFromVertexResponse) Reset ¶
func (x *GoFromVertexResponse) Reset()
func (*GoFromVertexResponse) String ¶
func (x *GoFromVertexResponse) String() string
type InsertEdgeRequest ¶
type InsertEdgeRequest struct { EdgeList []*Edge `protobuf:"bytes,1,rep,name=edge_list,json=edgeList,proto3" json:"edge_list,omitempty"` // contains filtered or unexported fields }
func (*InsertEdgeRequest) Descriptor
deprecated
func (*InsertEdgeRequest) Descriptor() ([]byte, []int)
Deprecated: Use InsertEdgeRequest.ProtoReflect.Descriptor instead.
func (*InsertEdgeRequest) GetEdgeList ¶
func (x *InsertEdgeRequest) GetEdgeList() []*Edge
func (*InsertEdgeRequest) ProtoMessage ¶
func (*InsertEdgeRequest) ProtoMessage()
func (*InsertEdgeRequest) ProtoReflect ¶
func (x *InsertEdgeRequest) ProtoReflect() protoreflect.Message
func (*InsertEdgeRequest) Reset ¶
func (x *InsertEdgeRequest) Reset()
func (*InsertEdgeRequest) String ¶
func (x *InsertEdgeRequest) String() string
type InsertEdgeResponse ¶
type InsertEdgeResponse struct {
// contains filtered or unexported fields
}
func (*InsertEdgeResponse) Descriptor
deprecated
func (*InsertEdgeResponse) Descriptor() ([]byte, []int)
Deprecated: Use InsertEdgeResponse.ProtoReflect.Descriptor instead.
func (*InsertEdgeResponse) ProtoMessage ¶
func (*InsertEdgeResponse) ProtoMessage()
func (*InsertEdgeResponse) ProtoReflect ¶
func (x *InsertEdgeResponse) ProtoReflect() protoreflect.Message
func (*InsertEdgeResponse) Reset ¶
func (x *InsertEdgeResponse) Reset()
func (*InsertEdgeResponse) String ¶
func (x *InsertEdgeResponse) String() string
type InsertVertexRequest ¶
type InsertVertexRequest struct { VertexList []*Vertex `protobuf:"bytes,1,rep,name=vertex_list,json=vertexList,proto3" json:"vertex_list,omitempty"` // contains filtered or unexported fields }
func (*InsertVertexRequest) Descriptor
deprecated
func (*InsertVertexRequest) Descriptor() ([]byte, []int)
Deprecated: Use InsertVertexRequest.ProtoReflect.Descriptor instead.
func (*InsertVertexRequest) GetVertexList ¶
func (x *InsertVertexRequest) GetVertexList() []*Vertex
func (*InsertVertexRequest) ProtoMessage ¶
func (*InsertVertexRequest) ProtoMessage()
func (*InsertVertexRequest) ProtoReflect ¶
func (x *InsertVertexRequest) ProtoReflect() protoreflect.Message
func (*InsertVertexRequest) Reset ¶
func (x *InsertVertexRequest) Reset()
func (*InsertVertexRequest) String ¶
func (x *InsertVertexRequest) String() string
type InsertVertexResponse ¶
type InsertVertexResponse struct {
// contains filtered or unexported fields
}
func (*InsertVertexResponse) Descriptor
deprecated
func (*InsertVertexResponse) Descriptor() ([]byte, []int)
Deprecated: Use InsertVertexResponse.ProtoReflect.Descriptor instead.
func (*InsertVertexResponse) ProtoMessage ¶
func (*InsertVertexResponse) ProtoMessage()
func (*InsertVertexResponse) ProtoReflect ¶
func (x *InsertVertexResponse) ProtoReflect() protoreflect.Message
func (*InsertVertexResponse) Reset ¶
func (x *InsertVertexResponse) Reset()
func (*InsertVertexResponse) String ¶
func (x *InsertVertexResponse) String() string
type LibrarianMapperServiceClient ¶
type LibrarianMapperServiceClient interface { InsertVertex(ctx context.Context, in *InsertVertexRequest, opts ...grpc.CallOption) (*InsertVertexResponse, error) DeleteVertex(ctx context.Context, in *DeleteVertexRequest, opts ...grpc.CallOption) (*DeleteVertexResponse, error) UpdateVertex(ctx context.Context, in *UpdateVertexRequest, opts ...grpc.CallOption) (*UpdateVertexResponse, error) InsertEdge(ctx context.Context, in *InsertEdgeRequest, opts ...grpc.CallOption) (*InsertEdgeResponse, error) DeleteEdge(ctx context.Context, in *DeleteEdgeRequest, opts ...grpc.CallOption) (*DeleteEdgeResponse, error) UpdateEdge(ctx context.Context, in *UpdateEdgeRequest, opts ...grpc.CallOption) (*UpdateEdgeResponse, error) // Search vertexs from a given start vertex GoFromVertex(ctx context.Context, in *GoFromVertexRequest, opts ...grpc.CallOption) (*GoFromVertexResponse, error) // Get vertexs in the connected subgraph of the `Equal` type edge where the given vertex is located FetchEqualVertex(ctx context.Context, in *FetchEqualVertexRequest, opts ...grpc.CallOption) (*FetchEqualVertexResponse, error) // Get vertexs connected to the connected subgraph of the `Equal` type edge where the given vertex is located FetchEqualVertexNeighbor(ctx context.Context, in *FetchEqualVertexNeighborRequest, opts ...grpc.CallOption) (*FetchEqualVertexNeighborResponse, error) // Find path between two given vertexs FindPath(ctx context.Context, in *FindPathRequest, opts ...grpc.CallOption) (*FindPathResponse, error) }
LibrarianMapperServiceClient is the client API for LibrarianMapperService 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.
The main role of Mapper is to encapsulate graph operations. In Mapper's model:
- Each vertex is uniquely determined by `vid` and can only have one `VERTEX_TYPE_type`
- Each edge is uniquely determined by `src_vid`, `dst_vid` and `EDGE_TYPE_type`. In other words, all edges are directed and edges can be repeated by type difference
- Mapper is not good at handling delete operations, try to avoid delete operations
- Mapper knows the rules for each type of edge and will prevent illegal edges from being created
Vertex Rules: - ABSTRACT is an undetermined type
- If no EQUAL edge linked to ABSTRACT, no need to check any edge rules on it
- If an EQUAL edge is on creating, must check exist edges as the equaled vertex type
- After first EUQAL edge creation, ABSTRACT follow edge rules as the equaled vertex type
Edge Rules: - EQUAL must link vertex with same type - EQUAL is the only undirected edge type, Any changes on EQUAL will affect the reverse direction - CREATE must start at ENTITY - ENJOY must start at ENTITY - MENTION must start at MESSAGE or OBJECT - DERIVE must start at OBJECT - CONTROL must start at ENTITY and end at ENTITY - FOLLOW must start at ENTITY and end at ENTITY - DESCRIBE must start at METADATA
func NewLibrarianMapperServiceClient ¶
func NewLibrarianMapperServiceClient(cc grpc.ClientConnInterface) LibrarianMapperServiceClient
type LibrarianMapperServiceServer ¶
type LibrarianMapperServiceServer interface { InsertVertex(context.Context, *InsertVertexRequest) (*InsertVertexResponse, error) DeleteVertex(context.Context, *DeleteVertexRequest) (*DeleteVertexResponse, error) UpdateVertex(context.Context, *UpdateVertexRequest) (*UpdateVertexResponse, error) InsertEdge(context.Context, *InsertEdgeRequest) (*InsertEdgeResponse, error) DeleteEdge(context.Context, *DeleteEdgeRequest) (*DeleteEdgeResponse, error) UpdateEdge(context.Context, *UpdateEdgeRequest) (*UpdateEdgeResponse, error) // Search vertexs from a given start vertex GoFromVertex(context.Context, *GoFromVertexRequest) (*GoFromVertexResponse, error) // Get vertexs in the connected subgraph of the `Equal` type edge where the given vertex is located FetchEqualVertex(context.Context, *FetchEqualVertexRequest) (*FetchEqualVertexResponse, error) // Get vertexs connected to the connected subgraph of the `Equal` type edge where the given vertex is located FetchEqualVertexNeighbor(context.Context, *FetchEqualVertexNeighborRequest) (*FetchEqualVertexNeighborResponse, error) // Find path between two given vertexs FindPath(context.Context, *FindPathRequest) (*FindPathResponse, error) // contains filtered or unexported methods }
LibrarianMapperServiceServer is the server API for LibrarianMapperService service. All implementations must embed UnimplementedLibrarianMapperServiceServer for forward compatibility.
The main role of Mapper is to encapsulate graph operations. In Mapper's model:
- Each vertex is uniquely determined by `vid` and can only have one `VERTEX_TYPE_type`
- Each edge is uniquely determined by `src_vid`, `dst_vid` and `EDGE_TYPE_type`. In other words, all edges are directed and edges can be repeated by type difference
- Mapper is not good at handling delete operations, try to avoid delete operations
- Mapper knows the rules for each type of edge and will prevent illegal edges from being created
Vertex Rules: - ABSTRACT is an undetermined type
- If no EQUAL edge linked to ABSTRACT, no need to check any edge rules on it
- If an EQUAL edge is on creating, must check exist edges as the equaled vertex type
- After first EUQAL edge creation, ABSTRACT follow edge rules as the equaled vertex type
Edge Rules: - EQUAL must link vertex with same type - EQUAL is the only undirected edge type, Any changes on EQUAL will affect the reverse direction - CREATE must start at ENTITY - ENJOY must start at ENTITY - MENTION must start at MESSAGE or OBJECT - DERIVE must start at OBJECT - CONTROL must start at ENTITY and end at ENTITY - FOLLOW must start at ENTITY and end at ENTITY - DESCRIBE must start at METADATA
type UnimplementedLibrarianMapperServiceServer ¶
type UnimplementedLibrarianMapperServiceServer struct{}
UnimplementedLibrarianMapperServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedLibrarianMapperServiceServer) DeleteEdge ¶
func (UnimplementedLibrarianMapperServiceServer) DeleteEdge(context.Context, *DeleteEdgeRequest) (*DeleteEdgeResponse, error)
func (UnimplementedLibrarianMapperServiceServer) DeleteVertex ¶
func (UnimplementedLibrarianMapperServiceServer) DeleteVertex(context.Context, *DeleteVertexRequest) (*DeleteVertexResponse, error)
func (UnimplementedLibrarianMapperServiceServer) FetchEqualVertex ¶
func (UnimplementedLibrarianMapperServiceServer) FetchEqualVertex(context.Context, *FetchEqualVertexRequest) (*FetchEqualVertexResponse, error)
func (UnimplementedLibrarianMapperServiceServer) FetchEqualVertexNeighbor ¶
func (UnimplementedLibrarianMapperServiceServer) FetchEqualVertexNeighbor(context.Context, *FetchEqualVertexNeighborRequest) (*FetchEqualVertexNeighborResponse, error)
func (UnimplementedLibrarianMapperServiceServer) FindPath ¶
func (UnimplementedLibrarianMapperServiceServer) FindPath(context.Context, *FindPathRequest) (*FindPathResponse, error)
func (UnimplementedLibrarianMapperServiceServer) GoFromVertex ¶
func (UnimplementedLibrarianMapperServiceServer) GoFromVertex(context.Context, *GoFromVertexRequest) (*GoFromVertexResponse, error)
func (UnimplementedLibrarianMapperServiceServer) InsertEdge ¶
func (UnimplementedLibrarianMapperServiceServer) InsertEdge(context.Context, *InsertEdgeRequest) (*InsertEdgeResponse, error)
func (UnimplementedLibrarianMapperServiceServer) InsertVertex ¶
func (UnimplementedLibrarianMapperServiceServer) InsertVertex(context.Context, *InsertVertexRequest) (*InsertVertexResponse, error)
func (UnimplementedLibrarianMapperServiceServer) UpdateEdge ¶
func (UnimplementedLibrarianMapperServiceServer) UpdateEdge(context.Context, *UpdateEdgeRequest) (*UpdateEdgeResponse, error)
func (UnimplementedLibrarianMapperServiceServer) UpdateVertex ¶
func (UnimplementedLibrarianMapperServiceServer) UpdateVertex(context.Context, *UpdateVertexRequest) (*UpdateVertexResponse, error)
type UnsafeLibrarianMapperServiceServer ¶
type UnsafeLibrarianMapperServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLibrarianMapperServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LibrarianMapperServiceServer will result in compilation errors.
type UpdateEdgeRequest ¶
type UpdateEdgeRequest struct { EdgeList []*Edge `protobuf:"bytes,3,rep,name=edge_list,json=edgeList,proto3" json:"edge_list,omitempty"` // contains filtered or unexported fields }
func (*UpdateEdgeRequest) Descriptor
deprecated
func (*UpdateEdgeRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateEdgeRequest.ProtoReflect.Descriptor instead.
func (*UpdateEdgeRequest) GetEdgeList ¶
func (x *UpdateEdgeRequest) GetEdgeList() []*Edge
func (*UpdateEdgeRequest) ProtoMessage ¶
func (*UpdateEdgeRequest) ProtoMessage()
func (*UpdateEdgeRequest) ProtoReflect ¶
func (x *UpdateEdgeRequest) ProtoReflect() protoreflect.Message
func (*UpdateEdgeRequest) Reset ¶
func (x *UpdateEdgeRequest) Reset()
func (*UpdateEdgeRequest) String ¶
func (x *UpdateEdgeRequest) String() string
type UpdateEdgeResponse ¶
type UpdateEdgeResponse struct {
// contains filtered or unexported fields
}
func (*UpdateEdgeResponse) Descriptor
deprecated
func (*UpdateEdgeResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateEdgeResponse.ProtoReflect.Descriptor instead.
func (*UpdateEdgeResponse) ProtoMessage ¶
func (*UpdateEdgeResponse) ProtoMessage()
func (*UpdateEdgeResponse) ProtoReflect ¶
func (x *UpdateEdgeResponse) ProtoReflect() protoreflect.Message
func (*UpdateEdgeResponse) Reset ¶
func (x *UpdateEdgeResponse) Reset()
func (*UpdateEdgeResponse) String ¶
func (x *UpdateEdgeResponse) String() string
type UpdateVertexRequest ¶
type UpdateVertexRequest struct { VertexList []*Vertex `protobuf:"bytes,1,rep,name=vertex_list,json=vertexList,proto3" json:"vertex_list,omitempty"` // contains filtered or unexported fields }
func (*UpdateVertexRequest) Descriptor
deprecated
func (*UpdateVertexRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateVertexRequest.ProtoReflect.Descriptor instead.
func (*UpdateVertexRequest) GetVertexList ¶
func (x *UpdateVertexRequest) GetVertexList() []*Vertex
func (*UpdateVertexRequest) ProtoMessage ¶
func (*UpdateVertexRequest) ProtoMessage()
func (*UpdateVertexRequest) ProtoReflect ¶
func (x *UpdateVertexRequest) ProtoReflect() protoreflect.Message
func (*UpdateVertexRequest) Reset ¶
func (x *UpdateVertexRequest) Reset()
func (*UpdateVertexRequest) String ¶
func (x *UpdateVertexRequest) String() string
type UpdateVertexResponse ¶
type UpdateVertexResponse struct {
// contains filtered or unexported fields
}
func (*UpdateVertexResponse) Descriptor
deprecated
func (*UpdateVertexResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateVertexResponse.ProtoReflect.Descriptor instead.
func (*UpdateVertexResponse) ProtoMessage ¶
func (*UpdateVertexResponse) ProtoMessage()
func (*UpdateVertexResponse) ProtoReflect ¶
func (x *UpdateVertexResponse) ProtoReflect() protoreflect.Message
func (*UpdateVertexResponse) Reset ¶
func (x *UpdateVertexResponse) Reset()
func (*UpdateVertexResponse) String ¶
func (x *UpdateVertexResponse) String() string
type Vertex ¶
type Vertex struct { Vid int64 `protobuf:"varint,1,opt,name=vid,proto3" json:"vid,omitempty"` Type VertexType `protobuf:"varint,2,opt,name=type,proto3,enum=librarian.mapper.v1.VertexType" json:"type,omitempty"` Prop *VertexProp `protobuf:"bytes,3,opt,name=prop,proto3,oneof" json:"prop,omitempty"` // contains filtered or unexported fields }
func (*Vertex) Descriptor
deprecated
func (*Vertex) GetProp ¶
func (x *Vertex) GetProp() *VertexProp
func (*Vertex) GetType ¶
func (x *Vertex) GetType() VertexType
func (*Vertex) ProtoMessage ¶
func (*Vertex) ProtoMessage()
func (*Vertex) ProtoReflect ¶
func (x *Vertex) ProtoReflect() protoreflect.Message
type VertexCommonProp ¶
type VertexCommonProp struct { OccurTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=occur_time,json=occurTime,proto3,oneof" json:"occur_time,omitempty"` CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3,oneof" json:"create_time,omitempty"` UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3,oneof" json:"update_time,omitempty"` // contains filtered or unexported fields }
func (*VertexCommonProp) Descriptor
deprecated
func (*VertexCommonProp) Descriptor() ([]byte, []int)
Deprecated: Use VertexCommonProp.ProtoReflect.Descriptor instead.
func (*VertexCommonProp) GetCreateTime ¶
func (x *VertexCommonProp) GetCreateTime() *timestamppb.Timestamp
func (*VertexCommonProp) GetOccurTime ¶
func (x *VertexCommonProp) GetOccurTime() *timestamppb.Timestamp
func (*VertexCommonProp) GetUpdateTime ¶
func (x *VertexCommonProp) GetUpdateTime() *timestamppb.Timestamp
func (*VertexCommonProp) ProtoMessage ¶
func (*VertexCommonProp) ProtoMessage()
func (*VertexCommonProp) ProtoReflect ¶
func (x *VertexCommonProp) ProtoReflect() protoreflect.Message
func (*VertexCommonProp) Reset ¶
func (x *VertexCommonProp) Reset()
func (*VertexCommonProp) String ¶
func (x *VertexCommonProp) String() string
type VertexProp ¶
type VertexProp struct { Common *VertexCommonProp `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"` Additional map[string]int64 `` /* 162-byte string literal not displayed */ // contains filtered or unexported fields }
func (*VertexProp) Descriptor
deprecated
func (*VertexProp) Descriptor() ([]byte, []int)
Deprecated: Use VertexProp.ProtoReflect.Descriptor instead.
func (*VertexProp) GetAdditional ¶
func (x *VertexProp) GetAdditional() map[string]int64
func (*VertexProp) GetCommon ¶
func (x *VertexProp) GetCommon() *VertexCommonProp
func (*VertexProp) ProtoMessage ¶
func (*VertexProp) ProtoMessage()
func (*VertexProp) ProtoReflect ¶
func (x *VertexProp) ProtoReflect() protoreflect.Message
func (*VertexProp) Reset ¶
func (x *VertexProp) Reset()
func (*VertexProp) String ¶
func (x *VertexProp) String() string
type VertexType ¶
type VertexType int32
const ( VertexType_VERTEX_TYPE_UNSPECIFIED VertexType = 0 VertexType_VERTEX_TYPE_ABSTRACT VertexType = 1 VertexType_VERTEX_TYPE_ENTITY VertexType = 2 VertexType_VERTEX_TYPE_MESSAGE VertexType = 3 VertexType_VERTEX_TYPE_OBJECT VertexType = 4 VertexType_VERTEX_TYPE_METADATA VertexType = 5 )
func (VertexType) Descriptor ¶
func (VertexType) Descriptor() protoreflect.EnumDescriptor
func (VertexType) Enum ¶
func (x VertexType) Enum() *VertexType
func (VertexType) EnumDescriptor
deprecated
func (VertexType) EnumDescriptor() ([]byte, []int)
Deprecated: Use VertexType.Descriptor instead.
func (VertexType) Number ¶
func (x VertexType) Number() protoreflect.EnumNumber
func (VertexType) String ¶
func (x VertexType) String() string
func (VertexType) Type ¶
func (VertexType) Type() protoreflect.EnumType