v1

package
v0.4.9 Latest Latest
Warning

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

Go to latest
Published: Mar 21, 2024 License: MIT Imports: 9 Imported by: 1

Documentation

Index

Constants

View Source
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

View Source
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.

View Source
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.

View Source
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.

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

Deprecated: Use Edge.ProtoReflect.Descriptor instead.

func (*Edge) GetDstVid

func (x *Edge) GetDstVid() int64

func (*Edge) GetProp

func (x *Edge) GetProp() *EdgeProp

func (*Edge) GetSrcVid

func (x *Edge) GetSrcVid() int64

func (*Edge) GetType

func (x *Edge) GetType() EdgeType

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

Deprecated: Use EdgeProp.ProtoReflect.Descriptor instead.

func (*EdgeProp) GetAdditional

func (x *EdgeProp) GetAdditional() map[string]int64

func (*EdgeProp) GetCommon

func (x *EdgeProp) GetCommon() *EdgeCommonProp

func (*EdgeProp) ProtoMessage

func (*EdgeProp) ProtoMessage()

func (*EdgeProp) ProtoReflect

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

func (*EdgeProp) Reset

func (x *EdgeProp) Reset()

func (*EdgeProp) String

func (x *EdgeProp) String() string

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

func (x EdgeType) Enum() *EdgeType

func (EdgeType) EnumDescriptor deprecated

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

Deprecated: Use EdgeType.Descriptor instead.

func (EdgeType) Number

func (x EdgeType) Number() protoreflect.EnumNumber

func (EdgeType) String

func (x EdgeType) String() string

func (EdgeType) Type

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 (*FetchEqualVertexNeighborRequest) Reset

func (*FetchEqualVertexNeighborRequest) 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 (*FetchEqualVertexNeighborResponse) Reset

func (*FetchEqualVertexNeighborResponse) 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 (*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.

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

type UnimplementedLibrarianMapperServiceServer

type UnimplementedLibrarianMapperServiceServer struct {
}

UnimplementedLibrarianMapperServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLibrarianMapperServiceServer) DeleteEdge

func (UnimplementedLibrarianMapperServiceServer) DeleteVertex

func (UnimplementedLibrarianMapperServiceServer) FetchEqualVertex

func (UnimplementedLibrarianMapperServiceServer) FindPath

func (UnimplementedLibrarianMapperServiceServer) GoFromVertex

func (UnimplementedLibrarianMapperServiceServer) InsertEdge

func (UnimplementedLibrarianMapperServiceServer) InsertVertex

func (UnimplementedLibrarianMapperServiceServer) UpdateEdge

func (UnimplementedLibrarianMapperServiceServer) UpdateVertex

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

Deprecated: Use Vertex.ProtoReflect.Descriptor instead.

func (*Vertex) GetProp

func (x *Vertex) GetProp() *VertexProp

func (*Vertex) GetType

func (x *Vertex) GetType() VertexType

func (*Vertex) GetVid

func (x *Vertex) GetVid() int64

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

Jump to

Keyboard shortcuts

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