graphstore

package
v0.1.15 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2020 License: MIT Imports: 16 Imported by: 1

Documentation

Overview

Package graphstore is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterGraphStoreHandler 

func RegisterGraphStoreHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterGraphStoreHandler registers the http handlers for service GraphStore to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterGraphStoreHandlerClient 

func RegisterGraphStoreHandlerClient(ctx context.Context, mux *runtime.ServeMux, client GraphStoreClient) error

RegisterGraphStoreHandlerClient registers the http handlers for service GraphStore to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "GraphStoreClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "GraphStoreClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "GraphStoreClient" to call the correct interceptors.

func RegisterGraphStoreHandlerFromEndpoint 

func RegisterGraphStoreHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterGraphStoreHandlerFromEndpoint is same as RegisterGraphStoreHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterGraphStoreHandlerServer 

func RegisterGraphStoreHandlerServer(ctx context.Context, mux *runtime.ServeMux, server GraphStoreServer) error

RegisterGraphStoreHandlerServer registers the http handlers for service GraphStore to "mux". UnaryRPC :call GraphStoreServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterGraphStoreHandlerFromEndpoint instead.

func RegisterGraphStoreServer 

func RegisterGraphStoreServer(s *grpc.Server, srv GraphStoreServer)

Types

type DeleteRequest 

type DeleteRequest struct {
	Nodes                []*Node  `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Edges                []*Edge  `protobuf:"bytes,2,rep,name=edges,proto3" json:"edges,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeleteRequest encapsulates elements we are removing from the database.

func (*DeleteRequest) Descriptor 

func (*DeleteRequest) Descriptor() ([]byte, []int)

func (*DeleteRequest) GetEdges 

func (m *DeleteRequest) GetEdges() []*Edge

func (*DeleteRequest) GetNodes 

func (m *DeleteRequest) GetNodes() []*Node

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRequest) XXX_Merge 

func (m *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

func (m *DeleteRequest) XXX_Unmarshal(b []byte) error

type DeleteResponse 

type DeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteResponse) Descriptor 

func (*DeleteResponse) Descriptor() ([]byte, []int)

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteResponse) XXX_Merge 

func (m *DeleteResponse) XXX_Merge(src proto.Message)

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

func (m *DeleteResponse) XXX_Unmarshal(b []byte) error

type Edge 

