Documentation ¶
Index ¶
- Variables
- func RegisterGraphAccessServer(s grpc.ServiceRegistrar, srv GraphAccessServer)
- type AccessRequest
- func (*AccessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AccessRequest) GetDirection() AccessRequest_Direction
- func (x *AccessRequest) GetLabel() uint32
- func (x *AccessRequest) GetNodeId() uint32
- func (x *AccessRequest) GetQueryId() int32
- func (*AccessRequest) ProtoMessage()
- func (x *AccessRequest) ProtoReflect() protoreflect.Message
- func (x *AccessRequest) Reset()
- func (x *AccessRequest) String() string
- type AccessRequest_Direction
- func (AccessRequest_Direction) Descriptor() protoreflect.EnumDescriptor
- func (x AccessRequest_Direction) Enum() *AccessRequest_Direction
- func (AccessRequest_Direction) EnumDescriptor() ([]byte, []int)deprecated
- func (x AccessRequest_Direction) Number() protoreflect.EnumNumber
- func (x AccessRequest_Direction) String() string
- func (AccessRequest_Direction) Type() protoreflect.EnumType
- type AccessResponse
- func (*AccessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AccessResponse) GetNeighbours() []uint32
- func (x *AccessResponse) GetStatus() AccessResponse_ResponseStatus
- func (*AccessResponse) ProtoMessage()
- func (x *AccessResponse) ProtoReflect() protoreflect.Message
- func (x *AccessResponse) Reset()
- func (x *AccessResponse) String() string
- type AccessResponse_ResponseStatus
- func (AccessResponse_ResponseStatus) Descriptor() protoreflect.EnumDescriptor
- func (x AccessResponse_ResponseStatus) Enum() *AccessResponse_ResponseStatus
- func (AccessResponse_ResponseStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x AccessResponse_ResponseStatus) Number() protoreflect.EnumNumber
- func (x AccessResponse_ResponseStatus) String() string
- func (AccessResponse_ResponseStatus) Type() protoreflect.EnumType
- type EndQueryRequest
- type EndQueryResponse
- type GraphAccessClient
- type GraphAccessServer
- type StartQueryRequest
- func (*StartQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartQueryRequest) GetAlgorithm() StartQueryRequest_Algo
- func (*StartQueryRequest) ProtoMessage()
- func (x *StartQueryRequest) ProtoReflect() protoreflect.Message
- func (x *StartQueryRequest) Reset()
- func (x *StartQueryRequest) String() string
- type StartQueryRequest_Algo
- func (StartQueryRequest_Algo) Descriptor() protoreflect.EnumDescriptor
- func (x StartQueryRequest_Algo) Enum() *StartQueryRequest_Algo
- func (StartQueryRequest_Algo) EnumDescriptor() ([]byte, []int)deprecated
- func (x StartQueryRequest_Algo) Number() protoreflect.EnumNumber
- func (x StartQueryRequest_Algo) String() string
- func (StartQueryRequest_Algo) Type() protoreflect.EnumType
- type StartQueryResponse
- func (*StartQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartQueryResponse) GetQueryId() int32
- func (*StartQueryResponse) ProtoMessage()
- func (x *StartQueryResponse) ProtoReflect() protoreflect.Message
- func (x *StartQueryResponse) Reset()
- func (x *StartQueryResponse) String() string
- type Stats
- type StatsRequest
- type UnimplementedGraphAccessServer
- func (UnimplementedGraphAccessServer) EndQuery(context.Context, *EndQueryRequest) (*EndQueryResponse, error)
- func (UnimplementedGraphAccessServer) GetNeighbours(context.Context, *AccessRequest) (*AccessResponse, error)
- func (UnimplementedGraphAccessServer) GetStats(context.Context, *StatsRequest) (*Stats, error)
- func (UnimplementedGraphAccessServer) StartQuery(context.Context, *StartQueryRequest) (*StartQueryResponse, error)
- type UnsafeGraphAccessServer
Constants ¶
This section is empty.
Variables ¶
var ( AccessRequest_Direction_name = map[int32]string{ 0: "INCOMING", 1: "OUTGOING", 2: "BOTH", } AccessRequest_Direction_value = map[string]int32{ "INCOMING": 0, "OUTGOING": 1, "BOTH": 2, } )
Enum value maps for AccessRequest_Direction.
var ( AccessResponse_ResponseStatus_name = map[int32]string{ 0: "NO_ERROR", 1: "UNSUPPORTED", 2: "SERVER_ERROR", } AccessResponse_ResponseStatus_value = map[string]int32{ "NO_ERROR": 0, "UNSUPPORTED": 1, "SERVER_ERROR": 2, } )
Enum value maps for AccessResponse_ResponseStatus.
var ( StartQueryRequest_Algo_name = map[int32]string{ 0: "BFS", 1: "DFS", } StartQueryRequest_Algo_value = map[string]int32{ "BFS": 0, "DFS": 1, } )
Enum value maps for StartQueryRequest_Algo.
var File_graph_access_proto protoreflect.FileDescriptor
var GraphAccess_ServiceDesc = grpc.ServiceDesc{ ServiceName: "graph_access_service.GraphAccess", HandlerType: (*GraphAccessServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "StartQuery", Handler: _GraphAccess_StartQuery_Handler, }, { MethodName: "GetNeighbours", Handler: _GraphAccess_GetNeighbours_Handler, }, { MethodName: "EndQuery", Handler: _GraphAccess_EndQuery_Handler, }, { MethodName: "GetStats", Handler: _GraphAccess_GetStats_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "graph_access.proto", }
GraphAccess_ServiceDesc is the grpc.ServiceDesc for GraphAccess service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGraphAccessServer ¶
func RegisterGraphAccessServer(s grpc.ServiceRegistrar, srv GraphAccessServer)
Types ¶
type AccessRequest ¶
type AccessRequest struct { NodeId uint32 `protobuf:"varint,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` // Source node id Label uint32 `protobuf:"varint,2,opt,name=label,proto3" json:"label,omitempty"` // Edge label Direction AccessRequest_Direction `protobuf:"varint,3,opt,name=direction,proto3,enum=graph_access_service.AccessRequest_Direction" json:"direction,omitempty"` // Is the edge outgoing or incoming QueryId int32 `protobuf:"varint,4,opt,name=queryId,proto3" json:"queryId,omitempty"` // contains filtered or unexported fields }
func (*AccessRequest) Descriptor
deprecated
func (*AccessRequest) Descriptor() ([]byte, []int)
Deprecated: Use AccessRequest.ProtoReflect.Descriptor instead.
func (*AccessRequest) GetDirection ¶
func (x *AccessRequest) GetDirection() AccessRequest_Direction
func (*AccessRequest) GetLabel ¶
func (x *AccessRequest) GetLabel() uint32
func (*AccessRequest) GetNodeId ¶
func (x *AccessRequest) GetNodeId() uint32
func (*AccessRequest) GetQueryId ¶
func (x *AccessRequest) GetQueryId() int32
func (*AccessRequest) ProtoMessage ¶
func (*AccessRequest) ProtoMessage()
func (*AccessRequest) ProtoReflect ¶
func (x *AccessRequest) ProtoReflect() protoreflect.Message
func (*AccessRequest) Reset ¶
func (x *AccessRequest) Reset()
func (*AccessRequest) String ¶
func (x *AccessRequest) String() string
type AccessRequest_Direction ¶
type AccessRequest_Direction int32
const ( AccessRequest_INCOMING AccessRequest_Direction = 0 AccessRequest_OUTGOING AccessRequest_Direction = 1 AccessRequest_BOTH AccessRequest_Direction = 2 )
func (AccessRequest_Direction) Descriptor ¶
func (AccessRequest_Direction) Descriptor() protoreflect.EnumDescriptor
func (AccessRequest_Direction) Enum ¶
func (x AccessRequest_Direction) Enum() *AccessRequest_Direction
func (AccessRequest_Direction) EnumDescriptor
deprecated
func (AccessRequest_Direction) EnumDescriptor() ([]byte, []int)
Deprecated: Use AccessRequest_Direction.Descriptor instead.
func (AccessRequest_Direction) Number ¶
func (x AccessRequest_Direction) Number() protoreflect.EnumNumber
func (AccessRequest_Direction) String ¶
func (x AccessRequest_Direction) String() string
func (AccessRequest_Direction) Type ¶
func (AccessRequest_Direction) Type() protoreflect.EnumType
type AccessResponse ¶
type AccessResponse struct { Neighbours []uint32 `protobuf:"varint,1,rep,packed,name=neighbours,proto3" json:"neighbours,omitempty"` // List of Node ids for the neighbours Status AccessResponse_ResponseStatus `protobuf:"varint,2,opt,name=status,proto3,enum=graph_access_service.AccessResponse_ResponseStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*AccessResponse) Descriptor
deprecated
func (*AccessResponse) Descriptor() ([]byte, []int)
Deprecated: Use AccessResponse.ProtoReflect.Descriptor instead.
func (*AccessResponse) GetNeighbours ¶
func (x *AccessResponse) GetNeighbours() []uint32
func (*AccessResponse) GetStatus ¶
func (x *AccessResponse) GetStatus() AccessResponse_ResponseStatus
func (*AccessResponse) ProtoMessage ¶
func (*AccessResponse) ProtoMessage()
func (*AccessResponse) ProtoReflect ¶
func (x *AccessResponse) ProtoReflect() protoreflect.Message
func (*AccessResponse) Reset ¶
func (x *AccessResponse) Reset()
func (*AccessResponse) String ¶
func (x *AccessResponse) String() string
type AccessResponse_ResponseStatus ¶
type AccessResponse_ResponseStatus int32
const ( AccessResponse_NO_ERROR AccessResponse_ResponseStatus = 0 AccessResponse_UNSUPPORTED AccessResponse_ResponseStatus = 1 AccessResponse_SERVER_ERROR AccessResponse_ResponseStatus = 2 )
func (AccessResponse_ResponseStatus) Descriptor ¶
func (AccessResponse_ResponseStatus) Descriptor() protoreflect.EnumDescriptor
func (AccessResponse_ResponseStatus) Enum ¶
func (x AccessResponse_ResponseStatus) Enum() *AccessResponse_ResponseStatus
func (AccessResponse_ResponseStatus) EnumDescriptor
deprecated
func (AccessResponse_ResponseStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use AccessResponse_ResponseStatus.Descriptor instead.
func (AccessResponse_ResponseStatus) Number ¶
func (x AccessResponse_ResponseStatus) Number() protoreflect.EnumNumber
func (AccessResponse_ResponseStatus) String ¶
func (x AccessResponse_ResponseStatus) String() string
func (AccessResponse_ResponseStatus) Type ¶
func (AccessResponse_ResponseStatus) Type() protoreflect.EnumType
type EndQueryRequest ¶
type EndQueryRequest struct { QueryId int32 `protobuf:"varint,1,opt,name=queryId,proto3" json:"queryId,omitempty"` // contains filtered or unexported fields }
func (*EndQueryRequest) Descriptor
deprecated
func (*EndQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use EndQueryRequest.ProtoReflect.Descriptor instead.
func (*EndQueryRequest) GetQueryId ¶
func (x *EndQueryRequest) GetQueryId() int32
func (*EndQueryRequest) ProtoMessage ¶
func (*EndQueryRequest) ProtoMessage()
func (*EndQueryRequest) ProtoReflect ¶
func (x *EndQueryRequest) ProtoReflect() protoreflect.Message
func (*EndQueryRequest) Reset ¶
func (x *EndQueryRequest) Reset()
func (*EndQueryRequest) String ¶
func (x *EndQueryRequest) String() string
type EndQueryResponse ¶
type EndQueryResponse struct {
// contains filtered or unexported fields
}
func (*EndQueryResponse) Descriptor
deprecated
func (*EndQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use EndQueryResponse.ProtoReflect.Descriptor instead.
func (*EndQueryResponse) ProtoMessage ¶
func (*EndQueryResponse) ProtoMessage()
func (*EndQueryResponse) ProtoReflect ¶
func (x *EndQueryResponse) ProtoReflect() protoreflect.Message
func (*EndQueryResponse) Reset ¶
func (x *EndQueryResponse) Reset()
func (*EndQueryResponse) String ¶
func (x *EndQueryResponse) String() string
type GraphAccessClient ¶
type GraphAccessClient interface { StartQuery(ctx context.Context, in *StartQueryRequest, opts ...grpc.CallOption) (*StartQueryResponse, error) GetNeighbours(ctx context.Context, in *AccessRequest, opts ...grpc.CallOption) (*AccessResponse, error) EndQuery(ctx context.Context, in *EndQueryRequest, opts ...grpc.CallOption) (*EndQueryResponse, error) GetStats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*Stats, error) }
GraphAccessClient is the client API for GraphAccess 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 NewGraphAccessClient ¶
func NewGraphAccessClient(cc grpc.ClientConnInterface) GraphAccessClient
type GraphAccessServer ¶
type GraphAccessServer interface { StartQuery(context.Context, *StartQueryRequest) (*StartQueryResponse, error) GetNeighbours(context.Context, *AccessRequest) (*AccessResponse, error) EndQuery(context.Context, *EndQueryRequest) (*EndQueryResponse, error) GetStats(context.Context, *StatsRequest) (*Stats, error) // contains filtered or unexported methods }
GraphAccessServer is the server API for GraphAccess service. All implementations must embed UnimplementedGraphAccessServer for forward compatibility
type StartQueryRequest ¶
type StartQueryRequest struct { Algorithm StartQueryRequest_Algo `protobuf:"varint,2,opt,name=algorithm,proto3,enum=graph_access_service.StartQueryRequest_Algo" json:"algorithm,omitempty"` // contains filtered or unexported fields }
func (*StartQueryRequest) Descriptor
deprecated
func (*StartQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartQueryRequest.ProtoReflect.Descriptor instead.
func (*StartQueryRequest) GetAlgorithm ¶
func (x *StartQueryRequest) GetAlgorithm() StartQueryRequest_Algo
func (*StartQueryRequest) ProtoMessage ¶
func (*StartQueryRequest) ProtoMessage()
func (*StartQueryRequest) ProtoReflect ¶
func (x *StartQueryRequest) ProtoReflect() protoreflect.Message
func (*StartQueryRequest) Reset ¶
func (x *StartQueryRequest) Reset()
func (*StartQueryRequest) String ¶
func (x *StartQueryRequest) String() string
type StartQueryRequest_Algo ¶
type StartQueryRequest_Algo int32
const ( StartQueryRequest_BFS StartQueryRequest_Algo = 0 StartQueryRequest_DFS StartQueryRequest_Algo = 1 )
func (StartQueryRequest_Algo) Descriptor ¶
func (StartQueryRequest_Algo) Descriptor() protoreflect.EnumDescriptor
func (StartQueryRequest_Algo) Enum ¶
func (x StartQueryRequest_Algo) Enum() *StartQueryRequest_Algo
func (StartQueryRequest_Algo) EnumDescriptor
deprecated
func (StartQueryRequest_Algo) EnumDescriptor() ([]byte, []int)
Deprecated: Use StartQueryRequest_Algo.Descriptor instead.
func (StartQueryRequest_Algo) Number ¶
func (x StartQueryRequest_Algo) Number() protoreflect.EnumNumber
func (StartQueryRequest_Algo) String ¶
func (x StartQueryRequest_Algo) String() string
func (StartQueryRequest_Algo) Type ¶
func (StartQueryRequest_Algo) Type() protoreflect.EnumType
type StartQueryResponse ¶
type StartQueryResponse struct { QueryId int32 `protobuf:"varint,1,opt,name=queryId,proto3" json:"queryId,omitempty"` // contains filtered or unexported fields }
func (*StartQueryResponse) Descriptor
deprecated
func (*StartQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartQueryResponse.ProtoReflect.Descriptor instead.
func (*StartQueryResponse) GetQueryId ¶
func (x *StartQueryResponse) GetQueryId() int32
func (*StartQueryResponse) ProtoMessage ¶
func (*StartQueryResponse) ProtoMessage()
func (*StartQueryResponse) ProtoReflect ¶
func (x *StartQueryResponse) ProtoReflect() protoreflect.Message
func (*StartQueryResponse) Reset ¶
func (x *StartQueryResponse) Reset()
func (*StartQueryResponse) String ¶
func (x *StartQueryResponse) String() string
type Stats ¶
type Stats struct { Stats string `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` // contains filtered or unexported fields }
func (*Stats) Descriptor
deprecated
func (*Stats) ProtoMessage ¶
func (*Stats) ProtoMessage()
func (*Stats) ProtoReflect ¶
func (x *Stats) ProtoReflect() protoreflect.Message
type StatsRequest ¶
type StatsRequest struct {
// contains filtered or unexported fields
}
func (*StatsRequest) Descriptor
deprecated
func (*StatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.
func (*StatsRequest) ProtoMessage ¶
func (*StatsRequest) ProtoMessage()
func (*StatsRequest) ProtoReflect ¶
func (x *StatsRequest) ProtoReflect() protoreflect.Message
func (*StatsRequest) Reset ¶
func (x *StatsRequest) Reset()
func (*StatsRequest) String ¶
func (x *StatsRequest) String() string
type UnimplementedGraphAccessServer ¶
type UnimplementedGraphAccessServer struct { }
UnimplementedGraphAccessServer must be embedded to have forward compatible implementations.
func (UnimplementedGraphAccessServer) EndQuery ¶
func (UnimplementedGraphAccessServer) EndQuery(context.Context, *EndQueryRequest) (*EndQueryResponse, error)
func (UnimplementedGraphAccessServer) GetNeighbours ¶
func (UnimplementedGraphAccessServer) GetNeighbours(context.Context, *AccessRequest) (*AccessResponse, error)
func (UnimplementedGraphAccessServer) GetStats ¶
func (UnimplementedGraphAccessServer) GetStats(context.Context, *StatsRequest) (*Stats, error)
func (UnimplementedGraphAccessServer) StartQuery ¶
func (UnimplementedGraphAccessServer) StartQuery(context.Context, *StartQueryRequest) (*StartQueryResponse, error)
type UnsafeGraphAccessServer ¶
type UnsafeGraphAccessServer interface {
// contains filtered or unexported methods
}
UnsafeGraphAccessServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GraphAccessServer will result in compilation errors.