store

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: May 27, 2021 License: MIT Imports: 7 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GraphItemEncoding_name = map[int32]string{
	0: "RAW",
	1: "JSON",
}
View Source 
var GraphItemEncoding_value = map[string]int32{
	"RAW":  0,
	"JSON": 1,
}

Functions

func RegisterGraphStoreServer 

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

Types

type DeleteRequest 

type DeleteRequest struct {
	Items                []*GraphItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetItems 

func (m *DeleteRequest) GetItems() []*GraphItem

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 FindRequest 

type FindRequest struct {
	Keys                 [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	EdgeTypes            []string `protobuf:"bytes,2,rep,name=edgeTypes,proto3" json:"edgeTypes,omitempty"`
	NodeTypes            []string `protobuf:"bytes,3,rep,name=nodeTypes,proto3" json:"nodeTypes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindRequest) Descriptor 

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

func (*FindRequest) GetEdgeTypes 

func (m *FindRequest) GetEdgeTypes() []string

func (*FindRequest) GetKeys added in v0.1.6 

func (m *FindRequest) GetKeys() [][]byte

func (*FindRequest) GetNodeTypes added in v0.1.6 

func (m *FindRequest) GetNodeTypes() []string

func (*FindRequest) ProtoMessage 

func (*FindRequest) ProtoMessage()

func (*FindRequest) Reset 

func (m *FindRequest) Reset()

func (*FindRequest) String 

func (m *FindRequest) String() string

func (*FindRequest) XXX_DiscardUnknown 

func (m *FindRequest) XXX_DiscardUnknown()

func (*FindRequest) XXX_Marshal 

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

func (*FindRequest) XXX_Merge 

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

func (*FindRequest) XXX_Size 

func (m *FindRequest) XXX_Size() int

func (*FindRequest) XXX_Unmarshal 

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

type FindResponse 

type FindResponse struct {
	Pairs                []*GraphItemPair `protobuf:"bytes,1,rep,name=pairs,proto3" json:"pairs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*FindResponse) Descriptor 

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

func (*FindResponse) GetPairs 

func (m *FindResponse) GetPairs() []*GraphItemPair

func (*FindResponse) ProtoMessage 

func (*FindResponse) ProtoMessage()

func (*FindResponse) Reset 

func (m *FindResponse) Reset()

func (*FindResponse) String 

func (m *FindResponse) String() string

func (*FindResponse) XXX_DiscardUnknown 

func (m *FindResponse) XXX_DiscardUnknown()

func (*FindResponse) XXX_Marshal 

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

func (*FindResponse) XXX_Merge 

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

func (*FindResponse) XXX_Size 

func (m *FindResponse) XXX_Size() int

func (*FindResponse) XXX_Unmarshal 

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

type GraphItem 

type GraphItem struct {
	GraphItemType        string            `protobuf:"bytes,1,opt,name=graphItemType,proto3" json:"graphItemType,omitempty"`
	K1                   []byte            `protobuf:"bytes,2,opt,name=k1,proto3" json:"k1,omitempty"`
	K2                   []byte            `protobuf:"bytes,3,opt,name=k2,proto3" json:"k2,omitempty"`
	K3                   []byte            `protobuf:"bytes,4,opt,name=k3,proto3" json:"k3,omitempty"`
	Encoding             GraphItemEncoding `protobuf:"varint,6,opt,name=encoding,proto3,enum=cloud.deps.api.v1alpha.store.GraphItemEncoding" json:"encoding,omitempty"`
	GraphItemData        []byte            `protobuf:"bytes,7,opt,name=graphItemData,proto3" json:"graphItemData,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GraphItem) Descriptor 

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

func (*GraphItem) GetEncoding 

func (m *GraphItem) GetEncoding() GraphItemEncoding

func (*GraphItem) GetGraphItemData 

func (m *GraphItem) GetGraphItemData() []byte

func (*GraphItem) GetGraphItemType 

func (m *GraphItem) GetGraphItemType() string

func (*GraphItem) GetK1 

func (m *GraphItem) GetK1() []byte

func (*GraphItem) GetK2 

func (m *GraphItem) GetK2() []byte

func (*GraphItem) GetK3 

func (m *GraphItem) GetK3() []byte

func (*GraphItem) ProtoMessage 

func (*GraphItem) ProtoMessage()

func (*GraphItem) Reset 

func (m *GraphItem) Reset()

func (*GraphItem) String 

func (m *GraphItem) String() string

func (*GraphItem) XXX_DiscardUnknown 

func (m *GraphItem) XXX_DiscardUnknown()

func (*GraphItem) XXX_Marshal 

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

func (*GraphItem) XXX_Merge 

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

func (*GraphItem) XXX_Size 

func (m *GraphItem) XXX_Size() int

func (*GraphItem) XXX_Unmarshal 

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

type GraphItemEncoding 

type GraphItemEncoding int32
const (
	GraphItemEncoding_RAW  GraphItemEncoding = 0
	GraphItemEncoding_JSON GraphItemEncoding = 1
)

func (GraphItemEncoding) EnumDescriptor 

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

func (GraphItemEncoding) String 

func (x GraphItemEncoding) String() string

type GraphItemPair 

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

func (*GraphItemPair) Descriptor 

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

func (*GraphItemPair) GetEdge 

func (m *GraphItemPair) GetEdge() *GraphItem

func (*GraphItemPair) GetNode 

func (m *GraphItemPair) GetNode() *GraphItem

func (*GraphItemPair) ProtoMessage 

func (*GraphItemPair) ProtoMessage()

func (*GraphItemPair) Reset 

func (m *GraphItemPair) Reset()

func (*GraphItemPair) String 

func (m *GraphItemPair) String() string

func (*GraphItemPair) XXX_DiscardUnknown 

func (m *GraphItemPair) XXX_DiscardUnknown()

func (*GraphItemPair) XXX_Marshal 

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

func (*GraphItemPair) XXX_Merge 

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

func (*GraphItemPair) XXX_Size 

func (m *GraphItemPair) XXX_Size() int

func (*GraphItemPair) XXX_Unmarshal 

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

type GraphStoreClient 

type GraphStoreClient interface {
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	FindUpstream(ctx context.Context, in *FindRequest, opts ...grpc.CallOption) (*FindResponse, error)
	FindDownstream(ctx context.Context, in *FindRequest, opts ...grpc.CallOption) (*FindResponse, 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

func NewInProcessGraphStoreClient 

func NewInProcessGraphStoreClient(server GraphStoreServer) GraphStoreClient

NewInProcessGraphStoreClient constructs a thin shim allowing a gRPC service to be called from in memory

type GraphStoreServer 

type GraphStoreServer interface {
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	FindUpstream(context.Context, *FindRequest) (*FindResponse, error)
	FindDownstream(context.Context, *FindRequest) (*FindResponse, error)
}

GraphStoreServer is the server API for GraphStore service.

type ListRequest 

type ListRequest struct {
	Page                 int32    `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	Count                int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Type                 string   `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetCount 

func (m *ListRequest) GetCount() int32

func (*ListRequest) GetPage 

func (m *ListRequest) GetPage() int32

func (*ListRequest) GetType 

func (m *ListRequest) GetType() 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 {
	Items                []*GraphItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListResponse) Descriptor 

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

func (*ListResponse) GetItems 

func (m *ListResponse) GetItems() []*GraphItem

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 PutRequest 

type PutRequest struct {
	Items                []*GraphItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetItems 

func (m *PutRequest) GetItems() []*GraphItem

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

func (*UnimplementedGraphStoreServer) FindDownstream(ctx context.Context, req *FindRequest) (*FindResponse, error)

func (*UnimplementedGraphStoreServer) FindUpstream 

func (*UnimplementedGraphStoreServer) FindUpstream(ctx context.Context, req *FindRequest) (*FindResponse, error)

func (*UnimplementedGraphStoreServer) List 

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

func (*UnimplementedGraphStoreServer) Put 

func (*UnimplementedGraphStoreServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, 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.