store

package
v0.3.3 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2021 License: MIT Imports: 8 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for GraphItemEncoding.

View Source 
var File_depscloud_api_v1alpha_store_store_proto protoreflect.FileDescriptor
View Source 
var GraphStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cloud.deps.api.v1alpha.store.GraphStore",
	HandlerType: (*GraphStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Put",
			Handler:    _GraphStore_Put_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _GraphStore_Delete_Handler,
		},
		{
			MethodName: "List",
			Handler:    _GraphStore_List_Handler,
		},
		{
			MethodName: "FindUpstream",
			Handler:    _GraphStore_FindUpstream_Handler,
		},
		{
			MethodName: "FindDownstream",
			Handler:    _GraphStore_FindDownstream_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "depscloud_api/v1alpha/store/store.proto",
}

GraphStore_ServiceDesc is the grpc.ServiceDesc for GraphStore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGraphStoreServer 

func RegisterGraphStoreServer(s grpc.ServiceRegistrar, srv GraphStoreServer)

Types

type DeleteRequest 

type DeleteRequest struct {
	Items []*GraphItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetItems 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect added in v0.3.2 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect added in v0.3.2 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*FindRequest) Descriptor deprecated 

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

Deprecated: Use FindRequest.ProtoReflect.Descriptor instead.

func (*FindRequest) GetEdgeTypes 

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

func (*FindRequest) GetKeys added in v0.1.6 

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

func (*FindRequest) GetNodeTypes added in v0.1.6 

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

func (*FindRequest) ProtoMessage 

func (*FindRequest) ProtoMessage()

func (*FindRequest) ProtoReflect added in v0.3.2 

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

func (*FindRequest) Reset 

func (x *FindRequest) Reset()

func (*FindRequest) String 

func (x *FindRequest) String() string

type FindResponse 

type FindResponse struct {
	Pairs []*GraphItemPair `protobuf:"bytes,1,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*FindResponse) Descriptor deprecated 

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

Deprecated: Use FindResponse.ProtoReflect.Descriptor instead.

func (*FindResponse) GetPairs 

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

func (*FindResponse) ProtoMessage 

func (*FindResponse) ProtoMessage()

func (*FindResponse) ProtoReflect added in v0.3.2 

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

func (*FindResponse) Reset 

func (x *FindResponse) Reset()

func (*FindResponse) String 

func (x *FindResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GraphItem) Descriptor deprecated 

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

Deprecated: Use GraphItem.ProtoReflect.Descriptor instead.

func (*GraphItem) GetEncoding 

func (x *GraphItem) GetEncoding() GraphItemEncoding

func (*GraphItem) GetGraphItemData 

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

func (*GraphItem) GetGraphItemType 

func (x *GraphItem) GetGraphItemType() string

func (*GraphItem) GetK1 

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

func (*GraphItem) GetK2 

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

func (*GraphItem) GetK3 

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

func (*GraphItem) ProtoMessage 

func (*GraphItem) ProtoMessage()

func (*GraphItem) ProtoReflect added in v0.3.2 

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

func (*GraphItem) Reset 

func (x *GraphItem) Reset()

func (*GraphItem) String 

func (x *GraphItem) String() string

type GraphItemEncoding 

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

func (GraphItemEncoding) Descriptor added in v0.3.2 

func (GraphItemEncoding) Descriptor() protoreflect.EnumDescriptor

func (GraphItemEncoding) Enum added in v0.3.2 

func (x GraphItemEncoding) Enum() *GraphItemEncoding

func (GraphItemEncoding) EnumDescriptor deprecated 

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

Deprecated: Use GraphItemEncoding.Descriptor instead.

func (GraphItemEncoding) Number added in v0.3.2 

func (x GraphItemEncoding) Number() protoreflect.EnumNumber

func (GraphItemEncoding) String 

func (x GraphItemEncoding) String() string

func (GraphItemEncoding) Type added in v0.3.2 

func (GraphItemEncoding) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*GraphItemPair) Descriptor deprecated 

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

Deprecated: Use GraphItemPair.ProtoReflect.Descriptor instead.

func (*GraphItemPair) GetEdge 

func (x *GraphItemPair) GetEdge() *GraphItem

func (*GraphItemPair) GetNode 

func (x *GraphItemPair) GetNode() *GraphItem

func (*GraphItemPair) ProtoMessage 

func (*GraphItemPair) ProtoMessage()

func (*GraphItemPair) ProtoReflect added in v0.3.2 

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

func (*GraphItemPair) Reset 

func (x *GraphItemPair) Reset()

func (*GraphItemPair) String 

func (x *GraphItemPair) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGraphStoreClient 

func NewGraphStoreClient(cc grpc.ClientConnInterface) 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)
	// contains filtered or unexported methods
}

GraphStoreServer is the server API for GraphStore service. All implementations must embed UnimplementedGraphStoreServer for forward compatibility

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"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetCount 

func (x *ListRequest) GetCount() int32

func (*ListRequest) GetPage 

func (x *ListRequest) GetPage() int32

func (*ListRequest) GetType 

func (x *ListRequest) GetType() string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect added in v0.3.2 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Items []*GraphItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetItems 

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

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect added in v0.3.2 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type PutRequest 

type PutRequest struct {
	Items []*GraphItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetItems 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect added in v0.3.2 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type PutResponse 

type PutResponse struct {
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect added in v0.3.2 

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

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) String 

func (x *PutResponse) String() string

type UnimplementedGraphStoreServer 

type UnimplementedGraphStoreServer struct {
}

UnimplementedGraphStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedGraphStoreServer) Delete 

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

func (UnimplementedGraphStoreServer) FindDownstream 

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

func (UnimplementedGraphStoreServer) FindUpstream 

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

func (UnimplementedGraphStoreServer) List 

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

func (UnimplementedGraphStoreServer) Put 

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

type UnsafeGraphStoreServer added in v0.3.2 

type UnsafeGraphStoreServer interface {
	// contains filtered or unexported methods
}

UnsafeGraphStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GraphStoreServer will result in compilation errors.

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.