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 (*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 GraphAccessClient
- type GraphAccessServer
- type Stats
- type StatsRequest
- type UnimplementedGraphAccessServer
- 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 File_graph_access_proto protoreflect.FileDescriptor
var GraphAccess_ServiceDesc = grpc.ServiceDesc{ ServiceName: "graph_access_service.GraphAccess", HandlerType: (*GraphAccessServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetNeighbours", Handler: _GraphAccess_GetNeighbours_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 // 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) 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 GraphAccessClient ¶
type GraphAccessClient interface { GetNeighbours(ctx context.Context, in *AccessRequest, opts ...grpc.CallOption) (*AccessResponse, 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 { GetNeighbours(context.Context, *AccessRequest) (*AccessResponse, 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 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) GetNeighbours ¶
func (UnimplementedGraphAccessServer) GetNeighbours(context.Context, *AccessRequest) (*AccessResponse, error)
func (UnimplementedGraphAccessServer) GetStats ¶
func (UnimplementedGraphAccessServer) GetStats(context.Context, *StatsRequest) (*Stats, 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.