apipb

package
v0.0.18 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Any = "*"
)

Variables

View Source 
var File_api_graphik_proto protoreflect.FileDescriptor

Functions

func NewStruct 

func NewStruct(data map[string]interface{}) *structpb.Struct

func RegisterGraphServiceServer 

func RegisterGraphServiceServer(s *grpc.Server, srv GraphServiceServer)

func RegisterTriggerServiceServer 

func RegisterTriggerServiceServer(s *grpc.Server, srv TriggerServiceServer)

Types

type Change added in v0.0.9 

type Change struct {

	// method is the gRPC method invoked
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// identity is the identity invoking the change
	Identity *Node `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	// timestamp is when the change was made
	Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// edge_changes are state changes to edges
	EdgeChanges []*EdgeChange `protobuf:"bytes,4,rep,name=edge_changes,json=edgeChanges,proto3" json:"edge_changes,omitempty"`
	// node_changes are state changes to nodes
	NodeChanges []*NodeChange `protobuf:"bytes,5,rep,name=node_changes,json=nodeChanges,proto3" json:"node_changes,omitempty"`
	// contains filtered or unexported fields
}

Change represents a set of state changes in the graph

func (*Change) AsMap added in v0.0.9 

func (c *Change) AsMap() map[string]interface{}

func (*Change) Descriptor deprecated added in v0.0.9 

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

Deprecated: Use Change.ProtoReflect.Descriptor instead.

func (*Change) GetEdgeChanges added in v0.0.9 

func (x *Change) GetEdgeChanges() []*EdgeChange

func (*Change) GetIdentity added in v0.0.9 

func (x *Change) GetIdentity() *Node

func (*Change) GetMethod added in v0.0.9 

func (x *Change) GetMethod() string

func (*Change) GetNodeChanges added in v0.0.9 

func (x *Change) GetNodeChanges() []*NodeChange

func (*Change) GetTimestamp added in v0.0.9 

func (x *Change) GetTimestamp() *timestamp.Timestamp

func (*Change) ProtoMessage added in v0.0.9 

func (*Change) ProtoMessage()

func (*Change) ProtoReflect added in v0.0.15 

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

func (*Change) Reset added in v0.0.9 

func (x *Change) Reset()

func (*Change) String added in v0.0.9 

func (x *Change) String() string

func (*Change) Validate added in v0.0.9 

func (this *Change) Validate() error

type ChannelFilter 

type ChannelFilter struct {

	// channel is the target channel to filter from
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// expressions are CEL expressions used to filter messages
	Expressions []string `protobuf:"bytes,2,rep,name=expressions,proto3" json:"expressions,omitempty"`
	// contains filtered or unexported fields
}

ChannelFilter is used to filter messages in a pubsub channel

func (*ChannelFilter) AsMap added in v0.0.9 

func (n *ChannelFilter) AsMap() map[string]interface{}

func (*ChannelFilter) Descriptor deprecated 

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

Deprecated: Use ChannelFilter.ProtoReflect.Descriptor instead.

func (*ChannelFilter) GetChannel 

func (x *ChannelFilter) GetChannel() string

func (*ChannelFilter) GetExpressions 

func (x *ChannelFilter) GetExpressions() []string

func (*ChannelFilter) ProtoMessage 

func (*ChannelFilter) ProtoMessage()

func (*ChannelFilter) ProtoReflect added in v0.0.15 

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

func (*ChannelFilter) Reset 

func (x *ChannelFilter) Reset()

func (*ChannelFilter) String 

func (x *ChannelFilter) String() string

func (*ChannelFilter) Validate 

func (this *ChannelFilter) Validate() error

type Edge 

type Edge struct {

	// path is the path to the edge
	Path *Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// attributes are k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// directed is false if the edge is bi-directional
	Directed bool `protobuf:"varint,3,opt,name=directed,proto3" json:"directed,omitempty"`
	// from is the node path that is the source of the edge
	From *Path `protobuf:"bytes,4,opt,name=from,proto3" json:"from,omitempty"`
	// to is the node path that is the destination of the edge
	To *Path `protobuf:"bytes,5,opt,name=to,proto3" json:"to,omitempty"`
	// metadata is general metadata collected about the edge
	Metadata *Metadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Edge is a graph primitive that represents a relationship between two nodes

func (*Edge) AsMap added in v0.0.2 

func (n *Edge) AsMap() map[string]interface{}

func (*Edge) Descriptor deprecated 

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

Deprecated: Use Edge.ProtoReflect.Descriptor instead.

func (*Edge) FromMap added in v0.0.3 

func (m *Edge) FromMap(data map[string]interface{})

func (*Edge) GetAttributes 

func (x *Edge) GetAttributes() *_struct.Struct

func (*Edge) GetDirected added in v0.0.9 

func (x *Edge) GetDirected() bool

func (*Edge) GetFrom 

func (x *Edge) GetFrom() *Path

func (*Edge) GetMetadata added in v0.0.2 

func (x *Edge) GetMetadata() *Metadata

func (*Edge) GetPath 

func (x *Edge) GetPath() *Path

func (*Edge) GetTo 

func (x *Edge) GetTo() *Path

func (*Edge) ProtoMessage 

func (*Edge) ProtoMessage()

func (*Edge) ProtoReflect added in v0.0.15 

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

func (*Edge) Reset 

func (x *Edge) Reset()

func (*Edge) String 

func (x *Edge) String() string

func (*Edge) Validate 

func (this *Edge) Validate() error

type EdgeChange added in v0.0.9 

type EdgeChange struct {
	Before *Edge `protobuf:"bytes,4,opt,name=before,proto3" json:"before,omitempty"`
	After  *Edge `protobuf:"bytes,5,opt,name=after,proto3" json:"after,omitempty"`
	// contains filtered or unexported fields
}

func (*EdgeChange) Descriptor deprecated added in v0.0.9 

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

Deprecated: Use EdgeChange.ProtoReflect.Descriptor instead.

func (*EdgeChange) GetAfter added in v0.0.9 

func (x *EdgeChange) GetAfter() *Edge

func (*EdgeChange) GetBefore added in v0.0.9 

func (x *EdgeChange) GetBefore() *Edge

func (*EdgeChange) ProtoMessage added in v0.0.9 

func (*EdgeChange) ProtoMessage()

func (*EdgeChange) ProtoReflect added in v0.0.15 

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

func (*EdgeChange) Reset added in v0.0.9 

func (x *EdgeChange) Reset()

func (*EdgeChange) String added in v0.0.9 

func (x *EdgeChange) String() string

func (*EdgeChange) Validate added in v0.0.9 

func (this *EdgeChange) Validate() error

type EdgeConstructor 

type EdgeConstructor struct {

	// path is the path to the edge. If an id is not provided, a unique id will be generated
	Path *Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// attributes are k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// directed is false if the edge is bi-directional
	Directed bool `protobuf:"varint,4,opt,name=directed,proto3" json:"directed,omitempty"`
	// from is the node path that is the root of the edge
	From *Path `protobuf:"bytes,5,opt,name=from,proto3" json:"from,omitempty"`
	// to is the node path that is the destination of the edge
	To *Path `protobuf:"bytes,6,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

EdgeConstructor is used to create an Edge

func (*EdgeConstructor) AsMap added in v0.0.9 

func (e *EdgeConstructor) AsMap() map[string]interface{}

func (*EdgeConstructor) Descriptor deprecated 

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

Deprecated: Use EdgeConstructor.ProtoReflect.Descriptor instead.

func (*EdgeConstructor) GetAttributes 

func (x *EdgeConstructor) GetAttributes() *_struct.Struct

func (*EdgeConstructor) GetDirected added in v0.0.9 

func (x *EdgeConstructor) GetDirected() bool

func (*EdgeConstructor) GetFrom 

func (x *EdgeConstructor) GetFrom() *Path

func (*EdgeConstructor) GetPath 

func (x *EdgeConstructor) GetPath() *Path

func (*EdgeConstructor) GetTo 

func (x *EdgeConstructor) GetTo() *Path

func (*EdgeConstructor) ProtoMessage 

func (*EdgeConstructor) ProtoMessage()

func (*EdgeConstructor) ProtoReflect added in v0.0.15 

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

func (*EdgeConstructor) Reset 

func (x *EdgeConstructor) Reset()

func (*EdgeConstructor) String 

func (x *EdgeConstructor) String() string

func (*EdgeConstructor) Validate 

func (this *EdgeConstructor) Validate() error

type EdgeConstructors 

type EdgeConstructors struct {
	Edges []*EdgeConstructor `protobuf:"bytes,1,rep,name=edges,proto3" json:"edges,omitempty"`
	// contains filtered or unexported fields
}

EdgeConstructors is an array of EdgeConstructor

func (*EdgeConstructors) Descriptor deprecated 

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

Deprecated: Use EdgeConstructors.ProtoReflect.Descriptor instead.

func (*EdgeConstructors) GetEdges 

func (x *EdgeConstructors) GetEdges() []*EdgeConstructor

func (*EdgeConstructors) ProtoMessage 

func (*EdgeConstructors) ProtoMessage()

func (*EdgeConstructors) ProtoReflect added in v0.0.15 

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

func (*EdgeConstructors) Reset 

func (x *EdgeConstructors) Reset()

func (*EdgeConstructors) String 

func (x *EdgeConstructors) String() string

func (*EdgeConstructors) Validate 

func (this *EdgeConstructors) Validate() error

type EdgeDetail 

type EdgeDetail struct {

	// path is the path to the edge
	Path *Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// attributes are k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// directed is false if the edge is bi-directional
	Directed bool `protobuf:"varint,3,opt,name=directed,proto3" json:"directed,omitempty"`
	// from is the full node that is the root of the edge
	From *Node `protobuf:"bytes,4,opt,name=from,proto3" json:"from,omitempty"`
	// to is the full node that is the destination of the edge
	To *Node `protobuf:"bytes,5,opt,name=to,proto3" json:"to,omitempty"`
	// metadata is general metadata collected about the edge
	Metadata *Metadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

EdgeDetail is an edge with both of it's connected nodes fully loaded

func (*EdgeDetail) Descriptor deprecated 

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

Deprecated: Use EdgeDetail.ProtoReflect.Descriptor instead.

func (*EdgeDetail) GetAttributes 

func (x *EdgeDetail) GetAttributes() *_struct.Struct

func (*EdgeDetail) GetDirected added in v0.0.9 

func (x *EdgeDetail) GetDirected() bool

func (*EdgeDetail) GetFrom 

func (x *EdgeDetail) GetFrom() *Node

func (*EdgeDetail) GetMetadata added in v0.0.2 

func (x *EdgeDetail) GetMetadata() *Metadata

func (*EdgeDetail) GetPath 

func (x *EdgeDetail) GetPath() *Path

func (*EdgeDetail) GetTo 

func (x *EdgeDetail) GetTo() *Node

func (*EdgeDetail) ProtoMessage 

func (*EdgeDetail) ProtoMessage()

func (*EdgeDetail) ProtoReflect added in v0.0.15 

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

func (*EdgeDetail) Reset 

func (x *EdgeDetail) Reset()

func (*EdgeDetail) String 

func (x *EdgeDetail) String() string

func (*EdgeDetail) Validate 

func (this *EdgeDetail) Validate() error

type EdgeDetails 

type EdgeDetails struct {
	Edges []*EdgeDetail `protobuf:"bytes,1,rep,name=edges,proto3" json:"edges,omitempty"`
	// contains filtered or unexported fields
}

EdgeDetails is an array of EdgeDetail

func (*EdgeDetails) Descriptor deprecated 

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

Deprecated: Use EdgeDetails.ProtoReflect.Descriptor instead.

func (*EdgeDetails) GetEdges 

func (x *EdgeDetails) GetEdges() []*EdgeDetail

func (*EdgeDetails) ProtoMessage 

func (*EdgeDetails) ProtoMessage()

func (*EdgeDetails) ProtoReflect added in v0.0.15 

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

func (*EdgeDetails) Reset 

func (x *EdgeDetails) Reset()

func (*EdgeDetails) Sort 

func (e *EdgeDetails) Sort()

func (*EdgeDetails) String 

func (x *EdgeDetails) String() string

func (*EdgeDetails) Validate 

func (this *EdgeDetails) Validate() error

type EdgeFilter 

type EdgeFilter struct {

	// node_path is the path to the target node
	NodePath *Path `protobuf:"bytes,1,opt,name=node_path,json=nodePath,proto3" json:"node_path,omitempty"`
	// gtype is the type of edges to return
	Gtype string `protobuf:"bytes,2,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// expressions are CEL expressions used to filter edges
	Expressions []string `protobuf:"bytes,3,rep,name=expressions,proto3" json:"expressions,omitempty"`
	// limit is the maximum number of edges to return
	Limit int32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

EdgeFilter is used to fetch edges related to a single noted

func (*EdgeFilter) AsMap added in v0.0.9 

func (n *EdgeFilter) AsMap() map[string]interface{}

func (*EdgeFilter) Descriptor deprecated 

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

Deprecated: Use EdgeFilter.ProtoReflect.Descriptor instead.

func (*EdgeFilter) GetExpressions 

func (x *EdgeFilter) GetExpressions() []string

func (*EdgeFilter) GetGtype 

func (x *EdgeFilter) GetGtype() string

func (*EdgeFilter) GetLimit 

func (x *EdgeFilter) GetLimit() int32

func (*EdgeFilter) GetNodePath 

func (x *EdgeFilter) GetNodePath() *Path

func (*EdgeFilter) ProtoMessage 

func (*EdgeFilter) ProtoMessage()

func (*EdgeFilter) ProtoReflect added in v0.0.15 

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

func (*EdgeFilter) Reset 

func (x *EdgeFilter) Reset()

func (*EdgeFilter) String 

func (x *EdgeFilter) String() string

func (*EdgeFilter) Validate 

func (this *EdgeFilter) Validate() error

type Edges 

type Edges struct {
	Edges []*Edge `protobuf:"bytes,1,rep,name=edges,proto3" json:"edges,omitempty"`
	// contains filtered or unexported fields
}

Edges is an array of Edge

func (*Edges) AsMap added in v0.0.11 

func (e *Edges) AsMap() map[string]interface{}

func (*Edges) Descriptor deprecated 

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

Deprecated: Use Edges.ProtoReflect.Descriptor instead.

func (*Edges) GetEdges 

func (x *Edges) GetEdges() []*Edge

func (*Edges) ProtoMessage 

func (*Edges) ProtoMessage()

func (*Edges) ProtoReflect added in v0.0.15 

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

func (*Edges) Reset 

func (x *Edges) Reset()

func (*Edges) Sort 

func (e *Edges) Sort()

func (*Edges) String 

func (x *Edges) String() string

func (*Edges) Validate 

func (this *Edges) Validate() error

type ExpressionFilter added in v0.0.9 

type ExpressionFilter struct {

	// expressions are CEL expressions used to filter edges
	Expressions []string `protobuf:"bytes,1,rep,name=expressions,proto3" json:"expressions,omitempty"`
	// contains filtered or unexported fields
}

func (*ExpressionFilter) AsMap added in v0.0.9 

func (n *ExpressionFilter) AsMap() map[string]interface{}

func (*ExpressionFilter) Descriptor deprecated added in v0.0.9 

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

Deprecated: Use ExpressionFilter.ProtoReflect.Descriptor instead.

func (*ExpressionFilter) GetExpressions added in v0.0.9 

func (x *ExpressionFilter) GetExpressions() []string

func (*ExpressionFilter) ProtoMessage added in v0.0.9 

func (*ExpressionFilter) ProtoMessage()

func (*ExpressionFilter) ProtoReflect added in v0.0.15 

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

func (*ExpressionFilter) Reset added in v0.0.9 

func (x *ExpressionFilter) Reset()

func (*ExpressionFilter) String added in v0.0.9 

func (x *ExpressionFilter) String() string

func (*ExpressionFilter) Validate added in v0.0.9 

func (this *ExpressionFilter) Validate() error

type Filter 

type Filter struct {

	// gtype is the node/edge type to be filtered
	Gtype string `protobuf:"bytes,1,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// expressions are CEL expressions used to filter edges
	Expressions []string `protobuf:"bytes,2,rep,name=expressions,proto3" json:"expressions,omitempty"`
	// limit is the maximum number of items to return
	Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

Filter is a generic filter using Common Expression Language

func (*Filter) AsMap added in v0.0.9 

func (n *Filter) AsMap() map[string]interface{}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetExpressions 

func (x *Filter) GetExpressions() []string

func (*Filter) GetGtype 

func (x *Filter) GetGtype() string

func (*Filter) GetLimit 

func (x *Filter) GetLimit() int32

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect added in v0.0.15 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

func (*Filter) Validate 

func (this *Filter) Validate() error

type FromMapper added in v0.0.3 

type FromMapper interface {
	FromMap(data map[string]interface{})
}

type Graph 

type Graph struct {

	// nodes are nodes present in the graph
	Nodes *Nodes `protobuf:"bytes,1,opt,name=nodes,proto3" json:"nodes,omitempty"`
	// edges are edges present in the graph
	Edges *Edges `protobuf:"bytes,2,opt,name=edges,proto3" json:"edges,omitempty"`
	// contains filtered or unexported fields
}

Graph is an array of nodes and edges

func (*Graph) AsMap added in v0.0.11 

func (g *Graph) AsMap() map[string]interface{}

func (*Graph) Descriptor deprecated 

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

Deprecated: Use Graph.ProtoReflect.Descriptor instead.

func (*Graph) GetEdges 

func (x *Graph) GetEdges() *Edges

func (*Graph) GetNodes 

func (x *Graph) GetNodes() *Nodes

func (*Graph) ProtoMessage 

func (*Graph) ProtoMessage()

func (*Graph) ProtoReflect added in v0.0.15 

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

func (*Graph) Reset 

func (x *Graph) Reset()

func (*Graph) String 

func (x *Graph) String() string

func (*Graph) Validate 

func (this *Graph) Validate() error

type GraphServiceClient 

type GraphServiceClient interface {
	// Ping returns PONG if the server is health
	Ping(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Pong, error)
	// GetSchema gets schema about the Graph node & edge types
	GetSchema(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Schema, error)
	// Me returns a NodeDetail of the currently logged in identity(the subject of the JWT)
	Me(ctx context.Context, in *MeFilter, opts ...grpc.CallOption) (*NodeDetail, error)
	// CreateNode creates a node in the graph
	CreateNode(ctx context.Context, in *NodeConstructor, opts ...grpc.CallOption) (*Node, error)
	// CreateNodes creates a batch of nodes in the graph
	CreateNodes(ctx context.Context, in *NodeConstructors, opts ...grpc.CallOption) (*Nodes, error)
	// GetNode gets a single node in the graph
	GetNode(ctx context.Context, in *Path, opts ...grpc.CallOption) (*Node, error)
	// SearchNodes searches the graph for nodes
	SearchNodes(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Nodes, error)
	// PatchNode patches a nodes attributes
	PatchNode(ctx context.Context, in *Patch, opts ...grpc.CallOption) (*Node, error)
	// PatchNodes patches a batch of nodes attributes
	PatchNodes(ctx context.Context, in *PatchFilter, opts ...grpc.CallOption) (*Nodes, error)
	// CreateEdge creates an edge in the graph
	CreateEdge(ctx context.Context, in *EdgeConstructor, opts ...grpc.CallOption) (*Edge, error)
	// CreateEdges creates a batch of edges in the graph
	CreateEdges(ctx context.Context, in *EdgeConstructors, opts ...grpc.CallOption) (*Edges, error)
	// GetEdge gets a single edge in the graph
	GetEdge(ctx context.Context, in *Path, opts ...grpc.CallOption) (*Edge, error)
	// SearchEdges searches the graph for edges
	SearchEdges(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Edges, error)
	// PatchEdge patches an edges attributes
	PatchEdge(ctx context.Context, in *Patch, opts ...grpc.CallOption) (*Edge, error)
	// PatchEdges patches a batch of edges attributes
	PatchEdges(ctx context.Context, in *PatchFilter, opts ...grpc.CallOption) (*Edges, error)
	// EdgesFrom returns edges that source from the given node path that pass the filter
	EdgesFrom(ctx context.Context, in *EdgeFilter, opts ...grpc.CallOption) (*Edges, error)
	// EdgesTo returns edges that point to the given node path that pass the filter
	EdgesTo(ctx context.Context, in *EdgeFilter, opts ...grpc.CallOption) (*Edges, error)
	// Publish publishes a message to a pubsub channel
	Publish(ctx context.Context, in *OutboundMessage, opts ...grpc.CallOption) (*empty.Empty, error)
	// Subscribe subscribes to messages on a pubsub channel
	Subscribe(ctx context.Context, in *ChannelFilter, opts ...grpc.CallOption) (GraphService_SubscribeClient, error)
	SubscribeChanges(ctx context.Context, in *ExpressionFilter, opts ...grpc.CallOption) (GraphService_SubscribeChangesClient, error)
	// Import imports the Graph into the database
	Import(ctx context.Context, in *Graph, opts ...grpc.CallOption) (*Graph, error)
	// Export returns the Graph data
	Export(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Graph, error)
	// SubGraph returns a subgraph using the given filter
	SubGraph(ctx context.Context, in *SubGraphFilter, opts ...grpc.CallOption) (*Graph, error)
	// Shutdown shuts down the database
	Shutdown(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

GraphServiceClient is the client API for GraphService service.

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

func NewGraphServiceClient 

func NewGraphServiceClient(cc grpc.ClientConnInterface) GraphServiceClient

type GraphServiceServer 

type GraphServiceServer interface {
	// Ping returns PONG if the server is health
	Ping(context.Context, *empty.Empty) (*Pong, error)
	// GetSchema gets schema about the Graph node & edge types
	GetSchema(context.Context, *empty.Empty) (*Schema, error)
	// Me returns a NodeDetail of the currently logged in identity(the subject of the JWT)
	Me(context.Context, *MeFilter) (*NodeDetail, error)
	// CreateNode creates a node in the graph
	CreateNode(context.Context, *NodeConstructor) (*Node, error)
	// CreateNodes creates a batch of nodes in the graph
	CreateNodes(context.Context, *NodeConstructors) (*Nodes, error)
	// GetNode gets a single node in the graph
	GetNode(context.Context, *Path) (*Node, error)
	// SearchNodes searches the graph for nodes
	SearchNodes(context.Context, *Filter) (*Nodes, error)
	// PatchNode patches a nodes attributes
	PatchNode(context.Context, *Patch) (*Node, error)
	// PatchNodes patches a batch of nodes attributes
	PatchNodes(context.Context, *PatchFilter) (*Nodes, error)
	// CreateEdge creates an edge in the graph
	CreateEdge(context.Context, *EdgeConstructor) (*Edge, error)
	// CreateEdges creates a batch of edges in the graph
	CreateEdges(context.Context, *EdgeConstructors) (*Edges, error)
	// GetEdge gets a single edge in the graph
	GetEdge(context.Context, *Path) (*Edge, error)
	// SearchEdges searches the graph for edges
	SearchEdges(context.Context, *Filter) (*Edges, error)
	// PatchEdge patches an edges attributes
	PatchEdge(context.Context, *Patch) (*Edge, error)
	// PatchEdges patches a batch of edges attributes
	PatchEdges(context.Context, *PatchFilter) (*Edges, error)
	// EdgesFrom returns edges that source from the given node path that pass the filter
	EdgesFrom(context.Context, *EdgeFilter) (*Edges, error)
	// EdgesTo returns edges that point to the given node path that pass the filter
	EdgesTo(context.Context, *EdgeFilter) (*Edges, error)
	// Publish publishes a message to a pubsub channel
	Publish(context.Context, *OutboundMessage) (*empty.Empty, error)
	// Subscribe subscribes to messages on a pubsub channel
	Subscribe(*ChannelFilter, GraphService_SubscribeServer) error
	SubscribeChanges(*ExpressionFilter, GraphService_SubscribeChangesServer) error
	// Import imports the Graph into the database
	Import(context.Context, *Graph) (*Graph, error)
	// Export returns the Graph data
	Export(context.Context, *empty.Empty) (*Graph, error)
	// SubGraph returns a subgraph using the given filter
	SubGraph(context.Context, *SubGraphFilter) (*Graph, error)
	// Shutdown shuts down the database
	Shutdown(context.Context, *empty.Empty) (*empty.Empty, error)
}

GraphServiceServer is the server API for GraphService service.

type GraphService_SubscribeChangesClient added in v0.0.9 

type GraphService_SubscribeChangesClient interface {
	Recv() (*Change, error)
	grpc.ClientStream
}

type GraphService_SubscribeChangesServer added in v0.0.9 

type GraphService_SubscribeChangesServer interface {
	Send(*Change) error
	grpc.ServerStream
}

type GraphService_SubscribeClient 

type GraphService_SubscribeClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type GraphService_SubscribeServer 

type GraphService_SubscribeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type Mapper added in v0.0.2 

type Mapper interface {
	AsMap() map[string]interface{}
}

type MeFilter 

type MeFilter struct {

	// edges_from is a filter used to filter edges from the identity making the request
	EdgesFrom *Filter `protobuf:"bytes,1,opt,name=edges_from,json=edgesFrom,proto3" json:"edges_from,omitempty"`
	// edges_to is a filter used to filter edges to the identity making the request
	EdgesTo *Filter `protobuf:"bytes,2,opt,name=edges_to,json=edgesTo,proto3" json:"edges_to,omitempty"`
	// contains filtered or unexported fields
}

MeFilter is used to fetch a NodeDetail representing the identity in the inbound JWT token

func (*MeFilter) AsMap added in v0.0.9 

func (m *MeFilter) AsMap() map[string]interface{}

func (*MeFilter) Descriptor deprecated 

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

Deprecated: Use MeFilter.ProtoReflect.Descriptor instead.

func (*MeFilter) GetEdgesFrom 

func (x *MeFilter) GetEdgesFrom() *Filter

func (*MeFilter) GetEdgesTo 

func (x *MeFilter) GetEdgesTo() *Filter

func (*MeFilter) ProtoMessage 

func (*MeFilter) ProtoMessage()

func (*MeFilter) ProtoReflect added in v0.0.15 

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

func (*MeFilter) Reset 

func (x *MeFilter) Reset()

func (*MeFilter) String 

func (x *MeFilter) String() string

func (*MeFilter) Validate 

func (this *MeFilter) Validate() error

type Message 

type Message struct {

	// channel is the channel the message was sent to
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// data is the data sent with the message
	Data *_struct.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// sender is the identity that sent the message
	Sender *Path `protobuf:"bytes,3,opt,name=sender,proto3" json:"sender,omitempty"`
	// timestamp is when the message was sent
	Timestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Message is received on PubSub subscriptions

func (*Message) AsMap added in v0.0.2 

func (n *Message) AsMap() map[string]interface{}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) FromMap added in v0.0.3 

func (m *Message) FromMap(data map[string]interface{})

func (*Message) GetChannel 

func (x *Message) GetChannel() string

func (*Message) GetData 

func (x *Message) GetData() *_struct.Struct

func (*Message) GetSender 

func (x *Message) GetSender() *Path

func (*Message) GetTimestamp 

func (x *Message) GetTimestamp() *timestamp.Timestamp

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect added in v0.0.15 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

func (*Message) Validate 

func (this *Message) Validate() error

type Metadata added in v0.0.2 

type Metadata struct {

	// created_at is the unix timestamp when the node/edge was created
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// updated_at is the unix timestamp when the node/edge was last updated
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// updated_by is the identity that last modified the node/edge
	UpdatedBy *Path `protobuf:"bytes,3,opt,name=updated_by,json=updatedBy,proto3" json:"updated_by,omitempty"`
	// sequence is the sequence within the context of the node/edge type
	Sequence uint64 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// version iterates by 1 every time the node/edge is modified
	Version uint64 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Metadata is general metadata collected on nodes/edges

func (*Metadata) AsMap added in v0.0.2 

func (m *Metadata) AsMap() map[string]interface{}

func (*Metadata) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) FromMap added in v0.0.3 

func (m *Metadata) FromMap(data map[string]interface{})

func (*Metadata) GetCreatedAt added in v0.0.2 

func (x *Metadata) GetCreatedAt() *timestamp.Timestamp

func (*Metadata) GetSequence added in v0.0.3 

func (x *Metadata) GetSequence() uint64

func (*Metadata) GetUpdatedAt added in v0.0.2 

func (x *Metadata) GetUpdatedAt() *timestamp.Timestamp

func (*Metadata) GetUpdatedBy added in v0.0.2 

func (x *Metadata) GetUpdatedBy() *Path

func (*Metadata) GetVersion added in v0.0.9 

func (x *Metadata) GetVersion() uint64

func (*Metadata) ProtoMessage added in v0.0.2 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect added in v0.0.15 

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

func (*Metadata) Reset added in v0.0.2 

func (x *Metadata) Reset()

func (*Metadata) String added in v0.0.2 

func (x *Metadata) String() string

func (*Metadata) Validate added in v0.0.2 

func (this *Metadata) Validate() error

type Node 

type Node struct {

	// path is the path to the node
	Path *Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// metadata is general metadata collected about the node
	Metadata *Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Node is a Graph primitive representing a single entity/resource. It is connected to other nodes via Edges

func (*Node) AsMap added in v0.0.2 

func (n *Node) AsMap() map[string]interface{}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) FromMap added in v0.0.3 

func (m *Node) FromMap(data map[string]interface{})

func (*Node) GetAttributes 

func (x *Node) GetAttributes() *_struct.Struct

func (*Node) GetMetadata added in v0.0.2 

func (x *Node) GetMetadata() *Metadata

func (*Node) GetPath 

func (x *Node) GetPath() *Path

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect added in v0.0.15 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

func (*Node) Validate 

func (this *Node) Validate() error

type NodeChange added in v0.0.9 

type NodeChange struct {

	// before is the node before state change
	Before *Node `protobuf:"bytes,4,opt,name=before,proto3" json:"before,omitempty"`
	// after is the node after state change
	After *Node `protobuf:"bytes,5,opt,name=after,proto3" json:"after,omitempty"`
	// contains filtered or unexported fields
}

NodeChange is a single state change to a node

func (*NodeChange) Descriptor deprecated added in v0.0.9 

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

Deprecated: Use NodeChange.ProtoReflect.Descriptor instead.

func (*NodeChange) GetAfter added in v0.0.9 

func (x *NodeChange) GetAfter() *Node

func (*NodeChange) GetBefore added in v0.0.9 

func (x *NodeChange) GetBefore() *Node

func (*NodeChange) ProtoMessage added in v0.0.9 

func (*NodeChange) ProtoMessage()

func (*NodeChange) ProtoReflect added in v0.0.15 

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

func (*NodeChange) Reset added in v0.0.9 

func (x *NodeChange) Reset()

func (*NodeChange) String added in v0.0.9 

func (x *NodeChange) String() string

func (*NodeChange) Validate added in v0.0.9 

func (this *NodeChange) Validate() error

type NodeConstructor 

type NodeConstructor struct {

	// path is the path to the node. If an id is not provided, a unique id will be generated
	Path *Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// arbitrary k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

NodeConstructor is used to create a node

func (*NodeConstructor) AsMap added in v0.0.9 

func (e *NodeConstructor) AsMap() map[string]interface{}

func (*NodeConstructor) Descriptor deprecated 

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

Deprecated: Use NodeConstructor.ProtoReflect.Descriptor instead.

func (*NodeConstructor) GetAttributes 

func (x *NodeConstructor) GetAttributes() *_struct.Struct

func (*NodeConstructor) GetPath 

func (x *NodeConstructor) GetPath() *Path

func (*NodeConstructor) ProtoMessage 

func (*NodeConstructor) ProtoMessage()

func (*NodeConstructor) ProtoReflect added in v0.0.15 

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

func (*NodeConstructor) Reset 

func (x *NodeConstructor) Reset()

func (*NodeConstructor) String 

func (x *NodeConstructor) String() string

func (*NodeConstructor) Validate 

func (this *NodeConstructor) Validate() error

type NodeConstructors 

type NodeConstructors struct {

	// nodes is an array of node constructors
	Nodes []*NodeConstructor `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

NodeConstructor is used to create a batch of nodes

func (*NodeConstructors) Descriptor deprecated 

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

Deprecated: Use NodeConstructors.ProtoReflect.Descriptor instead.

func (*NodeConstructors) GetNodes 

func (x *NodeConstructors) GetNodes() []*NodeConstructor

func (*NodeConstructors) ProtoMessage 

func (*NodeConstructors) ProtoMessage()

func (*NodeConstructors) ProtoReflect added in v0.0.15 

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

func (*NodeConstructors) Reset 

func (x *NodeConstructors) Reset()

func (*NodeConstructors) String 

func (x *NodeConstructors) String() string

func (*NodeConstructors) Validate 

func (this *NodeConstructors) Validate() error

type NodeDetail 

type NodeDetail struct {

	// path is the path to the node
	Path *Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// arbitrary k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// edges_from are edges that source from this node
	EdgesFrom *EdgeDetails `protobuf:"bytes,3,opt,name=edges_from,json=edgesFrom,proto3" json:"edges_from,omitempty"`
	// edges_to are edges that point toward this node
	EdgesTo *EdgeDetails `protobuf:"bytes,4,opt,name=edges_to,json=edgesTo,proto3" json:"edges_to,omitempty"`
	// metadata is general metadata collected about the node
	Metadata *Metadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

NodeDetail is a node with its connected edges

func (*NodeDetail) Descriptor deprecated 

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

Deprecated: Use NodeDetail.ProtoReflect.Descriptor instead.

func (*NodeDetail) GetAttributes 

func (x *NodeDetail) GetAttributes() *_struct.Struct

func (*NodeDetail) GetEdgesFrom 

func (x *NodeDetail) GetEdgesFrom() *EdgeDetails

func (*NodeDetail) GetEdgesTo 

func (x *NodeDetail) GetEdgesTo() *EdgeDetails

func (*NodeDetail) GetMetadata added in v0.0.2 

func (x *NodeDetail) GetMetadata() *Metadata

func (*NodeDetail) GetPath 

func (x *NodeDetail) GetPath() *Path

func (*NodeDetail) ProtoMessage 

func (*NodeDetail) ProtoMessage()

func (*NodeDetail) ProtoReflect added in v0.0.15 

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

func (*NodeDetail) Reset 

func (x *NodeDetail) Reset()

func (*NodeDetail) String 

func (x *NodeDetail) String() string

func (*NodeDetail) Validate 

func (this *NodeDetail) Validate() error

type NodeDetailFilter 

type NodeDetailFilter struct {

	// path is the path to the node
	Path      *Path   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	FromEdges *Filter `protobuf:"bytes,2,opt,name=from_edges,json=fromEdges,proto3" json:"from_edges,omitempty"`
	ToEdges   *Filter `protobuf:"bytes,3,opt,name=to_edges,json=toEdges,proto3" json:"to_edges,omitempty"`
	// contains filtered or unexported fields
}

NodeDetailFilter is used to fetch node details

func (*NodeDetailFilter) Descriptor deprecated 

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

Deprecated: Use NodeDetailFilter.ProtoReflect.Descriptor instead.

func (*NodeDetailFilter) GetFromEdges added in v0.0.9 

func (x *NodeDetailFilter) GetFromEdges() *Filter

func (*NodeDetailFilter) GetPath 

func (x *NodeDetailFilter) GetPath() *Path

func (*NodeDetailFilter) GetToEdges added in v0.0.9 

func (x *NodeDetailFilter) GetToEdges() *Filter

func (*NodeDetailFilter) ProtoMessage 

func (*NodeDetailFilter) ProtoMessage()

func (*NodeDetailFilter) ProtoReflect added in v0.0.15 

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

func (*NodeDetailFilter) Reset 

func (x *NodeDetailFilter) Reset()

func (*NodeDetailFilter) String 

func (x *NodeDetailFilter) String() string

func (*NodeDetailFilter) Validate 

func (this *NodeDetailFilter) Validate() error

type NodeDetails 

type NodeDetails struct {
	NodeDetails []*NodeDetail `protobuf:"bytes,1,rep,name=node_details,json=nodeDetails,proto3" json:"node_details,omitempty"`
	// contains filtered or unexported fields
}

NodeDetails is an array of NodeDetail

func (*NodeDetails) Descriptor deprecated 

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

Deprecated: Use NodeDetails.ProtoReflect.Descriptor instead.

func (*NodeDetails) GetNodeDetails 

func (x *NodeDetails) GetNodeDetails() []*NodeDetail

func (*NodeDetails) ProtoMessage 

func (*NodeDetails) ProtoMessage()

func (*NodeDetails) ProtoReflect added in v0.0.15 

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

func (*NodeDetails) Reset 

func (x *NodeDetails) Reset()

func (*NodeDetails) String 

func (x *NodeDetails) String() string

func (*NodeDetails) Validate 

func (this *NodeDetails) Validate() error

type Nodes 

type Nodes struct {

	// nodes is an array of nodes
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

Nodes is an array of nodes

func (*Nodes) AsMap added in v0.0.11 

func (e *Nodes) AsMap() map[string]interface{}

func (*Nodes) Descriptor deprecated 

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

Deprecated: Use Nodes.ProtoReflect.Descriptor instead.

func (*Nodes) GetNodes 

func (x *Nodes) GetNodes() []*Node

func (*Nodes) ProtoMessage 

func (*Nodes) ProtoMessage()

func (*Nodes) ProtoReflect added in v0.0.15 

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

func (*Nodes) Reset 

func (x *Nodes) Reset()

func (*Nodes) Sort 

func (n *Nodes) Sort()

func (*Nodes) String 

func (x *Nodes) String() string

func (*Nodes) Validate 

func (this *Nodes) Validate() error

type OutboundMessage 

type OutboundMessage struct {

	// channel is the target channel to send the message to
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// data is the data to send with the message
	Data *_struct.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

OutboundMessage is a message to be published to a pubsub channel

func (*OutboundMessage) AsMap added in v0.0.11 

func (o *OutboundMessage) AsMap() map[string]interface{}

func (*OutboundMessage) Descriptor deprecated 

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

Deprecated: Use OutboundMessage.ProtoReflect.Descriptor instead.

func (*OutboundMessage) GetChannel 

func (x *OutboundMessage) GetChannel() string

func (*OutboundMessage) GetData 

func (x *OutboundMessage) GetData() *_struct.Struct

func (*OutboundMessage) ProtoMessage 

func (*OutboundMessage) ProtoMessage()

func (*OutboundMessage) ProtoReflect added in v0.0.15 

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

func (*OutboundMessage) Reset 

func (x *OutboundMessage) Reset()

func (*OutboundMessage) String 

func (x *OutboundMessage) String() string

func (*OutboundMessage) Validate 

func (this *OutboundMessage) Validate() error

type Patch 

type Patch struct {

	// path is the path to the target node/edge to patch
	Path *Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// attributes are k/v pairs used to overwrite k/v pairs on a node/edge
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Patch patches the attributes of a Node or Edge

func (*Patch) AsMap added in v0.0.9 

func (p *Patch) AsMap() map[string]interface{}

func (*Patch) Descriptor deprecated 

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

Deprecated: Use Patch.ProtoReflect.Descriptor instead.

func (*Patch) GetAttributes 

func (x *Patch) GetAttributes() *_struct.Struct

func (*Patch) GetPath 

func (x *Patch) GetPath() *Path

func (*Patch) ProtoMessage 

func (*Patch) ProtoMessage()

func (*Patch) ProtoReflect added in v0.0.15 

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

func (*Patch) Reset 

func (x *Patch) Reset()

func (*Patch) String 

func (x *Patch) String() string

func (*Patch) Validate 

func (this *Patch) Validate() error

type PatchFilter added in v0.0.9 

type PatchFilter struct {

	// filter is used to filter nodes/edges to patch
	Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// attributes are k/v pairs used to overwrite k/v pairs on all nodes/edges that pass the filter
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

PatchFilter is used to patch nodes/edges

func (*PatchFilter) AsMap added in v0.0.9 

func (n *PatchFilter) AsMap() map[string]interface{}

func (*PatchFilter) Descriptor deprecated added in v0.0.9 

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

Deprecated: Use PatchFilter.ProtoReflect.Descriptor instead.

func (*PatchFilter) GetAttributes added in v0.0.15 

func (x *PatchFilter) GetAttributes() *_struct.Struct

func (*PatchFilter) GetFilter added in v0.0.9 

func (x *PatchFilter) GetFilter() *Filter

func (*PatchFilter) ProtoMessage added in v0.0.9 

func (*PatchFilter) ProtoMessage()

func (*PatchFilter) ProtoReflect added in v0.0.15 

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

func (*PatchFilter) Reset added in v0.0.9 

func (x *PatchFilter) Reset()

func (*PatchFilter) String added in v0.0.9 

func (x *PatchFilter) String() string

func (*PatchFilter) Validate added in v0.0.9 

func (this *PatchFilter) Validate() error

type Path 

type Path struct {

	// gtype is the type of the node/edge ex: pet
	Gtype string `protobuf:"bytes,1,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// gid is the unique id of the node/edge within the context of it's type
	Gid string `protobuf:"bytes,2,opt,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

Path describes a node/edge type & id

func (*Path) AsMap added in v0.0.2 

func (m *Path) AsMap() map[string]interface{}

func (*Path) Descriptor deprecated 

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

Deprecated: Use Path.ProtoReflect.Descriptor instead.

func (*Path) FromMap added in v0.0.3 

func (m *Path) FromMap(data map[string]interface{})

func (*Path) GetGid 

func (x *Path) GetGid() string

func (*Path) GetGtype 

func (x *Path) GetGtype() string

func (*Path) ProtoMessage 

func (*Path) ProtoMessage()

func (*Path) ProtoReflect added in v0.0.15 

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

func (*Path) Reset 

func (x *Path) Reset()

func (*Path) String 

func (x *Path) String() string

func (*Path) Validate 

func (this *Path) Validate() error

type Paths 

type Paths struct {
	Paths []*Path `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

Paths is an array of paths

func (*Paths) Descriptor deprecated 

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

Deprecated: Use Paths.ProtoReflect.Descriptor instead.

func (*Paths) GetPaths 

func (x *Paths) GetPaths() []*Path

func (*Paths) ProtoMessage 

func (*Paths) ProtoMessage()

func (*Paths) ProtoReflect added in v0.0.15 

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

func (*Paths) Reset 

func (x *Paths) Reset()

func (*Paths) Sort added in v0.0.3 

func (p *Paths) Sort()

func (*Paths) String 

func (x *Paths) String() string

func (*Paths) Validate 

func (this *Paths) Validate() error

type Pong 

type Pong struct {

	// message returns PONG if healthy
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Pong returns PONG if the server is healthy

func (*Pong) Descriptor deprecated 

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

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetMessage 

func (x *Pong) GetMessage() string

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect added in v0.0.15 

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

func (*Pong) Reset 

func (x *Pong) Reset()

func (*Pong) String 

func (x *Pong) String() string

func (*Pong) Validate 

func (this *Pong) Validate() error

type Request added in v0.0.16 

type Request struct {

	// method is the rpc method
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// identity is the identity making the request
	Identity *Node `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	// timestamp is when the intercept was received
	Timestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// request is the intercepted request
	Request *_struct.Struct `protobuf:"bytes,4,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated added in v0.0.16 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetIdentity added in v0.0.16 

func (x *Request) GetIdentity() *Node

func (*Request) GetMethod added in v0.0.16 

func (x *Request) GetMethod() string

func (*Request) GetRequest added in v0.0.16 

func (x *Request) GetRequest() *_struct.Struct

func (*Request) GetTimestamp added in v0.0.16 

func (x *Request) GetTimestamp() *timestamp.Timestamp

func (*Request) ProtoMessage added in v0.0.16 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect added in v0.0.16 

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

func (*Request) Reset added in v0.0.16 

func (x *Request) Reset()

func (*Request) String added in v0.0.16 

func (x *Request) String() string

func (*Request) Validate added in v0.0.16 

func (this *Request) Validate() error

type Schema 

type Schema struct {

	// edge_types are the types of edges in the graph
	EdgeTypes []string `protobuf:"bytes,1,rep,name=edge_types,json=edgeTypes,proto3" json:"edge_types,omitempty"`
	// node_types are the types of nodes in the graph
	NodeTypes []string `protobuf:"bytes,2,rep,name=node_types,json=nodeTypes,proto3" json:"node_types,omitempty"`
	// contains filtered or unexported fields
}

Schema returns registered edge & node types

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetEdgeTypes 

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

func (*Schema) GetNodeTypes 

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

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect added in v0.0.15 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

func (*Schema) Validate 

func (this *Schema) Validate() error

type SubGraphFilter 

type SubGraphFilter struct {

	// node_filter is a filter used to filter nodes in the graph
	NodeFilter *Filter `protobuf:"bytes,1,opt,name=node_filter,json=nodeFilter,proto3" json:"node_filter,omitempty"`
	// edge_filter is a filter used to filter the edges of each node returned by the node_filter
	EdgeFilter *Filter `protobuf:"bytes,2,opt,name=edge_filter,json=edgeFilter,proto3" json:"edge_filter,omitempty"`
	// contains filtered or unexported fields
}

SubGraphFilter is used to filter nodes/edges in the graph

func (*SubGraphFilter) AsMap added in v0.0.11 

func (n *SubGraphFilter) AsMap() map[string]interface{}

func (*SubGraphFilter) Descriptor deprecated 

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

Deprecated: Use SubGraphFilter.ProtoReflect.Descriptor instead.

func (*SubGraphFilter) GetEdgeFilter added in v0.0.11 

func (x *SubGraphFilter) GetEdgeFilter() *Filter

func (*SubGraphFilter) GetNodeFilter added in v0.0.11 

func (x *SubGraphFilter) GetNodeFilter() *Filter

func (*SubGraphFilter) ProtoMessage 

func (*SubGraphFilter) ProtoMessage()

func (*SubGraphFilter) ProtoReflect added in v0.0.15 

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

func (*SubGraphFilter) Reset 

func (x *SubGraphFilter) Reset()

func (*SubGraphFilter) String 

func (x *SubGraphFilter) String() string

func (*SubGraphFilter) Validate 

func (this *SubGraphFilter) Validate() error

type TriggerServiceClient 

type TriggerServiceClient interface {
	// Ping returns PONG if the server is health
	Ping(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Pong, error)
	// Mutate mutates state changes before they are commited
	Mutate(ctx context.Context, in *Change, opts ...grpc.CallOption) (*Change, error)
	// Filter returns a set of expressions used to determine whether the request/response will be sent to the Mutation function.
	// These expressions are cached by the Graphik server
	Filter(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ExpressionFilter, error)
}

TriggerServiceClient is the client API for TriggerService service.

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

func NewTriggerServiceClient 

func NewTriggerServiceClient(cc grpc.ClientConnInterface) TriggerServiceClient

type TriggerServiceServer 

type TriggerServiceServer interface {
	// Ping returns PONG if the server is health
	Ping(context.Context, *empty.Empty) (*Pong, error)
	// Mutate mutates state changes before they are commited
	Mutate(context.Context, *Change) (*Change, error)
	// Filter returns a set of expressions used to determine whether the request/response will be sent to the Mutation function.
	// These expressions are cached by the Graphik server
	Filter(context.Context, *empty.Empty) (*ExpressionFilter, error)
}

TriggerServiceServer is the server API for TriggerService service.

type UnimplementedGraphServiceServer added in v0.0.15 

type UnimplementedGraphServiceServer struct {
}

UnimplementedGraphServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGraphServiceServer) CreateEdge added in v0.0.15 

func (*UnimplementedGraphServiceServer) CreateEdge(context.Context, *EdgeConstructor) (*Edge, error)

func (*UnimplementedGraphServiceServer) CreateEdges added in v0.0.15 

func (*UnimplementedGraphServiceServer) CreateEdges(context.Context, *EdgeConstructors) (*Edges, error)

func (*UnimplementedGraphServiceServer) CreateNode added in v0.0.15 

func (*UnimplementedGraphServiceServer) CreateNode(context.Context, *NodeConstructor) (*Node, error)

func (*UnimplementedGraphServiceServer) CreateNodes added in v0.0.15 

func (*UnimplementedGraphServiceServer) CreateNodes(context.Context, *NodeConstructors) (*Nodes, error)

func (*UnimplementedGraphServiceServer) EdgesFrom added in v0.0.15 

func (*UnimplementedGraphServiceServer) EdgesFrom(context.Context, *EdgeFilter) (*Edges, error)

func (*UnimplementedGraphServiceServer) EdgesTo added in v0.0.15 

func (*UnimplementedGraphServiceServer) EdgesTo(context.Context, *EdgeFilter) (*Edges, error)

func (*UnimplementedGraphServiceServer) Export added in v0.0.15 

func (*UnimplementedGraphServiceServer) Export(context.Context, *empty.Empty) (*Graph, error)

func (*UnimplementedGraphServiceServer) GetEdge added in v0.0.15 

func (*UnimplementedGraphServiceServer) GetEdge(context.Context, *Path) (*Edge, error)

func (*UnimplementedGraphServiceServer) GetNode added in v0.0.15 

func (*UnimplementedGraphServiceServer) GetNode(context.Context, *Path) (*Node, error)

func (*UnimplementedGraphServiceServer) GetSchema added in v0.0.15 

func (*UnimplementedGraphServiceServer) GetSchema(context.Context, *empty.Empty) (*Schema, error)

func (*UnimplementedGraphServiceServer) Import added in v0.0.15 

func (*UnimplementedGraphServiceServer) Import(context.Context, *Graph) (*Graph, error)

func (*UnimplementedGraphServiceServer) Me added in v0.0.15 

func (*UnimplementedGraphServiceServer) Me(context.Context, *MeFilter) (*NodeDetail, error)

func (*UnimplementedGraphServiceServer) PatchEdge added in v0.0.15 

func (*UnimplementedGraphServiceServer) PatchEdge(context.Context, *Patch) (*Edge, error)

func (*UnimplementedGraphServiceServer) PatchEdges added in v0.0.15 

func (*UnimplementedGraphServiceServer) PatchEdges(context.Context, *PatchFilter) (*Edges, error)

func (*UnimplementedGraphServiceServer) PatchNode added in v0.0.15 

func (*UnimplementedGraphServiceServer) PatchNode(context.Context, *Patch) (*Node, error)

func (*UnimplementedGraphServiceServer) PatchNodes added in v0.0.15 

func (*UnimplementedGraphServiceServer) PatchNodes(context.Context, *PatchFilter) (*Nodes, error)

func (*UnimplementedGraphServiceServer) Ping added in v0.0.15 

func (*UnimplementedGraphServiceServer) Ping(context.Context, *empty.Empty) (*Pong, error)

func (*UnimplementedGraphServiceServer) Publish added in v0.0.15 

func (*UnimplementedGraphServiceServer) Publish(context.Context, *OutboundMessage) (*empty.Empty, error)

func (*UnimplementedGraphServiceServer) SearchEdges added in v0.0.15 

func (*UnimplementedGraphServiceServer) SearchEdges(context.Context, *Filter) (*Edges, error)

func (*UnimplementedGraphServiceServer) SearchNodes added in v0.0.15 

func (*UnimplementedGraphServiceServer) SearchNodes(context.Context, *Filter) (*Nodes, error)

func (*UnimplementedGraphServiceServer) Shutdown added in v0.0.15 

func (*UnimplementedGraphServiceServer) Shutdown(context.Context, *empty.Empty) (*empty.Empty, error)

func (*UnimplementedGraphServiceServer) SubGraph added in v0.0.15 

func (*UnimplementedGraphServiceServer) SubGraph(context.Context, *SubGraphFilter) (*Graph, error)

func (*UnimplementedGraphServiceServer) Subscribe added in v0.0.15 

func (*UnimplementedGraphServiceServer) Subscribe(*ChannelFilter, GraphService_SubscribeServer) error

func (*UnimplementedGraphServiceServer) SubscribeChanges added in v0.0.15 

func (*UnimplementedGraphServiceServer) SubscribeChanges(*ExpressionFilter, GraphService_SubscribeChangesServer) error

type UnimplementedTriggerServiceServer added in v0.0.15 

type UnimplementedTriggerServiceServer struct {
}

UnimplementedTriggerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTriggerServiceServer) Filter added in v0.0.15 

func (*UnimplementedTriggerServiceServer) Filter(context.Context, *empty.Empty) (*ExpressionFilter, error)

func (*UnimplementedTriggerServiceServer) Mutate added in v0.0.15 

func (*UnimplementedTriggerServiceServer) Mutate(context.Context, *Change) (*Change, error)

func (*UnimplementedTriggerServiceServer) Ping added in v0.0.15 

func (*UnimplementedTriggerServiceServer) Ping(context.Context, *empty.Empty) (*Pong, 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.