type Edge struct {
	FromKey              []byte   `protobuf:"bytes,1,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"`
	ToKey                []byte   `protobuf:"bytes,2,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"`
	Key                  []byte   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Body                 *any.Any `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Edges represent associations between nodes.

func (*Edge) Descriptor 

func (*Edge) Descriptor() ([]byte, []int)

func (*Edge) GetBody 

func (m *Edge) GetBody() *any.Any

func (*Edge) GetFromKey 

func (m *Edge) GetFromKey() []byte

func (*Edge) GetKey 

func (m *Edge) GetKey() []byte

func (*Edge) GetToKey 

func (m *Edge) GetToKey() []byte

func (*Edge) ProtoMessage 

func (*Edge) ProtoMessage()

func (*Edge) Reset 

func (m *Edge) Reset()

func (*Edge) String 

func (m *Edge) String() string

func (*Edge) XXX_DiscardUnknown 

func (m *Edge) XXX_DiscardUnknown()

func (*Edge) XXX_Marshal 

func (m *Edge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Edge) XXX_Merge 

func (m *Edge) XXX_Merge(src proto.Message)

func (*Edge) XXX_Size 

func (m *Edge) XXX_Size() int

func (*Edge) XXX_Unmarshal 

func (m *Edge) XXX_Unmarshal(b []byte) error

type EdgeFilter 

type EdgeFilter struct {
	Body                 *any.Any `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EdgeFilter is used to reduce the considered edges

func (*EdgeFilter) Descriptor 

func (*EdgeFilter) Descriptor() ([]byte, []int)

func (*EdgeFilter) GetBody 

func (m *EdgeFilter) GetBody() *any.Any

func (*EdgeFilter) ProtoMessage 

func (*EdgeFilter) ProtoMessage()

func (*EdgeFilter) Reset 

func (m *EdgeFilter) Reset()

func (*EdgeFilter) String 

func (m *EdgeFilter) String() string

func (*EdgeFilter) XXX_DiscardUnknown 

func (m *EdgeFilter) XXX_DiscardUnknown()

func (*EdgeFilter) XXX_Marshal 

func (m *EdgeFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EdgeFilter) XXX_Merge 

func (m *EdgeFilter) XXX_Merge(src proto.Message)

func (*EdgeFilter) XXX_Size 

func (m *EdgeFilter) XXX_Size() int

func (*EdgeFilter) XXX_Unmarshal 

func (m *EdgeFilter) XXX_Unmarshal(b []byte) error

type GraphStoreClient 

type GraphStoreClient interface {
	// Used to insert data into the store.
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// Used to delete data from the store.
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Used to list data within the store.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	// Used to query data within the store.
	Neighbors(ctx context.Context, in *NeighborsRequest, opts ...grpc.CallOption) (*NeighborsResponse, error)
	// Used to navigate the graph.
	Traverse(ctx context.Context, opts ...grpc.CallOption) (GraphStore_TraverseClient, error)
}

GraphStoreClient is the client API for GraphStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGraphStoreClient 

func NewGraphStoreClient(cc *grpc.ClientConn) GraphStoreClient

type GraphStoreServer 

type GraphStoreServer interface {
	// Used to insert data into the store.
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// Used to delete data from the store.
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Used to list data within the store.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// Used to query data within the store.
	Neighbors(context.Context, *NeighborsRequest) (*NeighborsResponse, error)
	// Used to navigate the graph.
	Traverse(GraphStore_TraverseServer) error
}

GraphStoreServer is the server API for GraphStore service.

type GraphStore_TraverseClient 

type GraphStore_TraverseClient interface {
	Send(*TraverseRequest) error
	Recv() (*TraverseResponse, error)
	grpc.ClientStream
}

type GraphStore_TraverseServer 

type GraphStore_TraverseServer interface {
	Send(*TraverseResponse) error
	Recv() (*TraverseRequest, error)
	grpc.ServerStream
}

type ListRequest 

type ListRequest struct {
	Parent               string   `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	PageSize             int32    `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken            string   `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	Kind                 string   `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListRequest encapsulates requirements for listing data from the database.

func (*ListRequest) Descriptor 

func (*ListRequest) Descriptor() ([]byte, []int)

func (*ListRequest) GetKind 

func (m *ListRequest) GetKind() string

func (*ListRequest) GetPageSize 

func (m *ListRequest) GetPageSize() int32

func (*ListRequest) GetPageToken 

func (m *ListRequest) GetPageToken() string

func (*ListRequest) GetParent 

func (m *ListRequest) GetParent() string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRequest) XXX_Merge 

func (m *ListRequest) XXX_Merge(src proto.Message)

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

func (m *ListRequest) XXX_Unmarshal(b []byte) error

type ListResponse 

type ListResponse struct {
	NextPageToken        string   `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Nodes                []*Node  `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Edges                []*Edge  `protobuf:"bytes,3,rep,name=edges,proto3" json:"edges,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListResponse encapsulates listed response data.

func (*ListResponse) Descriptor 

func (*ListResponse) Descriptor() ([]byte, []int)

func (*ListResponse) GetEdges 

func (m *ListResponse) GetEdges() []*Edge

func (*ListResponse) GetNextPageToken 

func (m *ListResponse) GetNextPageToken() string

func (*ListResponse) GetNodes 

func (m *ListResponse) GetNodes() []*Node

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) String 

func (m *ListResponse) String() string

func (*ListResponse) XXX_DiscardUnknown 

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal 

func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListResponse) XXX_Merge 

func (m *ListResponse) XXX_Merge(src proto.Message)

func (*ListResponse) XXX_Size 

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal 

func (m *ListResponse) XXX_Unmarshal(b []byte) error

type Neighbor 

type Neighbor struct {
	Node                 *Node    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Edges                []*Edge  `protobuf:"bytes,2,rep,name=edges,proto3" json:"edges,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Neighbor represents a node and all the edges pointing to it.

func (*Neighbor) Descriptor 

func (*Neighbor) Descriptor() ([]byte, []int)

func (*Neighbor) GetEdges 

func (m *Neighbor) GetEdges() []*Edge

func (*Neighbor) GetNode 

func (m *Neighbor) GetNode() *Node

func (*Neighbor) ProtoMessage 

func (*Neighbor) ProtoMessage()

func (*Neighbor) Reset 

func (m *Neighbor) Reset()

func (*Neighbor) String 

func (m *Neighbor) String() string

func (*Neighbor) XXX_DiscardUnknown 

func (m *Neighbor) XXX_DiscardUnknown()

func (*Neighbor) XXX_Marshal 

func (m *Neighbor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Neighbor) XXX_Merge 

func (m *Neighbor) XXX_Merge(src proto.Message)

func (*Neighbor) XXX_Size 

func (m *Neighbor) XXX_Size() int

func (*Neighbor) XXX_Unmarshal 

func (m *Neighbor) XXX_Unmarshal(b []byte) error

type NeighborsRequest 

type NeighborsRequest struct {
	// Used to fetch all neighbors of a node, regardless of directionality.
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// Used to fetch all neighbors on the receiving end of edges.
	From *Node `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	// Used to fetch all neighbors on the initiating end of edges.
	To *Node `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	// Used to reduce the edges considered when finding neighbors.
	Filter               []*EdgeFilter `protobuf:"bytes,4,rep,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

NeighborsRequest encapsulates the variety of ways neighbors can be looked up.

func (*NeighborsRequest) Descriptor 

func (*NeighborsRequest) Descriptor() ([]byte, []int)

func (*NeighborsRequest) GetFilter 

func (m *NeighborsRequest) GetFilter() []*EdgeFilter

func (*NeighborsRequest) GetFrom 

func (m *NeighborsRequest) GetFrom() *Node

func (*NeighborsRequest) GetNode 

func (m *NeighborsRequest) GetNode() *Node

func (*NeighborsRequest) GetTo 

func (m *NeighborsRequest) GetTo() *Node

func (*NeighborsRequest) ProtoMessage 

func (*NeighborsRequest) ProtoMessage()

func (*NeighborsRequest) Reset 

func (m *NeighborsRequest) Reset()

func (*NeighborsRequest) String 

func (m *NeighborsRequest) String() string

func (*NeighborsRequest) XXX_DiscardUnknown 

func (m *NeighborsRequest) XXX_DiscardUnknown()

func (*NeighborsRequest) XXX_Marshal 

func (m *NeighborsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NeighborsRequest) XXX_Merge 

func (m *NeighborsRequest) XXX_Merge(src proto.Message)

func (*NeighborsRequest) XXX_Size 

func (m *NeighborsRequest) XXX_Size() int

func (*NeighborsRequest) XXX_Unmarshal 

func (m *NeighborsRequest) XXX_Unmarshal(b []byte) error

type NeighborsResponse 

type NeighborsResponse struct {
	Neighbors            []*Neighbor `protobuf:"bytes,1,rep,name=neighbors,proto3" json:"neighbors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

NeighborsResponse returns all neighbors from the query.

func (*NeighborsResponse) Descriptor 

func (*NeighborsResponse) Descriptor() ([]byte, []int)

func (*NeighborsResponse) GetNeighbors 

func (m *NeighborsResponse) GetNeighbors() []*Neighbor

func (*NeighborsResponse) ProtoMessage 

func (*NeighborsResponse) ProtoMessage()

func (*NeighborsResponse) Reset 

func (m *NeighborsResponse) Reset()

func (*NeighborsResponse) String 

func (m *NeighborsResponse) String() string

func (*NeighborsResponse) XXX_DiscardUnknown 

func (m *NeighborsResponse) XXX_DiscardUnknown()

func (*NeighborsResponse) XXX_Marshal 

func (m *NeighborsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NeighborsResponse) XXX_Merge 

func (m *NeighborsResponse) XXX_Merge(src proto.Message)

func (*NeighborsResponse) XXX_Size 

func (m *NeighborsResponse) XXX_Size() int

func (*NeighborsResponse) XXX_Unmarshal 

func (m *NeighborsResponse) XXX_Unmarshal(b []byte) error

type Node 

type Node struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Body                 *any.Any `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Nodes represent entities in a graph.

func (*Node) Descriptor 

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GetBody 

func (m *Node) GetBody() *any.Any

func (*Node) GetKey 

func (m *Node) GetKey() []byte

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge 

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

func (m *Node) XXX_Unmarshal(b []byte) error

type PutRequest 

type PutRequest struct {
	Nodes                []*Node  `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Edges                []*Edge  `protobuf:"bytes,2,rep,name=edges,proto3" json:"edges,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PutRequest encapsulates elements we are inserting into the database.

func (*PutRequest) Descriptor 

func (*PutRequest) Descriptor() ([]byte, []int)

func (*PutRequest) GetEdges 

func (m *PutRequest) GetEdges() []*Edge

func (*PutRequest) GetNodes 

func (m *PutRequest) GetNodes() []*Node

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) XXX_DiscardUnknown 

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal 

func (m *PutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutRequest) XXX_Merge 

func (m *PutRequest) XXX_Merge(src proto.Message)

func (*PutRequest) XXX_Size 

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal 

func (m *PutRequest) XXX_Unmarshal(b []byte) error

type PutResponse 

type PutResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutResponse) Descriptor 

func (*PutResponse) Descriptor() ([]byte, []int)

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) String 

func (m *PutResponse) String() string

func (*PutResponse) XXX_DiscardUnknown 

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal 

func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutResponse) XXX_Merge 

func (m *PutResponse) XXX_Merge(src proto.Message)

func (*PutResponse) XXX_Size 

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal 

func (m *PutResponse) XXX_Unmarshal(b []byte) error

type TraverseRequest 

type TraverseRequest struct {
	Cancel               bool              `protobuf:"varint,1,opt,name=cancel,proto3" json:"cancel,omitempty"`
	Request              *NeighborsRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

TraverseRequest is used to navigate the graph, optionally halting once the desired node is found.

func (*TraverseRequest) Descriptor 

func (*TraverseRequest) Descriptor() ([]byte, []int)

func (*TraverseRequest) GetCancel 

func (m *TraverseRequest) GetCancel() bool

func (*TraverseRequest) GetRequest 

func (m *TraverseRequest) GetRequest() *NeighborsRequest

func (*TraverseRequest) ProtoMessage 

func (*TraverseRequest) ProtoMessage()

func (*TraverseRequest) Reset 

func (m *TraverseRequest) Reset()

func (*TraverseRequest) String 

func (m *TraverseRequest) String() string

func (*TraverseRequest) XXX_DiscardUnknown 

func (m *TraverseRequest) XXX_DiscardUnknown()

func (*TraverseRequest) XXX_Marshal 

func (m *TraverseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TraverseRequest) XXX_Merge 

func (m *TraverseRequest) XXX_Merge(src proto.Message)

func (*TraverseRequest) XXX_Size 

func (m *TraverseRequest) XXX_Size() int

func (*TraverseRequest) XXX_Unmarshal 

func (m *TraverseRequest) XXX_Unmarshal(b []byte) error

type TraverseResponse 

type TraverseResponse struct {
	Request              *NeighborsRequest  `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Response             *NeighborsResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

TraverseResponse is used to encapsulate a traversal request and its associated response data.

func (*TraverseResponse) Descriptor 

func (*TraverseResponse) Descriptor() ([]byte, []int)

func (*TraverseResponse) GetRequest 

func (m *TraverseResponse) GetRequest() *NeighborsRequest

func (*TraverseResponse) GetResponse 

func (m *TraverseResponse) GetResponse() *NeighborsResponse

func (*TraverseResponse) ProtoMessage 

func (*TraverseResponse) ProtoMessage()

func (*TraverseResponse) Reset 

func (m *TraverseResponse) Reset()

func (*TraverseResponse) String 

func (m *TraverseResponse) String() string

func (*TraverseResponse) XXX_DiscardUnknown 

func (m *TraverseResponse) XXX_DiscardUnknown()

func (*TraverseResponse) XXX_Marshal 

func (m *TraverseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TraverseResponse) XXX_Merge 

func (m *TraverseResponse) XXX_Merge(src proto.Message)

func (*TraverseResponse) XXX_Size 

func (m *TraverseResponse) XXX_Size() int

func (*TraverseResponse) XXX_Unmarshal 

func (m *TraverseResponse) XXX_Unmarshal(b []byte) error

type UnimplementedGraphStoreServer 

type UnimplementedGraphStoreServer struct {
}

UnimplementedGraphStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedGraphStoreServer) Delete 

func (*UnimplementedGraphStoreServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*UnimplementedGraphStoreServer) List 

func (*UnimplementedGraphStoreServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error)

func (*UnimplementedGraphStoreServer) Neighbors 

func (*UnimplementedGraphStoreServer) Neighbors(ctx context.Context, req *NeighborsRequest) (*NeighborsResponse, error)

func (*UnimplementedGraphStoreServer) Put 

func (*UnimplementedGraphStoreServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error)

func (*UnimplementedGraphStoreServer) Traverse 

func (*UnimplementedGraphStoreServer) Traverse(srv GraphStore_TraverseServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.