Versions in this module Expand all Collapse all v0 v0.0.1 Nov 26, 2020 v0.0.0 Nov 23, 2020 Changes in this version + type Client struct + func NewClient(ctx context.Context, target string, opts ...Opt) (*Client, error) + func (c *Client) CreateEdge(ctx context.Context, in *apipb.EdgeConstructor, opts ...grpc.CallOption) (*apipb.Edge, error) + func (c *Client) CreateEdges(ctx context.Context, in *apipb.EdgeConstructors, opts ...grpc.CallOption) (*apipb.Edges, error) + func (c *Client) CreateNode(ctx context.Context, in *apipb.NodeConstructor, opts ...grpc.CallOption) (*apipb.Node, error) + func (c *Client) CreateNodes(ctx context.Context, in *apipb.NodeConstructors, opts ...grpc.CallOption) (*apipb.Nodes, error) + func (c *Client) DelEdge(ctx context.Context, in *apipb.Path, opts ...grpc.CallOption) (*empty.Empty, error) + func (c *Client) DelEdges(ctx context.Context, in *apipb.Paths, opts ...grpc.CallOption) (*empty.Empty, error) + func (c *Client) DelNode(ctx context.Context, in *apipb.Path, opts ...grpc.CallOption) (*empty.Empty, error) + func (c *Client) DelNodes(ctx context.Context, in *apipb.Paths, opts ...grpc.CallOption) (*empty.Empty, error) + func (c *Client) EdgesFrom(ctx context.Context, in *apipb.EdgeFilter, opts ...grpc.CallOption) (*apipb.Edges, error) + func (c *Client) EdgesTo(ctx context.Context, in *apipb.EdgeFilter, opts ...grpc.CallOption) (*apipb.Edges, error) + func (c *Client) GetEdge(ctx context.Context, in *apipb.Path, opts ...grpc.CallOption) (*apipb.Edge, error) + func (c *Client) GetNode(ctx context.Context, in *apipb.Path, opts ...grpc.CallOption) (*apipb.Node, error) + func (c *Client) GetSchema(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*apipb.Schema, error) + func (c *Client) Me(ctx context.Context, in *apipb.MeFilter, opts ...grpc.CallOption) (*apipb.NodeDetail, error) + func (c *Client) PatchEdge(ctx context.Context, in *apipb.Patch, opts ...grpc.CallOption) (*apipb.Edge, error) + func (c *Client) PatchEdges(ctx context.Context, in *apipb.Patches, opts ...grpc.CallOption) (*apipb.Edges, error) + func (c *Client) PatchNode(ctx context.Context, in *apipb.Patch, opts ...grpc.CallOption) (*apipb.Node, error) + func (c *Client) PatchNodes(ctx context.Context, in *apipb.Patches, opts ...grpc.CallOption) (*apipb.Nodes, error) + func (c *Client) Ping(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*apipb.Pong, error) + func (c *Client) Publish(ctx context.Context, in *apipb.OutboundMessage, opts ...grpc.CallOption) (*empty.Empty, error) + func (c *Client) SearchEdges(ctx context.Context, in *apipb.Filter, opts ...grpc.CallOption) (*apipb.Edges, error) + func (c *Client) SearchNodes(ctx context.Context, in *apipb.Filter, opts ...grpc.CallOption) (*apipb.Nodes, error) + func (c *Client) Shutdown(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error) + func (c *Client) SubGraph(ctx context.Context, in *apipb.SubGraphFilter) (*apipb.Graph, error) + func (c *Client) Subscribe(ctx context.Context, in *apipb.ChannelFilter, opts ...grpc.CallOption) (apipb.GraphService_SubscribeClient, error) + type Opt func(o *Options) + func WithRetry(retry uint) Opt + func WithTokenSource(tokenSource oauth2.TokenSource) Opt + type Options struct + type Trigger struct + func NewTrigger(fn TriggerFunc, expressions []string) *Trigger + func (t Trigger) Filter(ctx context.Context, _ *empty.Empty) (*apipb.TriggerFilter, error) + func (t Trigger) Mutate(ctx context.Context, interception *apipb.Interception) (*apipb.Interception, error) + func (t Trigger) Ping(ctx context.Context, _ *empty.Empty) (*apipb.Pong, error) + func (t Trigger) Serve(ctx context.Context, cfg *flags.PluginFlags) + type TriggerFunc func(ctx context.Context, trigger *apipb.Interception) (*apipb.Interception, error)