gripql

package
v0.0.0-...-fa720cf Latest Latest
Warning

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

Go to latest
Published: Nov 2, 2023 License: MIT Imports: 30 Imported by: 8

Documentation

Overview

Code generated by protoc-gen-grpc-rest-direct. DO NOT EDIT.

Package gripql is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	Condition_name = map[int32]string{
		0:  "UNKNOWN_CONDITION",
		1:  "EQ",
		2:  "NEQ",
		3:  "GT",
		4:  "GTE",
		5:  "LT",
		6:  "LTE",
		7:  "INSIDE",
		8:  "OUTSIDE",
		9:  "BETWEEN",
		10: "WITHIN",
		11: "WITHOUT",
		12: "CONTAINS",
	}
	Condition_value = map[string]int32{
		"UNKNOWN_CONDITION": 0,
		"EQ":                1,
		"NEQ":               2,
		"GT":                3,
		"GTE":               4,
		"LT":                5,
		"LTE":               6,
		"INSIDE":            7,
		"OUTSIDE":           8,
		"BETWEEN":           9,
		"WITHIN":            10,
		"WITHOUT":           11,
		"CONTAINS":          12,
	}
)

Enum value maps for Condition.

View Source
var (
	JobState_name = map[int32]string{
		0: "QUEUED",
		1: "RUNNING",
		2: "COMPLETE",
		3: "ERROR",
		4: "DELETED",
	}
	JobState_value = map[string]int32{
		"QUEUED":   0,
		"RUNNING":  1,
		"COMPLETE": 2,
		"ERROR":    3,
		"DELETED":  4,
	}
)

Enum value maps for JobState.

View Source
var (
	FieldType_name = map[int32]string{
		0: "UNKNOWN",
		1: "STRING",
		2: "NUMERIC",
		3: "BOOL",
		4: "MAP",
		5: "ARRAY",
	}
	FieldType_value = map[string]int32{
		"UNKNOWN": 0,
		"STRING":  1,
		"NUMERIC": 2,
		"BOOL":    3,
		"MAP":     4,
		"ARRAY":   5,
	}
)

Enum value maps for FieldType.

View Source
var Configure_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gripql.Configure",
	HandlerType: (*ConfigureServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartPlugin",
			Handler:    _Configure_StartPlugin_Handler,
		},
		{
			MethodName: "ListPlugins",
			Handler:    _Configure_ListPlugins_Handler,
		},
		{
			MethodName: "ListDrivers",
			Handler:    _Configure_ListDrivers_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gripql.proto",
}

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

View Source
var Edit_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gripql.Edit",
	HandlerType: (*EditServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddVertex",
			Handler:    _Edit_AddVertex_Handler,
		},
		{
			MethodName: "AddEdge",
			Handler:    _Edit_AddEdge_Handler,
		},
		{
			MethodName: "AddGraph",
			Handler:    _Edit_AddGraph_Handler,
		},
		{
			MethodName: "DeleteGraph",
			Handler:    _Edit_DeleteGraph_Handler,
		},
		{
			MethodName: "DeleteVertex",
			Handler:    _Edit_DeleteVertex_Handler,
		},
		{
			MethodName: "DeleteEdge",
			Handler:    _Edit_DeleteEdge_Handler,
		},
		{
			MethodName: "AddIndex",
			Handler:    _Edit_AddIndex_Handler,
		},
		{
			MethodName: "DeleteIndex",
			Handler:    _Edit_DeleteIndex_Handler,
		},
		{
			MethodName: "AddSchema",
			Handler:    _Edit_AddSchema_Handler,
		},
		{
			MethodName: "SampleSchema",
			Handler:    _Edit_SampleSchema_Handler,
		},
		{
			MethodName: "AddMapping",
			Handler:    _Edit_AddMapping_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "BulkAdd",
			Handler:       _Edit_BulkAdd_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "gripql.proto",
}

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

View Source
var File_gripql_proto protoreflect.FileDescriptor
View Source
var Job_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gripql.Job",
	HandlerType: (*JobServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Submit",
			Handler:    _Job_Submit_Handler,
		},
		{
			MethodName: "DeleteJob",
			Handler:    _Job_DeleteJob_Handler,
		},
		{
			MethodName: "GetJob",
			Handler:    _Job_GetJob_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListJobs",
			Handler:       _Job_ListJobs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SearchJobs",
			Handler:       _Job_SearchJobs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ViewJob",
			Handler:       _Job_ViewJob_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ResumeJob",
			Handler:       _Job_ResumeJob_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "gripql.proto",
}

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

View Source
var Query_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gripql.Query",
	HandlerType: (*QueryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetVertex",
			Handler:    _Query_GetVertex_Handler,
		},
		{
			MethodName: "GetEdge",
			Handler:    _Query_GetEdge_Handler,
		},
		{
			MethodName: "GetTimestamp",
			Handler:    _Query_GetTimestamp_Handler,
		},
		{
			MethodName: "GetSchema",
			Handler:    _Query_GetSchema_Handler,
		},
		{
			MethodName: "GetMapping",
			Handler:    _Query_GetMapping_Handler,
		},
		{
			MethodName: "ListGraphs",
			Handler:    _Query_ListGraphs_Handler,
		},
		{
			MethodName: "ListIndices",
			Handler:    _Query_ListIndices_Handler,
		},
		{
			MethodName: "ListLabels",
			Handler:    _Query_ListLabels_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Traversal",
			Handler:       _Query_Traversal_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListTables",
			Handler:       _Query_ListTables_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "gripql.proto",
}

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

View Source
var ReservedFields = []string{"_gid", "_label", "_to", "_from", "_data"}

ReservedFields are the fields that cannot be used as keys within the data of a vertex or edge

Functions

func DirectStreamInterceptor

func DirectStreamInterceptor(g grpc.StreamServerInterceptor) func(directClientBase)

func DirectUnaryInterceptor

func DirectUnaryInterceptor(g grpc.UnaryServerInterceptor) func(directClientBase)

func GetDataFieldTypes

func GetDataFieldTypes(data map[string]interface{}) map[string]interface{}

GetDataFieldTypes iterates over the data map and determines the type of each field

func GetFieldType

func GetFieldType(field interface{}) string

GetFieldType returns the FieldType for a value

func GraphToJSONString

func GraphToJSONString(graph *Graph) (string, error)

GraphToJSONString returns a graph formatted as a JSON string

func GraphToYAMLString

func GraphToYAMLString(graph *Graph) (string, error)

GraphToYAMLString returns a graph formatted as a YAML string

func HasExpressionString

func HasExpressionString(stmt *HasExpression) string

func RegisterConfigureHandler

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

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

func RegisterConfigureHandlerClient

func RegisterConfigureHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ConfigureClient) error

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

func RegisterConfigureHandlerFromEndpoint

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

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

func RegisterConfigureHandlerServer

func RegisterConfigureHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ConfigureServer) error

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

func RegisterConfigureServer

func RegisterConfigureServer(s grpc.ServiceRegistrar, srv ConfigureServer)

func RegisterEditHandler

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

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

func RegisterEditHandlerClient

func RegisterEditHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EditClient) error

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

func RegisterEditHandlerFromEndpoint

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

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

func RegisterEditHandlerServer

func RegisterEditHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EditServer) error

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

func RegisterEditServer

func RegisterEditServer(s grpc.ServiceRegistrar, srv EditServer)

func RegisterJobHandler

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

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

func RegisterJobHandlerClient

func RegisterJobHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobClient) error

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

func RegisterJobHandlerFromEndpoint

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

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

func RegisterJobHandlerServer

func RegisterJobHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobServer) error

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

func RegisterJobServer

func RegisterJobServer(s grpc.ServiceRegistrar, srv JobServer)

func RegisterQueryHandler

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

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

func RegisterQueryHandlerClient

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

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

func RegisterQueryHandlerFromEndpoint

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

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

func RegisterQueryHandlerServer

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

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

func RegisterQueryServer

func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)

func ValidateFieldName

func ValidateFieldName(k string) error

ValidateFieldName returns an error if the data field name is invalid

func ValidateGraphName

func ValidateGraphName(graph string) error

ValidateGraphName returns an error if the graph name is invalid

Types

type Aggregate

type Aggregate struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Aggregation:
	//
	//	*Aggregate_Term
	//	*Aggregate_Percentile
	//	*Aggregate_Histogram
	//	*Aggregate_Field
	//	*Aggregate_Type
	//	*Aggregate_Count
	Aggregation isAggregate_Aggregation `protobuf_oneof:"aggregation"`
	// contains filtered or unexported fields
}

func (*Aggregate) Descriptor deprecated

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

Deprecated: Use Aggregate.ProtoReflect.Descriptor instead.

func (*Aggregate) GetAggregation

func (m *Aggregate) GetAggregation() isAggregate_Aggregation

func (*Aggregate) GetCount

func (x *Aggregate) GetCount() *CountAggregation

func (*Aggregate) GetField

func (x *Aggregate) GetField() *FieldAggregation

func (*Aggregate) GetHistogram

func (x *Aggregate) GetHistogram() *HistogramAggregation

func (*Aggregate) GetName

func (x *Aggregate) GetName() string

func (*Aggregate) GetPercentile

func (x *Aggregate) GetPercentile() *PercentileAggregation

func (*Aggregate) GetTerm

func (x *Aggregate) GetTerm() *TermAggregation

func (*Aggregate) GetType

func (x *Aggregate) GetType() *TypeAggregation

func (*Aggregate) ProtoMessage

func (*Aggregate) ProtoMessage()

func (*Aggregate) ProtoReflect

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

func (*Aggregate) Reset

func (x *Aggregate) Reset()

func (*Aggregate) String

func (x *Aggregate) String() string

type Aggregate_Count

type Aggregate_Count struct {
	Count *CountAggregation `protobuf:"bytes,7,opt,name=count,proto3,oneof"`
}

type Aggregate_Field

type Aggregate_Field struct {
	Field *FieldAggregation `protobuf:"bytes,5,opt,name=field,proto3,oneof"`
}

type Aggregate_Histogram

type Aggregate_Histogram struct {
	Histogram *HistogramAggregation `protobuf:"bytes,4,opt,name=histogram,proto3,oneof"`
}

type Aggregate_Percentile

type Aggregate_Percentile struct {
	Percentile *PercentileAggregation `protobuf:"bytes,3,opt,name=percentile,proto3,oneof"`
}

type Aggregate_Term

type Aggregate_Term struct {
	Term *TermAggregation `protobuf:"bytes,2,opt,name=term,proto3,oneof"`
}

type Aggregate_Type

type Aggregate_Type struct {
	Type *TypeAggregation `protobuf:"bytes,6,opt,name=type,proto3,oneof"`
}

type Aggregations

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

func (*Aggregations) Descriptor deprecated

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

Deprecated: Use Aggregations.ProtoReflect.Descriptor instead.

func (*Aggregations) GetAggregations

func (x *Aggregations) GetAggregations() []*Aggregate

func (*Aggregations) ProtoMessage

func (*Aggregations) ProtoMessage()

func (*Aggregations) ProtoReflect

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

func (*Aggregations) Reset

func (x *Aggregations) Reset()

func (*Aggregations) String

func (x *Aggregations) String() string

type AggregationsRequest

type AggregationsRequest struct {
	Graph        string       `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"`
	Aggregations []*Aggregate `protobuf:"bytes,2,rep,name=aggregations,proto3" json:"aggregations,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregationsRequest) Descriptor deprecated

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

Deprecated: Use AggregationsRequest.ProtoReflect.Descriptor instead.

func (*AggregationsRequest) GetAggregations

func (x *AggregationsRequest) GetAggregations() []*Aggregate

func (*AggregationsRequest) GetGraph

func (x *AggregationsRequest) GetGraph() string

func (*AggregationsRequest) ProtoMessage

func (*AggregationsRequest) ProtoMessage()

func (*AggregationsRequest) ProtoReflect

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

func (*AggregationsRequest) Reset

func (x *AggregationsRequest) Reset()

func (*AggregationsRequest) String

func (x *AggregationsRequest) String() string

type BulkEditResult

type BulkEditResult struct {
	InsertCount int32 `protobuf:"varint,1,opt,name=insert_count,json=insertCount,proto3" json:"insert_count,omitempty"`
	ErrorCount  int32 `protobuf:"varint,2,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkEditResult) Descriptor deprecated

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

Deprecated: Use BulkEditResult.ProtoReflect.Descriptor instead.

func (*BulkEditResult) GetErrorCount

func (x *BulkEditResult) GetErrorCount() int32

func (*BulkEditResult) GetInsertCount

func (x *BulkEditResult) GetInsertCount() int32

func (*BulkEditResult) ProtoMessage

func (*BulkEditResult) ProtoMessage()

func (*BulkEditResult) ProtoReflect

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

func (*BulkEditResult) Reset

func (x *BulkEditResult) Reset()

func (*BulkEditResult) String

func (x *BulkEditResult) String() string

type Client

type Client struct {
	QueryC     QueryClient
	EditC      EditClient
	JobC       JobClient
	ConfigureC ConfigureClient
	// contains filtered or unexported fields
}

Client is a GRPC grip client with some helper functions

func Connect

func Connect(conf rpc.Config, write bool) (Client, error)

Connect opens a GRPC connection to an Grip server

func WrapClient

func WrapClient(QueryC QueryClient, EditC EditClient, JobC JobClient, ConfigureC ConfigureClient) Client

WrapClient takes previously initialized GRPC clients and uses them for the client wrapper

func (Client) AddEdge

func (client Client) AddEdge(graph string, e *Edge) error

AddEdge adds a single edge to the graph

func (Client) AddGraph

func (client Client) AddGraph(graph string) error

AddGraph creates a new graph

func (Client) AddMapping

func (client Client) AddMapping(graph *Graph) error

AddMapping adds a mapping for a graph.

func (Client) AddSchema

func (client Client) AddSchema(graph *Graph) error

AddSchema adds a schema for a graph.

func (Client) AddVertex

func (client Client) AddVertex(graph string, v *Vertex) error

AddVertex adds a single vertex to the graph

func (Client) BulkAdd

func (client Client) BulkAdd(elemChan chan *GraphElement) error

BulkAdd allows for bulk continuous loading of graph elements into the datastore

func (Client) Close

func (client Client) Close()

Close the connection

func (Client) DeleteEdge

func (client Client) DeleteEdge(graph string, id string) error

func (Client) DeleteGraph

func (client Client) DeleteGraph(graph string) error

DeleteGraph deletes a graph and all of its contents

func (Client) DeleteJob

func (client Client) DeleteJob(graph string, jobID string) (*JobStatus, error)

func (Client) DeleteVertex

func (client Client) DeleteVertex(graph string, id string) error

func (Client) GetEdge

func (client Client) GetEdge(graph string, id string) (*Edge, error)

func (Client) GetJob

func (client Client) GetJob(graph string, jobID string) (*JobStatus, error)

func (Client) GetMapping

func (client Client) GetMapping(graph string) (*Graph, error)

GetMaping returns the mapping for the given graph.

func (Client) GetSchema

func (client Client) GetSchema(graph string) (*Graph, error)

GetSchema returns the schema for the given graph.

func (Client) GetTimestamp

func (client Client) GetTimestamp(graph string) (*Timestamp, error)

GetTimestamp get update timestamp for graph

func (Client) GetVertex

func (client Client) GetVertex(graph string, id string) (*Vertex, error)

GetVertex obtains a vertex from a graph by `id`

func (Client) ListDrivers

func (client Client) ListDrivers() (*ListDriversResponse, error)

ListDrivers lists avalible drivers

func (Client) ListGraphs

func (client Client) ListGraphs() (*ListGraphsResponse, error)

ListGraphs lists the graphs in the database

func (Client) ListIndices

func (client Client) ListIndices(graph string) (*ListIndicesResponse, error)

ListIndices lists the indices on a graph in the database

func (Client) ListJobs

func (client Client) ListJobs(graph string) ([]*QueryJob, error)

func (Client) ListLabels

func (client Client) ListLabels(graph string) (*ListLabelsResponse, error)

ListLabels lists the vertex and edge labels for a graph in the database

func (Client) ListPlugins

func (client Client) ListPlugins() (*ListPluginsResponse, error)

ListPlugins

func (Client) ListTables

func (client Client) ListTables() (chan *TableInfo, error)

ListTables lists the tables in the database

func (Client) SampleSchema

func (client Client) SampleSchema(graph string) (*Graph, error)

SampleSchema asks server to scan data to determine possible schema

func (Client) StartPlugin

func (client Client) StartPlugin(conf *PluginConfig) (*PluginStatus, error)

ListPlugins

func (Client) Submit

func (client Client) Submit(query *GraphQuery) (*QueryJob, error)

func (Client) Traversal

func (client Client) Traversal(query *GraphQuery) (chan *QueryResult, error)

Traversal runs a graph traversal query

func (Client) WithConfigureAPI

func (client Client) WithConfigureAPI() Client

type Condition

type Condition int32
const (
	Condition_UNKNOWN_CONDITION Condition = 0
	Condition_EQ                Condition = 1
	Condition_NEQ               Condition = 2
	Condition_GT                Condition = 3
	Condition_GTE               Condition = 4
	Condition_LT                Condition = 5
	Condition_LTE               Condition = 6
	Condition_INSIDE            Condition = 7
	Condition_OUTSIDE           Condition = 8
	Condition_BETWEEN           Condition = 9
	Condition_WITHIN            Condition = 10
	Condition_WITHOUT           Condition = 11
	Condition_CONTAINS          Condition = 12
)

func (Condition) Descriptor

func (Condition) Descriptor() protoreflect.EnumDescriptor

func (Condition) Enum

func (x Condition) Enum() *Condition

func (Condition) EnumDescriptor deprecated

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

Deprecated: Use Condition.Descriptor instead.

func (Condition) Number

func (x Condition) Number() protoreflect.EnumNumber

func (Condition) String

func (x Condition) String() string

func (Condition) Type

type ConfigureClient

type ConfigureClient interface {
	StartPlugin(ctx context.Context, in *PluginConfig, opts ...grpc.CallOption) (*PluginStatus, error)
	ListPlugins(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListPluginsResponse, error)
	ListDrivers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListDriversResponse, error)
}

ConfigureClient is the client API for Configure 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 NewConfigureClient

func NewConfigureClient(cc grpc.ClientConnInterface) ConfigureClient

type ConfigureDirectClient

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

ConfigureDirectClient is a shim to connect Configure client directly server

func NewConfigureDirectClient

func NewConfigureDirectClient(server ConfigureServer, opts ...DirectOption) *ConfigureDirectClient

NewConfigureDirectClient creates new ConfigureDirectClient

func (*ConfigureDirectClient) ListDrivers

func (shim *ConfigureDirectClient) ListDrivers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListDriversResponse, error)

ListDrivers shim

func (*ConfigureDirectClient) ListPlugins

func (shim *ConfigureDirectClient) ListPlugins(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListPluginsResponse, error)

ListPlugins shim

func (*ConfigureDirectClient) StartPlugin

func (shim *ConfigureDirectClient) StartPlugin(ctx context.Context, in *PluginConfig, opts ...grpc.CallOption) (*PluginStatus, error)

StartPlugin shim

type ConfigureGatewayClient

type ConfigureGatewayClient interface {
	StartPlugin(context.Context, *PluginConfig) (*PluginStatus, error)
	ListPlugins(context.Context, *Empty) (*ListPluginsResponse, error)
	ListDrivers(context.Context, *Empty) (*ListDriversResponse, error)
}

ConfigureGatewayClient is the interface for Configure service client.

func NewConfigureGatewayClient

func NewConfigureGatewayClient(c gateway.Client) ConfigureGatewayClient

type ConfigureServer

type ConfigureServer interface {
	StartPlugin(context.Context, *PluginConfig) (*PluginStatus, error)
	ListPlugins(context.Context, *Empty) (*ListPluginsResponse, error)
	ListDrivers(context.Context, *Empty) (*ListDriversResponse, error)
	// contains filtered or unexported methods
}

ConfigureServer is the server API for Configure service. All implementations must embed UnimplementedConfigureServer for forward compatibility

type CountAggregation

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

func (*CountAggregation) Descriptor deprecated

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

Deprecated: Use CountAggregation.ProtoReflect.Descriptor instead.

func (*CountAggregation) ProtoMessage

func (*CountAggregation) ProtoMessage()

func (*CountAggregation) ProtoReflect

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

func (*CountAggregation) Reset

func (x *CountAggregation) Reset()

func (*CountAggregation) String

func (x *CountAggregation) String() string

type DirectOption

type DirectOption func(directClientBase)

type Edge

type Edge struct {
	Gid   string           `protobuf:"bytes,1,opt,name=gid,proto3" json:"gid,omitempty"`
	Label string           `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	From  string           `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	To    string           `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"`
	Data  *structpb.Struct `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Edge) Descriptor deprecated

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

Deprecated: Use Edge.ProtoReflect.Descriptor instead.

func (*Edge) GetData

func (x *Edge) GetData() *structpb.Struct

func (*Edge) GetDataMap

func (edge *Edge) GetDataMap() map[string]interface{}

GetDataMap obtains data attached to vertex in the form of a map

func (*Edge) GetFrom

func (x *Edge) GetFrom() string

func (*Edge) GetGid

func (x *Edge) GetGid() string

func (*Edge) GetLabel

func (x *Edge) GetLabel() string

func (*Edge) GetProperty

func (edge *Edge) GetProperty(key string) interface{}

GetProperty get named field from edge data

func (*Edge) GetTo

func (x *Edge) GetTo() string

func (*Edge) HasProperty

func (edge *Edge) HasProperty(key string) bool

HasProperty returns true is field is defined

func (*Edge) ProtoMessage

func (*Edge) ProtoMessage()

func (*Edge) ProtoReflect

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

func (*Edge) Reset

func (x *Edge) Reset()

func (*Edge) SetDataMap

func (edge *Edge) SetDataMap(i map[string]interface{})

SetDataMap obtains data attached to vertex in the form of a map

func (*Edge) SetProperty

func (edge *Edge) SetProperty(key string, value interface{})

SetProperty sets named field in Vertex data

func (*Edge) String

func (x *Edge) String() string

func (*Edge) Validate

func (edge *Edge) Validate() error

Validate returns an error if the edge is invalid

type EditClient

type EditClient interface {
	AddVertex(ctx context.Context, in *GraphElement, opts ...grpc.CallOption) (*EditResult, error)
	AddEdge(ctx context.Context, in *GraphElement, opts ...grpc.CallOption) (*EditResult, error)
	BulkAdd(ctx context.Context, opts ...grpc.CallOption) (Edit_BulkAddClient, error)
	AddGraph(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*EditResult, error)
	DeleteGraph(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*EditResult, error)
	DeleteVertex(ctx context.Context, in *ElementID, opts ...grpc.CallOption) (*EditResult, error)
	DeleteEdge(ctx context.Context, in *ElementID, opts ...grpc.CallOption) (*EditResult, error)
	AddIndex(ctx context.Context, in *IndexID, opts ...grpc.CallOption) (*EditResult, error)
	DeleteIndex(ctx context.Context, in *IndexID, opts ...grpc.CallOption) (*EditResult, error)
	AddSchema(ctx context.Context, in *Graph, opts ...grpc.CallOption) (*EditResult, error)
	SampleSchema(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*Graph, error)
	AddMapping(ctx context.Context, in *Graph, opts ...grpc.CallOption) (*EditResult, error)
}

EditClient is the client API for Edit 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 NewEditClient

func NewEditClient(cc grpc.ClientConnInterface) EditClient

type EditDirectClient

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

EditDirectClient is a shim to connect Edit client directly server

func NewEditDirectClient

func NewEditDirectClient(server EditServer, opts ...DirectOption) *EditDirectClient

NewEditDirectClient creates new EditDirectClient

func (*EditDirectClient) AddEdge

func (shim *EditDirectClient) AddEdge(ctx context.Context, in *GraphElement, opts ...grpc.CallOption) (*EditResult, error)

AddEdge shim

func (*EditDirectClient) AddGraph

func (shim *EditDirectClient) AddGraph(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*EditResult, error)

AddGraph shim

func (*EditDirectClient) AddIndex

func (shim *EditDirectClient) AddIndex(ctx context.Context, in *IndexID, opts ...grpc.CallOption) (*EditResult, error)

AddIndex shim

func (*EditDirectClient) AddMapping

func (shim *EditDirectClient) AddMapping(ctx context.Context, in *Graph, opts ...grpc.CallOption) (*EditResult, error)

AddMapping shim

func (*EditDirectClient) AddSchema

func (shim *EditDirectClient) AddSchema(ctx context.Context, in *Graph, opts ...grpc.CallOption) (*EditResult, error)

AddSchema shim

func (*EditDirectClient) AddVertex

func (shim *EditDirectClient) AddVertex(ctx context.Context, in *GraphElement, opts ...grpc.CallOption) (*EditResult, error)

AddVertex shim

func (*EditDirectClient) BulkAdd

func (shim *EditDirectClient) BulkAdd(ctx context.Context, opts ...grpc.CallOption) (Edit_BulkAddClient, error)

func (*EditDirectClient) DeleteEdge

func (shim *EditDirectClient) DeleteEdge(ctx context.Context, in *ElementID, opts ...grpc.CallOption) (*EditResult, error)

DeleteEdge shim

func (*EditDirectClient) DeleteGraph

func (shim *EditDirectClient) DeleteGraph(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*EditResult, error)

DeleteGraph shim

func (*EditDirectClient) DeleteIndex

func (shim *EditDirectClient) DeleteIndex(ctx context.Context, in *IndexID, opts ...grpc.CallOption) (*EditResult, error)

DeleteIndex shim

func (*EditDirectClient) DeleteVertex

func (shim *EditDirectClient) DeleteVertex(ctx context.Context, in *ElementID, opts ...grpc.CallOption) (*EditResult, error)

DeleteVertex shim

func (*EditDirectClient) SampleSchema

func (shim *EditDirectClient) SampleSchema(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*Graph, error)

SampleSchema shim

type EditGatewayClient

type EditGatewayClient interface {
	AddVertex(context.Context, *GraphElement) (*EditResult, error)
	AddEdge(context.Context, *GraphElement) (*EditResult, error)
	AddGraph(context.Context, *GraphID) (*EditResult, error)
	DeleteGraph(context.Context, *GraphID) (*EditResult, error)
	DeleteVertex(context.Context, *ElementID) (*EditResult, error)
	DeleteEdge(context.Context, *ElementID) (*EditResult, error)
	AddIndex(context.Context, *IndexID) (*EditResult, error)
	DeleteIndex(context.Context, *IndexID) (*EditResult, error)
	AddSchema(context.Context, *Graph) (*EditResult, error)
	SampleSchema(context.Context, *GraphID) (*Graph, error)
	AddMapping(context.Context, *Graph) (*EditResult, error)
}

EditGatewayClient is the interface for Edit service client.

func NewEditGatewayClient

func NewEditGatewayClient(c gateway.Client) EditGatewayClient

type EditResult

type EditResult struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*EditResult) Descriptor deprecated

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

Deprecated: Use EditResult.ProtoReflect.Descriptor instead.

func (*EditResult) GetId

func (x *EditResult) GetId() string

func (*EditResult) ProtoMessage

func (*EditResult) ProtoMessage()

func (*EditResult) ProtoReflect

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

func (*EditResult) Reset

func (x *EditResult) Reset()

func (*EditResult) String

func (x *EditResult) String() string

type EditServer

type EditServer interface {
	AddVertex(context.Context, *GraphElement) (*EditResult, error)
	AddEdge(context.Context, *GraphElement) (*EditResult, error)
	BulkAdd(Edit_BulkAddServer) error
	AddGraph(context.Context, *GraphID) (*EditResult, error)
	DeleteGraph(context.Context, *GraphID) (*EditResult, error)
	DeleteVertex(context.Context, *ElementID) (*EditResult, error)
	DeleteEdge(context.Context, *ElementID) (*EditResult, error)
	AddIndex(context.Context, *IndexID) (*EditResult, error)
	DeleteIndex(context.Context, *IndexID) (*EditResult, error)
	AddSchema(context.Context, *Graph) (*EditResult, error)
	SampleSchema(context.Context, *GraphID) (*Graph, error)
	AddMapping(context.Context, *Graph) (*EditResult, error)
	// contains filtered or unexported methods
}

EditServer is the server API for Edit service. All implementations must embed UnimplementedEditServer for forward compatibility

type Edit_BulkAddClient

type Edit_BulkAddClient interface {
	Send(*GraphElement) error
	CloseAndRecv() (*BulkEditResult, error)
	grpc.ClientStream
}

type Edit_BulkAddServer

type Edit_BulkAddServer interface {
	SendAndClose(*BulkEditResult) error
	Recv() (*GraphElement, error)
	grpc.ServerStream
}

type ElementID

type ElementID struct {
	Graph string `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"`
	Id    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ElementID) Descriptor deprecated

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

Deprecated: Use ElementID.ProtoReflect.Descriptor instead.

func (*ElementID) GetGraph

func (x *ElementID) GetGraph() string

func (*ElementID) GetId

func (x *ElementID) GetId() string

func (*ElementID) ProtoMessage

func (*ElementID) ProtoMessage()

func (*ElementID) ProtoReflect

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

func (*ElementID) Reset

func (x *ElementID) Reset()

func (*ElementID) String

func (x *ElementID) String() string

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type ExtendQuery

type ExtendQuery struct {
	SrcId string            `protobuf:"bytes,1,opt,name=src_id,json=srcId,proto3" json:"src_id,omitempty"`
	Graph string            `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"`
	Query []*GraphStatement `protobuf:"bytes,3,rep,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendQuery) Descriptor deprecated

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

Deprecated: Use ExtendQuery.ProtoReflect.Descriptor instead.

func (*ExtendQuery) GetGraph

func (x *ExtendQuery) GetGraph() string

func (*ExtendQuery) GetQuery

func (x *ExtendQuery) GetQuery() []*GraphStatement

func (*ExtendQuery) GetSrcId

func (x *ExtendQuery) GetSrcId() string

func (*ExtendQuery) ProtoMessage

func (*ExtendQuery) ProtoMessage()

func (*ExtendQuery) ProtoReflect

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

func (*ExtendQuery) Reset

func (x *ExtendQuery) Reset()

func (*ExtendQuery) String

func (x *ExtendQuery) String() string

type FieldAggregation

type FieldAggregation struct {
	Field string `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldAggregation) Descriptor deprecated

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

Deprecated: Use FieldAggregation.ProtoReflect.Descriptor instead.

func (*FieldAggregation) GetField

func (x *FieldAggregation) GetField() string

func (*FieldAggregation) ProtoMessage

func (*FieldAggregation) ProtoMessage()

func (*FieldAggregation) ProtoReflect

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

func (*FieldAggregation) Reset

func (x *FieldAggregation) Reset()

func (*FieldAggregation) String

func (x *FieldAggregation) String() string

type FieldType

type FieldType int32
const (
	FieldType_UNKNOWN FieldType = 0
	FieldType_STRING  FieldType = 1
	FieldType_NUMERIC FieldType = 2
	FieldType_BOOL    FieldType = 3
	FieldType_MAP     FieldType = 4
	FieldType_ARRAY   FieldType = 5
)

func (FieldType) Descriptor

func (FieldType) Descriptor() protoreflect.EnumDescriptor

func (FieldType) Enum

func (x FieldType) Enum() *FieldType

func (FieldType) EnumDescriptor deprecated

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

Deprecated: Use FieldType.Descriptor instead.

func (FieldType) Number

func (x FieldType) Number() protoreflect.EnumNumber

func (FieldType) String

func (x FieldType) String() string

func (FieldType) Type

type Graph

type Graph struct {
	Graph    string    `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"`
	Vertices []*Vertex `protobuf:"bytes,2,rep,name=vertices,proto3" json:"vertices,omitempty"`
	Edges    []*Edge   `protobuf:"bytes,3,rep,name=edges,proto3" json:"edges,omitempty"`
	// contains filtered or unexported fields
}

func GraphMapToProto

func GraphMapToProto(data map[string]interface{}) (*Graph, error)

func ParseJSONGraphs

func ParseJSONGraphs(raw []byte) ([]*Graph, error)

ParseJSONGraph parses a JSON doc into the given Graph instance.

func ParseJSONGraphsFile

func ParseJSONGraphsFile(relpath string) ([]*Graph, error)

ParseJSONGraphFile parses a graph file, which is formatted in JSON, and returns a slice of graph objects.

func ParseYAMLGraph

func ParseYAMLGraph(raw []byte) (*Graph, error)

ParseYAMLGraph parses a YAML doc into the given Graph instance.

func ParseYAMLGraphPath

func ParseYAMLGraphPath(relpath string) (*Graph, error)

func ParseYAMLGraphs

func ParseYAMLGraphs(raw []byte) ([]*Graph, error)

ParseYAMLGraph parses a YAML doc into the given Graph instance.

func ParseYAMLGraphsFile

func ParseYAMLGraphsFile(relpath string) ([]*Graph, error)

ParseYAMLGraphFile parses a graph file, which is formatted in YAML, and returns a slice of graph objects.

func (*Graph) Descriptor deprecated

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

Deprecated: Use Graph.ProtoReflect.Descriptor instead.

func (*Graph) GetEdges

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

func (*Graph) GetGraph

func (x *Graph) GetGraph() string

func (*Graph) GetVertices

func (x *Graph) GetVertices() []*Vertex

func (*Graph) ProtoMessage

func (*Graph) ProtoMessage()

func (*Graph) ProtoReflect

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

func (*Graph) Reset

func (x *Graph) Reset()

func (*Graph) String

func (x *Graph) String() string

type GraphElement

type GraphElement struct {
	Graph  string  `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"`
	Vertex *Vertex `protobuf:"bytes,2,opt,name=vertex,proto3" json:"vertex,omitempty"`
	Edge   *Edge   `protobuf:"bytes,3,opt,name=edge,proto3" json:"edge,omitempty"`
	// contains filtered or unexported fields
}

func (*GraphElement) Descriptor deprecated

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

Deprecated: Use GraphElement.ProtoReflect.Descriptor instead.

func (*GraphElement) GetEdge

func (x *GraphElement) GetEdge() *Edge

func (*GraphElement) GetGraph

func (x *GraphElement) GetGraph() string

func (*GraphElement) GetVertex

func (x *GraphElement) GetVertex() *Vertex

func (*GraphElement) ProtoMessage

func (*GraphElement) ProtoMessage()

func (*GraphElement) ProtoReflect

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

func (*GraphElement) Reset

func (x *GraphElement) Reset()

func (*GraphElement) String

func (x *GraphElement) String() string

type GraphID

type GraphID struct {
	Graph string `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"`
	// contains filtered or unexported fields
}

func (*GraphID) Descriptor deprecated

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

Deprecated: Use GraphID.ProtoReflect.Descriptor instead.

func (*GraphID) GetGraph

func (x *GraphID) GetGraph() string

func (*GraphID) ProtoMessage

func (*GraphID) ProtoMessage()

func (*GraphID) ProtoReflect

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

func (*GraphID) Reset

func (x *GraphID) Reset()

func (*GraphID) String

func (x *GraphID) String() string

type GraphQuery

type GraphQuery struct {
	Graph string            `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"`
	Query []*GraphStatement `protobuf:"bytes,2,rep,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*GraphQuery) Descriptor deprecated

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

Deprecated: Use GraphQuery.ProtoReflect.Descriptor instead.

func (*GraphQuery) GetGraph

func (x *GraphQuery) GetGraph() string

func (*GraphQuery) GetQuery

func (x *GraphQuery) GetQuery() []*GraphStatement

func (*GraphQuery) ProtoMessage

func (*GraphQuery) ProtoMessage()

func (*GraphQuery) ProtoReflect

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

func (*GraphQuery) Reset

func (x *GraphQuery) Reset()

func (*GraphQuery) String

func (x *GraphQuery) String() string

type GraphStatement

type GraphStatement struct {

	// Types that are assignable to Statement:
	//
	//	*GraphStatement_V
	//	*GraphStatement_E
	//	*GraphStatement_In
	//	*GraphStatement_Out
	//	*GraphStatement_Both
	//	*GraphStatement_InE
	//	*GraphStatement_OutE
	//	*GraphStatement_BothE
	//	*GraphStatement_InNull
	//	*GraphStatement_OutNull
	//	*GraphStatement_InENull
	//	*GraphStatement_OutENull
	//	*GraphStatement_As
	//	*GraphStatement_Select
	//	*GraphStatement_Limit
	//	*GraphStatement_Skip
	//	*GraphStatement_Range
	//	*GraphStatement_Has
	//	*GraphStatement_HasLabel
	//	*GraphStatement_HasKey
	//	*GraphStatement_HasId
	//	*GraphStatement_Distinct
	//	*GraphStatement_Fields
	//	*GraphStatement_Unwind
	//	*GraphStatement_Count
	//	*GraphStatement_Aggregate
	//	*GraphStatement_Render
	//	*GraphStatement_Path
	//	*GraphStatement_Mark
	//	*GraphStatement_Jump
	//	*GraphStatement_Set
	//	*GraphStatement_Increment
	Statement isGraphStatement_Statement `protobuf_oneof:"statement"`
	// contains filtered or unexported fields
}

func (*GraphStatement) Descriptor deprecated

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

Deprecated: Use GraphStatement.ProtoReflect.Descriptor instead.

func (*GraphStatement) GetAggregate

func (x *GraphStatement) GetAggregate() *Aggregations

func (*GraphStatement) GetAs

func (x *GraphStatement) GetAs() string

func (*GraphStatement) GetBoth

func (x *GraphStatement) GetBoth() *structpb.ListValue

func (*GraphStatement) GetBothE

func (x *GraphStatement) GetBothE() *structpb.ListValue

func (*GraphStatement) GetCount

func (x *GraphStatement) GetCount() string

func (*GraphStatement) GetDistinct

func (x *GraphStatement) GetDistinct() *structpb.ListValue

func (*GraphStatement) GetE

func (x *GraphStatement) GetE() *structpb.ListValue

func (*GraphStatement) GetFields

func (x *GraphStatement) GetFields() *structpb.ListValue

func (*GraphStatement) GetHas

func (x *GraphStatement) GetHas() *HasExpression

func (*GraphStatement) GetHasId

func (x *GraphStatement) GetHasId() *structpb.ListValue

func (*GraphStatement) GetHasKey

func (x *GraphStatement) GetHasKey() *structpb.ListValue

func (*GraphStatement) GetHasLabel

func (x *GraphStatement) GetHasLabel() *structpb.ListValue

func (*GraphStatement) GetIn

func (x *GraphStatement) GetIn() *structpb.ListValue

func (*GraphStatement) GetInE

func (x *GraphStatement) GetInE() *structpb.ListValue

func (*GraphStatement) GetInENull

func (x *GraphStatement) GetInENull() *structpb.ListValue

func (*GraphStatement) GetInNull

func (x *GraphStatement) GetInNull() *structpb.ListValue

func (*GraphStatement) GetIncrement

func (x *GraphStatement) GetIncrement() *Increment

func (*GraphStatement) GetJump

func (x *GraphStatement) GetJump() *Jump

func (*GraphStatement) GetLimit

func (x *GraphStatement) GetLimit() uint32

func (*GraphStatement) GetMark

func (x *GraphStatement) GetMark() string

func (*GraphStatement) GetOut

func (x *GraphStatement) GetOut() *structpb.ListValue

func (*GraphStatement) GetOutE

func (x *GraphStatement) GetOutE() *structpb.ListValue

func (*GraphStatement) GetOutENull

func (x *GraphStatement) GetOutENull() *structpb.ListValue

func (*GraphStatement) GetOutNull

func (x *GraphStatement) GetOutNull() *structpb.ListValue

func (*GraphStatement) GetPath

func (x *GraphStatement) GetPath() *structpb.ListValue

func (*GraphStatement) GetRange

func (x *GraphStatement) GetRange() *Range

func (*GraphStatement) GetRender

func (x *GraphStatement) GetRender() *structpb.Value

func (*GraphStatement) GetSelect

func (x *GraphStatement) GetSelect() *SelectStatement

func (*GraphStatement) GetSet

func (x *GraphStatement) GetSet() *Set

func (*GraphStatement) GetSkip

func (x *GraphStatement) GetSkip() uint32

func (*GraphStatement) GetStatement

func (m *GraphStatement) GetStatement() isGraphStatement_Statement

func (*GraphStatement) GetUnwind

func (x *GraphStatement) GetUnwind() string

func (*GraphStatement) GetV

func (x *GraphStatement) GetV() *structpb.ListValue

func (*GraphStatement) ProtoMessage

func (*GraphStatement) ProtoMessage()

func (*GraphStatement) ProtoReflect

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

func (*GraphStatement) Reset

func (x *GraphStatement) Reset()

func (*GraphStatement) String

func (x *GraphStatement) String() string

type GraphStatement_Aggregate

type GraphStatement_Aggregate struct {
	Aggregate *Aggregations `protobuf:"bytes,61,opt,name=aggregate,proto3,oneof"`
}

type GraphStatement_As

type GraphStatement_As struct {
	As string `protobuf:"bytes,20,opt,name=as,proto3,oneof"`
}

type GraphStatement_Both

type GraphStatement_Both struct {
	Both *structpb.ListValue `protobuf:"bytes,14,opt,name=both,proto3,oneof"`
}

type GraphStatement_BothE

type GraphStatement_BothE struct {
	BothE *structpb.ListValue `protobuf:"bytes,15,opt,name=both_e,json=bothE,proto3,oneof"`
}

type GraphStatement_Count

type GraphStatement_Count struct {
	Count string `protobuf:"bytes,60,opt,name=count,proto3,oneof"`
}

type GraphStatement_Distinct

type GraphStatement_Distinct struct {
	Distinct *structpb.ListValue `protobuf:"bytes,40,opt,name=distinct,proto3,oneof"`
}

type GraphStatement_E

type GraphStatement_E struct {
	E *structpb.ListValue `protobuf:"bytes,2,opt,name=e,proto3,oneof"`
}

type GraphStatement_EngineCustom

type GraphStatement_EngineCustom struct {
	Desc   string      `protobuf:"bytes,1,opt,name=desc" json:"desc,omitempty"`
	Custom interface{} `protobuf:"bytes,2,opt,name=custom" json:"custom,omitempty"`
}

type GraphStatement_Fields

type GraphStatement_Fields struct {
	Fields *structpb.ListValue `protobuf:"bytes,50,opt,name=fields,proto3,oneof"`
}

type GraphStatement_Has

type GraphStatement_Has struct {
	Has *HasExpression `protobuf:"bytes,30,opt,name=has,proto3,oneof"`
}

type GraphStatement_HasId

type GraphStatement_HasId struct {
	HasId *structpb.ListValue `protobuf:"bytes,33,opt,name=has_id,json=hasId,proto3,oneof"`
}

type GraphStatement_HasKey

type GraphStatement_HasKey struct {
	HasKey *structpb.ListValue `protobuf:"bytes,32,opt,name=has_key,json=hasKey,proto3,oneof"`
}

type GraphStatement_HasLabel

type GraphStatement_HasLabel struct {
	HasLabel *structpb.ListValue `protobuf:"bytes,31,opt,name=has_label,json=hasLabel,proto3,oneof"`
}

type GraphStatement_In

type GraphStatement_In struct {
	In *structpb.ListValue `protobuf:"bytes,10,opt,name=in,proto3,oneof"`
}

type GraphStatement_InE

type GraphStatement_InE struct {
	InE *structpb.ListValue `protobuf:"bytes,12,opt,name=in_e,json=inE,proto3,oneof"`
}

type GraphStatement_InENull

type GraphStatement_InENull struct {
	InENull *structpb.ListValue `protobuf:"bytes,18,opt,name=in_e_null,json=inENull,proto3,oneof"`
}

type GraphStatement_InNull

type GraphStatement_InNull struct {
	InNull *structpb.ListValue `protobuf:"bytes,16,opt,name=in_null,json=inNull,proto3,oneof"`
}

type GraphStatement_Increment

type GraphStatement_Increment struct {
	Increment *Increment `protobuf:"bytes,73,opt,name=increment,proto3,oneof"`
}

type GraphStatement_Jump

type GraphStatement_Jump struct {
	Jump *Jump `protobuf:"bytes,71,opt,name=jump,proto3,oneof"`
}

type GraphStatement_Limit

type GraphStatement_Limit struct {
	Limit uint32 `protobuf:"varint,24,opt,name=limit,proto3,oneof"`
}

type GraphStatement_LookupVertsIndex

type GraphStatement_LookupVertsIndex struct {
	Labels []string `protobuf:"bytes,1,rep,name=labels" json:"labels,omitempty"`
}

type GraphStatement_Mark

type GraphStatement_Mark struct {
	Mark string `protobuf:"bytes,70,opt,name=mark,proto3,oneof"`
}

type GraphStatement_Out

type GraphStatement_Out struct {
	Out *structpb.ListValue `protobuf:"bytes,11,opt,name=out,proto3,oneof"`
}

type GraphStatement_OutE

type GraphStatement_OutE struct {
	OutE *structpb.ListValue `protobuf:"bytes,13,opt,name=out_e,json=outE,proto3,oneof"`
}

type GraphStatement_OutENull

type GraphStatement_OutENull struct {
	OutENull *structpb.ListValue `protobuf:"bytes,19,opt,name=out_e_null,json=outENull,proto3,oneof"`
}

type GraphStatement_OutNull

type GraphStatement_OutNull struct {
	OutNull *structpb.ListValue `protobuf:"bytes,17,opt,name=out_null,json=outNull,proto3,oneof"`
}

type GraphStatement_Path

type GraphStatement_Path struct {
	Path *structpb.ListValue `protobuf:"bytes,63,opt,name=path,proto3,oneof"`
}

type GraphStatement_Range

type GraphStatement_Range struct {
	Range *Range `protobuf:"bytes,26,opt,name=range,proto3,oneof"`
}

type GraphStatement_Render

type GraphStatement_Render struct {
	Render *structpb.Value `protobuf:"bytes,62,opt,name=render,proto3,oneof"`
}

type GraphStatement_Select

type GraphStatement_Select struct {
	Select *SelectStatement `protobuf:"bytes,21,opt,name=select,proto3,oneof"`
}

type GraphStatement_Set

type GraphStatement_Set struct {
	Set *Set `protobuf:"bytes,72,opt,name=set,proto3,oneof"`
}

type GraphStatement_Skip

type GraphStatement_Skip struct {
	Skip uint32 `protobuf:"varint,25,opt,name=skip,proto3,oneof"`
}

type GraphStatement_Unwind

type GraphStatement_Unwind struct {
	Unwind string `protobuf:"bytes,51,opt,name=unwind,proto3,oneof"`
}

type GraphStatement_V

type GraphStatement_V struct {
	V *structpb.ListValue `protobuf:"bytes,1,opt,name=v,proto3,oneof"`
}

type HasCondition

type HasCondition struct {
	Key       string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     *structpb.Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Condition Condition       `protobuf:"varint,3,opt,name=condition,proto3,enum=gripql.Condition" json:"condition,omitempty"`
	// contains filtered or unexported fields
}

func (*HasCondition) Descriptor deprecated

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

Deprecated: Use HasCondition.ProtoReflect.Descriptor instead.

func (*HasCondition) GetCondition

func (x *HasCondition) GetCondition() Condition

func (*HasCondition) GetKey

func (x *HasCondition) GetKey() string

func (*HasCondition) GetValue

func (x *HasCondition) GetValue() *structpb.Value

func (*HasCondition) ProtoMessage

func (*HasCondition) ProtoMessage()

func (*HasCondition) ProtoReflect

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

func (*HasCondition) Reset

func (x *HasCondition) Reset()

func (*HasCondition) String

func (x *HasCondition) String() string

type HasExpression

type HasExpression struct {

	// Types that are assignable to Expression:
	//
	//	*HasExpression_And
	//	*HasExpression_Or
	//	*HasExpression_Not
	//	*HasExpression_Condition
	Expression isHasExpression_Expression `protobuf_oneof:"expression"`
	// contains filtered or unexported fields
}

func And

func And(expressions ...*HasExpression) *HasExpression

And repreesents a logical "and" of two or more HasExpressions

func Between

func Between(key string, value interface{}) *HasExpression

Between asserts that the number the provided key resolves to is greater than or equal to the first provided number and less than the second.

func Contains

func Contains(key string, value interface{}) *HasExpression

Contains asserts that the array the provided key resolves to contains the provided value.

func Eq

func Eq(key string, value interface{}) *HasExpression

Eq asserts that the value the provided key resolves to is equal to the provided value.

func Gt

func Gt(key string, value interface{}) *HasExpression

Gt asserts that the value the provided key resolves to is greater than the provided value.

func Gte

func Gte(key string, value interface{}) *HasExpression

Gte asserts that the value the provided key resolves to is greater than or equal to the provided value.

func Inside

func Inside(key string, value interface{}) *HasExpression

Inside asserts that the number the provided key resolves to is greater than the first provided number and less than the second.

func Lt

func Lt(key string, value interface{}) *HasExpression

Lt asserts that the value the provided key resolves to is less than the provided value.

func Lte

func Lte(key string, value interface{}) *HasExpression

Lte asserts that the value the provided key resolves to is less than or equal to the provided value.

func Neq

func Neq(key string, value interface{}) *HasExpression

Neq asserts that the value the provided key resolves to is not equal to the provided value.

func Not

func Not(expression *HasExpression) *HasExpression

Not repreesents a logical "not" for a HasExpression

func Or

func Or(expressions ...*HasExpression) *HasExpression

Or repreesents a logical "or" of two or more HasExpressions

func Outside

func Outside(key string, value interface{}) *HasExpression

Outside asserts that the number the provided key resolves to is less than the first provided number and greater than the second.

func Within

func Within(key string, values ...interface{}) *HasExpression

Within asserts that the value the provided key resolves to is in the provided list of values.

func Without

func Without(key string, values ...interface{}) *HasExpression

Without asserts that the value the provided key resolves to is not in the provided list of values.

func (*HasExpression) Descriptor deprecated

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

Deprecated: Use HasExpression.ProtoReflect.Descriptor instead.

func (*HasExpression) GetAnd

func (x *HasExpression) GetAnd() *HasExpressionList

func (*HasExpression) GetCondition

func (x *HasExpression) GetCondition() *HasCondition

func (*HasExpression) GetExpression

func (m *HasExpression) GetExpression() isHasExpression_Expression

func (*HasExpression) GetNot

func (x *HasExpression) GetNot() *HasExpression

func (*HasExpression) GetOr

func (x *HasExpression) GetOr() *HasExpressionList

func (*HasExpression) ProtoMessage

func (*HasExpression) ProtoMessage()

func (*HasExpression) ProtoReflect

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

func (*HasExpression) Reset

func (x *HasExpression) Reset()

func (*HasExpression) String

func (x *HasExpression) String() string

type HasExpressionList

type HasExpressionList struct {
	Expressions []*HasExpression `protobuf:"bytes,1,rep,name=expressions,proto3" json:"expressions,omitempty"`
	// contains filtered or unexported fields
}

func (*HasExpressionList) Descriptor deprecated

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

Deprecated: Use HasExpressionList.ProtoReflect.Descriptor instead.

func (*HasExpressionList) GetExpressions

func (x *HasExpressionList) GetExpressions() []*HasExpression

func (*HasExpressionList) ProtoMessage

func (*HasExpressionList) ProtoMessage()

func (*HasExpressionList) ProtoReflect

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

func (*HasExpressionList) Reset

func (x *HasExpressionList) Reset()

func (*HasExpressionList) String

func (x *HasExpressionList) String() string

type HasExpression_And

type HasExpression_And struct {
	And *HasExpressionList `protobuf:"bytes,1,opt,name=and,proto3,oneof"`
}

type HasExpression_Condition

type HasExpression_Condition struct {
	Condition *HasCondition `protobuf:"bytes,4,opt,name=condition,proto3,oneof"`
}

type HasExpression_Not

type HasExpression_Not struct {
	Not *HasExpression `protobuf:"bytes,3,opt,name=not,proto3,oneof"`
}

type HasExpression_Or

type HasExpression_Or struct {
	Or *HasExpressionList `protobuf:"bytes,2,opt,name=or,proto3,oneof"`
}

type HistogramAggregation

type HistogramAggregation struct {
	Field    string `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	Interval uint32 `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*HistogramAggregation) Descriptor deprecated

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

Deprecated: Use HistogramAggregation.ProtoReflect.Descriptor instead.

func (*HistogramAggregation) GetField

func (x *HistogramAggregation) GetField() string

func (*HistogramAggregation) GetInterval

func (x *HistogramAggregation) GetInterval() uint32

func (*HistogramAggregation) ProtoMessage

func (*HistogramAggregation) ProtoMessage()

func (*HistogramAggregation) ProtoReflect

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

func (*HistogramAggregation) Reset

func (x *HistogramAggregation) Reset()

func (*HistogramAggregation) String

func (x *HistogramAggregation) String() string

type Increment

type Increment struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value int32  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Increment) Descriptor deprecated

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

Deprecated: Use Increment.ProtoReflect.Descriptor instead.

func (*Increment) GetKey

func (x *Increment) GetKey() string

func (*Increment) GetValue

func (x *Increment) GetValue() int32

func (*Increment) ProtoMessage

func (*Increment) ProtoMessage()

func (*Increment) ProtoReflect

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

func (*Increment) Reset

func (x *Increment) Reset()

func (*Increment) String

func (x *Increment) String() string

type IndexID

type IndexID struct {
	Graph string `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"`
	Label string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Field string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexID) Descriptor deprecated

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

Deprecated: Use IndexID.ProtoReflect.Descriptor instead.

func (*IndexID) GetField

func (x *IndexID) GetField() string

func (*IndexID) GetGraph

func (x *IndexID) GetGraph() string

func (*IndexID) GetLabel

func (x *IndexID) GetLabel() string

func (*IndexID) ProtoMessage

func (*IndexID) ProtoMessage()

func (*IndexID) ProtoReflect

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

func (*IndexID) Reset

func (x *IndexID) Reset()

func (*IndexID) String

func (x *IndexID) String() string

type JobClient

type JobClient interface {
	Submit(ctx context.Context, in *GraphQuery, opts ...grpc.CallOption) (*QueryJob, error)
	ListJobs(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (Job_ListJobsClient, error)
	SearchJobs(ctx context.Context, in *GraphQuery, opts ...grpc.CallOption) (Job_SearchJobsClient, error)
	DeleteJob(ctx context.Context, in *QueryJob, opts ...grpc.CallOption) (*JobStatus, error)
	GetJob(ctx context.Context, in *QueryJob, opts ...grpc.CallOption) (*JobStatus, error)
	ViewJob(ctx context.Context, in *QueryJob, opts ...grpc.CallOption) (Job_ViewJobClient, error)
	ResumeJob(ctx context.Context, in *ExtendQuery, opts ...grpc.CallOption) (Job_ResumeJobClient, error)
}

JobClient is the client API for Job 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 NewJobClient

func NewJobClient(cc grpc.ClientConnInterface) JobClient

type JobDirectClient

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

JobDirectClient is a shim to connect Job client directly server

func NewJobDirectClient

func NewJobDirectClient(server JobServer, opts ...DirectOption) *JobDirectClient

NewJobDirectClient creates new JobDirectClient

func (*JobDirectClient) DeleteJob

func (shim *JobDirectClient) DeleteJob(ctx context.Context, in *QueryJob, opts ...grpc.CallOption) (*JobStatus, error)

DeleteJob shim

func (*JobDirectClient) GetJob

func (shim *JobDirectClient) GetJob(ctx context.Context, in *QueryJob, opts ...grpc.CallOption) (*JobStatus, error)

GetJob shim

func (*JobDirectClient) ListJobs

func (shim *JobDirectClient) ListJobs(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (Job_ListJobsClient, error)

func (*JobDirectClient) ResumeJob

func (shim *JobDirectClient) ResumeJob(ctx context.Context, in *ExtendQuery, opts ...grpc.CallOption) (Job_ResumeJobClient, error)

func (*JobDirectClient) SearchJobs

func (shim *JobDirectClient) SearchJobs(ctx context.Context, in *GraphQuery, opts ...grpc.CallOption) (Job_SearchJobsClient, error)

func (*JobDirectClient) Submit

func (shim *JobDirectClient) Submit(ctx context.Context, in *GraphQuery, opts ...grpc.CallOption) (*QueryJob, error)

Submit shim

func (*JobDirectClient) ViewJob

func (shim *JobDirectClient) ViewJob(ctx context.Context, in *QueryJob, opts ...grpc.CallOption) (Job_ViewJobClient, error)

type JobGatewayClient

type JobGatewayClient interface {
	Submit(context.Context, *GraphQuery) (*QueryJob, error)
	ListJobs(context.Context, *GraphID) (<-chan *QueryJob, <-chan error, error)
	SearchJobs(context.Context, *GraphQuery) (<-chan *JobStatus, <-chan error, error)
	DeleteJob(context.Context, *QueryJob) (*JobStatus, error)
	GetJob(context.Context, *QueryJob) (*JobStatus, error)
	ViewJob(context.Context, *QueryJob) (<-chan *QueryResult, <-chan error, error)
	ResumeJob(context.Context, *ExtendQuery) (<-chan *QueryResult, <-chan error, error)
}

JobGatewayClient is the interface for Job service client.

func NewJobGatewayClient

func NewJobGatewayClient(c gateway.Client) JobGatewayClient

type JobServer

type JobServer interface {
	Submit(context.Context, *GraphQuery) (*QueryJob, error)
	ListJobs(*GraphID, Job_ListJobsServer) error
	SearchJobs(*GraphQuery, Job_SearchJobsServer) error
	DeleteJob(context.Context, *QueryJob) (*JobStatus, error)
	GetJob(context.Context, *QueryJob) (*JobStatus, error)
	ViewJob(*QueryJob, Job_ViewJobServer) error
	ResumeJob(*ExtendQuery, Job_ResumeJobServer) error
	// contains filtered or unexported methods
}

JobServer is the server API for Job service. All implementations must embed UnimplementedJobServer for forward compatibility

type JobState

type JobState int32
const (
	JobState_QUEUED   JobState = 0
	JobState_RUNNING  JobState = 1
	JobState_COMPLETE JobState = 2
	JobState_ERROR    JobState = 3
	JobState_DELETED  JobState = 4
)

func (JobState) Descriptor

func (JobState) Descriptor() protoreflect.EnumDescriptor

func (JobState) Enum

func (x JobState) Enum() *JobState

func (JobState) EnumDescriptor deprecated

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

Deprecated: Use JobState.Descriptor instead.

func (JobState) Number

func (x JobState) Number() protoreflect.EnumNumber

func (JobState) String

func (x JobState) String() string

func (JobState) Type

type JobStatus

type JobStatus struct {
	Id        string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Graph     string            `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"`
	State     JobState          `protobuf:"varint,3,opt,name=state,proto3,enum=gripql.JobState" json:"state,omitempty"`
	Count     uint64            `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	Query     []*GraphStatement `protobuf:"bytes,5,rep,name=query,proto3" json:"query,omitempty"`
	Timestamp string            `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStatus) Descriptor deprecated

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

Deprecated: Use JobStatus.ProtoReflect.Descriptor instead.

func (*JobStatus) GetCount

func (x *JobStatus) GetCount() uint64

func (*JobStatus) GetGraph

func (x *JobStatus) GetGraph() string

func (*JobStatus) GetId

func (x *JobStatus) GetId() string

func (*JobStatus) GetQuery

func (x *JobStatus) GetQuery() []*GraphStatement

func (*JobStatus) GetState

func (x *JobStatus) GetState() JobState

func (*JobStatus) GetTimestamp

func (x *JobStatus) GetTimestamp() string

func (*JobStatus) MarshalJSON

func (js *JobStatus) MarshalJSON() ([]byte, error)

func (*JobStatus) ProtoMessage

func (*JobStatus) ProtoMessage()

func (*JobStatus) ProtoReflect

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

func (*JobStatus) Reset

func (x *JobStatus) Reset()

func (*JobStatus) String

func (x *JobStatus) String() string

func (*JobStatus) UnmarshalJSON

func (js *JobStatus) UnmarshalJSON(data []byte) error

type Job_ListJobsClient

type Job_ListJobsClient interface {
	Recv() (*QueryJob, error)
	grpc.ClientStream
}

type Job_ListJobsServer

type Job_ListJobsServer interface {
	Send(*QueryJob) error
	grpc.ServerStream
}

type Job_ResumeJobClient

type Job_ResumeJobClient interface {
	Recv() (*QueryResult, error)
	grpc.ClientStream
}

type Job_ResumeJobServer

type Job_ResumeJobServer interface {
	Send(*QueryResult) error
	grpc.ServerStream
}

type Job_SearchJobsClient

type Job_SearchJobsClient interface {
	Recv() (*JobStatus, error)
	grpc.ClientStream
}

type Job_SearchJobsServer

type Job_SearchJobsServer interface {
	Send(*JobStatus) error
	grpc.ServerStream
}

type Job_ViewJobClient

type Job_ViewJobClient interface {
	Recv() (*QueryResult, error)
	grpc.ClientStream
}

type Job_ViewJobServer

type Job_ViewJobServer interface {
	Send(*QueryResult) error
	grpc.ServerStream
}

type Jump

type Jump struct {
	Mark       string         `protobuf:"bytes,1,opt,name=mark,proto3" json:"mark,omitempty"`
	Expression *HasExpression `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	Emit       bool           `protobuf:"varint,3,opt,name=emit,proto3" json:"emit,omitempty"`
	// contains filtered or unexported fields
}

func (*Jump) Descriptor deprecated

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

Deprecated: Use Jump.ProtoReflect.Descriptor instead.

func (*Jump) GetEmit

func (x *Jump) GetEmit() bool

func (*Jump) GetExpression

func (x *Jump) GetExpression() *HasExpression

func (*Jump) GetMark

func (x *Jump) GetMark() string

func (*Jump) ProtoMessage

func (*Jump) ProtoMessage()

func (*Jump) ProtoReflect

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

func (*Jump) Reset

func (x *Jump) Reset()

func (*Jump) String

func (x *Jump) String() string

type ListDriversResponse

type ListDriversResponse struct {
	Drivers []string `protobuf:"bytes,1,rep,name=drivers,proto3" json:"drivers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDriversResponse) Descriptor deprecated

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

Deprecated: Use ListDriversResponse.ProtoReflect.Descriptor instead.

func (*ListDriversResponse) GetDrivers

func (x *ListDriversResponse) GetDrivers() []string

func (*ListDriversResponse) ProtoMessage

func (*ListDriversResponse) ProtoMessage()

func (*ListDriversResponse) ProtoReflect

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

func (*ListDriversResponse) Reset

func (x *ListDriversResponse) Reset()

func (*ListDriversResponse) String

func (x *ListDriversResponse) String() string

type ListGraphsResponse

type ListGraphsResponse struct {
	Graphs []string `protobuf:"bytes,1,rep,name=graphs,proto3" json:"graphs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListGraphsResponse) Descriptor deprecated

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

Deprecated: Use ListGraphsResponse.ProtoReflect.Descriptor instead.

func (*ListGraphsResponse) GetGraphs

func (x *ListGraphsResponse) GetGraphs() []string

func (*ListGraphsResponse) ProtoMessage

func (*ListGraphsResponse) ProtoMessage()

func (*ListGraphsResponse) ProtoReflect

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

func (*ListGraphsResponse) Reset

func (x *ListGraphsResponse) Reset()

func (*ListGraphsResponse) String

func (x *ListGraphsResponse) String() string

type ListIndicesResponse

type ListIndicesResponse struct {
	Indices []*IndexID `protobuf:"bytes,1,rep,name=indices,proto3" json:"indices,omitempty"`
	// contains filtered or unexported fields
}

func (*ListIndicesResponse) Descriptor deprecated

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

Deprecated: Use ListIndicesResponse.ProtoReflect.Descriptor instead.

func (*ListIndicesResponse) GetIndices

func (x *ListIndicesResponse) GetIndices() []*IndexID

func (*ListIndicesResponse) ProtoMessage

func (*ListIndicesResponse) ProtoMessage()

func (*ListIndicesResponse) ProtoReflect

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

func (*ListIndicesResponse) Reset

func (x *ListIndicesResponse) Reset()

func (*ListIndicesResponse) String

func (x *ListIndicesResponse) String() string

type ListLabelsResponse

type ListLabelsResponse struct {
	VertexLabels []string `protobuf:"bytes,1,rep,name=vertex_labels,json=vertexLabels,proto3" json:"vertex_labels,omitempty"`
	EdgeLabels   []string `protobuf:"bytes,2,rep,name=edge_labels,json=edgeLabels,proto3" json:"edge_labels,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLabelsResponse) Descriptor deprecated

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

Deprecated: Use ListLabelsResponse.ProtoReflect.Descriptor instead.

func (*ListLabelsResponse) GetEdgeLabels

func (x *ListLabelsResponse) GetEdgeLabels() []string

func (*ListLabelsResponse) GetVertexLabels

func (x *ListLabelsResponse) GetVertexLabels() []string

func (*ListLabelsResponse) ProtoMessage

func (*ListLabelsResponse) ProtoMessage()

func (*ListLabelsResponse) ProtoReflect

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

func (*ListLabelsResponse) Reset

func (x *ListLabelsResponse) Reset()

func (*ListLabelsResponse) String

func (x *ListLabelsResponse) String() string

type ListPluginsResponse

type ListPluginsResponse struct {
	Plugins []string `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPluginsResponse) Descriptor deprecated

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

Deprecated: Use ListPluginsResponse.ProtoReflect.Descriptor instead.

func (*ListPluginsResponse) GetPlugins

func (x *ListPluginsResponse) GetPlugins() []string

func (*ListPluginsResponse) ProtoMessage

func (*ListPluginsResponse) ProtoMessage()

func (*ListPluginsResponse) ProtoReflect

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

func (*ListPluginsResponse) Reset

func (x *ListPluginsResponse) Reset()

func (*ListPluginsResponse) String

func (x *ListPluginsResponse) String() string

type NamedAggregationResult

type NamedAggregationResult struct {
	Name  string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Key   *structpb.Value `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value float64         `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*NamedAggregationResult) Descriptor deprecated

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

Deprecated: Use NamedAggregationResult.ProtoReflect.Descriptor instead.

func (*NamedAggregationResult) GetKey

func (x *NamedAggregationResult) GetKey() *structpb.Value

func (*NamedAggregationResult) GetName

func (x *NamedAggregationResult) GetName() string

func (*NamedAggregationResult) GetValue

func (x *NamedAggregationResult) GetValue() float64

func (*NamedAggregationResult) ProtoMessage

func (*NamedAggregationResult) ProtoMessage()

func (*NamedAggregationResult) ProtoReflect

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

func (*NamedAggregationResult) Reset

func (x *NamedAggregationResult) Reset()

func (*NamedAggregationResult) String

func (x *NamedAggregationResult) String() string

type PercentileAggregation

type PercentileAggregation struct {
	Field    string    `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	Percents []float64 `protobuf:"fixed64,3,rep,packed,name=percents,proto3" json:"percents,omitempty"`
	// contains filtered or unexported fields
}

func (*PercentileAggregation) Descriptor deprecated

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

Deprecated: Use PercentileAggregation.ProtoReflect.Descriptor instead.

func (*PercentileAggregation) GetField

func (x *PercentileAggregation) GetField() string

func (*PercentileAggregation) GetPercents

func (x *PercentileAggregation) GetPercents() []float64

func (*PercentileAggregation) ProtoMessage

func (*PercentileAggregation) ProtoMessage()

func (*PercentileAggregation) ProtoReflect

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

func (*PercentileAggregation) Reset

func (x *PercentileAggregation) Reset()

func (*PercentileAggregation) String

func (x *PercentileAggregation) String() string

type PluginConfig

type PluginConfig struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Driver string            `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PluginConfig) Descriptor deprecated

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

Deprecated: Use PluginConfig.ProtoReflect.Descriptor instead.

func (*PluginConfig) GetConfig

func (x *PluginConfig) GetConfig() map[string]string

func (*PluginConfig) GetDriver

func (x *PluginConfig) GetDriver() string

func (*PluginConfig) GetName

func (x *PluginConfig) GetName() string

func (*PluginConfig) ProtoMessage

func (*PluginConfig) ProtoMessage()

func (*PluginConfig) ProtoReflect

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

func (*PluginConfig) Reset

func (x *PluginConfig) Reset()

func (*PluginConfig) String

func (x *PluginConfig) String() string

type PluginStatus

type PluginStatus struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginStatus) Descriptor deprecated

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

Deprecated: Use PluginStatus.ProtoReflect.Descriptor instead.

func (*PluginStatus) GetError

func (x *PluginStatus) GetError() string

func (*PluginStatus) GetName

func (x *PluginStatus) GetName() string

func (*PluginStatus) ProtoMessage

func (*PluginStatus) ProtoMessage()

func (*PluginStatus) ProtoReflect

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

func (*PluginStatus) Reset

func (x *PluginStatus) Reset()

func (*PluginStatus) String

func (x *PluginStatus) String() string

type Query

type Query struct {
	Statements []*GraphStatement
}

Query helps build graph queries.

func E

func E(ids ...string) *Query

E starts a new vertex query, short for `NewQuery().E()`.

func NewQuery

func NewQuery() *Query

NewQuery creates a new Query instance.

func V

func V(ids ...string) *Query

V starts a new vertex query, short for `NewQuery().V()`.

func (*Query) Aggregate

func (q *Query) Aggregate(agg []*Aggregate) *Query

func (*Query) As

func (q *Query) As(id string) *Query

As marks current elements with tag

func (*Query) Both

func (q *Query) Both(label ...string) *Query

Both follows both incoming and outgoing edges to adjacent vertex

func (*Query) BothE

func (q *Query) BothE(label ...string) *Query

BothE moves to both incoming and outgoing edges

func (*Query) BothV

func (q *Query) BothV(label ...string) *Query

BothV follows both incoming and outgoing edges to adjacent vertex

func (*Query) Count

func (q *Query) Count() *Query

Count adds a count step to the query

func (*Query) Distinct

func (q *Query) Distinct(args ...string) *Query

Distinct selects records with distinct elements of arg

func (*Query) E

func (q *Query) E(id ...string) *Query

E adds a edge selection step to the query

func (*Query) Fields

func (q *Query) Fields(keys ...string) *Query

Fields selects which properties are returned in the result.

func (*Query) Has

func (q *Query) Has(expression *HasExpression) *Query

Has filters elements based on data properties.

func (*Query) HasID

func (q *Query) HasID(id ...string) *Query

HasID filters elements based on their id.

func (*Query) HasKey

func (q *Query) HasKey(key ...string) *Query

HasKey filters elements based on whether it has one or more properties.

func (*Query) HasLabel

func (q *Query) HasLabel(label ...string) *Query

HasLabel filters elements based on their label.

func (*Query) In

func (q *Query) In(label ...string) *Query

In follows incoming edges to adjacent vertex

func (*Query) InE

func (q *Query) InE(label ...string) *Query

InE moves to incoming edge

func (*Query) InNull

func (q *Query) InNull(label ...string) *Query

InV follows incoming edges to adjacent vertex

func (*Query) Limit

func (q *Query) Limit(n uint32) *Query

Limit limits the number of results returned.

func (*Query) Out

func (q *Query) Out(label ...string) *Query

Out follows outgoing edges to adjacent vertex

func (*Query) OutE

func (q *Query) OutE(label ...string) *Query

OutE moves to outgoing edge

func (*Query) OutNull

func (q *Query) OutNull(label ...string) *Query

OutV follows outgoing edges to adjacent vertex

func (*Query) Range

func (q *Query) Range(start, stop int32) *Query

Range will limits which records are returned. When the low-end of the range is not met, objects are continued to be iterated. When within the low (inclusive) and high (exclusive) range, traversers are emitted. When above the high range, the traversal breaks out of iteration. Finally, the use of -1 on the high range will emit remaining traversers after the low range begins.

func (*Query) Render

func (q *Query) Render(template interface{}) *Query

Render adds a render step to the query

func (*Query) Select

func (q *Query) Select(id ...string) *Query

Select retreieves previously marked elemets

func (*Query) Skip

func (q *Query) Skip(n uint32) *Query

Skip will drop the first n number of records and return the rest.

func (*Query) String

func (q *Query) String() string

func (*Query) V

func (q *Query) V(id ...string) *Query

V adds a vertex selection step to the query

type QueryClient

type QueryClient interface {
	Traversal(ctx context.Context, in *GraphQuery, opts ...grpc.CallOption) (Query_TraversalClient, error)
	GetVertex(ctx context.Context, in *ElementID, opts ...grpc.CallOption) (*Vertex, error)
	GetEdge(ctx context.Context, in *ElementID, opts ...grpc.CallOption) (*Edge, error)
	GetTimestamp(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*Timestamp, error)
	GetSchema(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*Graph, error)
	GetMapping(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*Graph, error)
	ListGraphs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListGraphsResponse, error)
	ListIndices(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*ListIndicesResponse, error)
	ListLabels(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*ListLabelsResponse, error)
	ListTables(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Query_ListTablesClient, error)
}

QueryClient is the client API for Query 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 NewQueryClient

func NewQueryClient(cc grpc.ClientConnInterface) QueryClient

type QueryDirectClient

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

QueryDirectClient is a shim to connect Query client directly server

func NewQueryDirectClient

func NewQueryDirectClient(server QueryServer, opts ...DirectOption) *QueryDirectClient

NewQueryDirectClient creates new QueryDirectClient

func (*QueryDirectClient) GetEdge

func (shim *QueryDirectClient) GetEdge(ctx context.Context, in *ElementID, opts ...grpc.CallOption) (*Edge, error)

GetEdge shim

func (*QueryDirectClient) GetMapping

func (shim *QueryDirectClient) GetMapping(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*Graph, error)

GetMapping shim

func (*QueryDirectClient) GetSchema

func (shim *QueryDirectClient) GetSchema(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*Graph, error)

GetSchema shim

func (*QueryDirectClient) GetTimestamp

func (shim *QueryDirectClient) GetTimestamp(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*Timestamp, error)

GetTimestamp shim

func (*QueryDirectClient) GetVertex

func (shim *QueryDirectClient) GetVertex(ctx context.Context, in *ElementID, opts ...grpc.CallOption) (*Vertex, error)

GetVertex shim

func (*QueryDirectClient) ListGraphs

func (shim *QueryDirectClient) ListGraphs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListGraphsResponse, error)

ListGraphs shim

func (*QueryDirectClient) ListIndices

func (shim *QueryDirectClient) ListIndices(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*ListIndicesResponse, error)

ListIndices shim

func (*QueryDirectClient) ListLabels

func (shim *QueryDirectClient) ListLabels(ctx context.Context, in *GraphID, opts ...grpc.CallOption) (*ListLabelsResponse, error)

ListLabels shim

func (*QueryDirectClient) ListTables

func (shim *QueryDirectClient) ListTables(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Query_ListTablesClient, error)

func (*QueryDirectClient) Traversal

func (shim *QueryDirectClient) Traversal(ctx context.Context, in *GraphQuery, opts ...grpc.CallOption) (Query_TraversalClient, error)

type QueryGatewayClient

type QueryGatewayClient interface {
	Traversal(context.Context, *GraphQuery) (<-chan *QueryResult, <-chan error, error)
	GetVertex(context.Context, *ElementID) (*Vertex, error)
	GetEdge(context.Context, *ElementID) (*Edge, error)
	GetTimestamp(context.Context, *GraphID) (*Timestamp, error)
	GetSchema(context.Context, *GraphID) (*Graph, error)
	GetMapping(context.Context, *GraphID) (*Graph, error)
	ListGraphs(context.Context, *Empty) (*ListGraphsResponse, error)
	ListIndices(context.Context, *GraphID) (*ListIndicesResponse, error)
	ListLabels(context.Context, *GraphID) (*ListLabelsResponse, error)
	ListTables(context.Context, *Empty) (<-chan *TableInfo, <-chan error, error)
}

QueryGatewayClient is the interface for Query service client.

func NewQueryGatewayClient

func NewQueryGatewayClient(c gateway.Client) QueryGatewayClient

type QueryJob

type QueryJob struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Graph string `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryJob) Descriptor deprecated

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

Deprecated: Use QueryJob.ProtoReflect.Descriptor instead.

func (*QueryJob) GetGraph

func (x *QueryJob) GetGraph() string

func (*QueryJob) GetId

func (x *QueryJob) GetId() string

func (*QueryJob) ProtoMessage

func (*QueryJob) ProtoMessage()

func (*QueryJob) ProtoReflect

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

func (*QueryJob) Reset

func (x *QueryJob) Reset()

func (*QueryJob) String

func (x *QueryJob) String() string

type QueryResult

type QueryResult struct {

	// Types that are assignable to Result:
	//
	//	*QueryResult_Vertex
	//	*QueryResult_Edge
	//	*QueryResult_Aggregations
	//	*QueryResult_Selections
	//	*QueryResult_Render
	//	*QueryResult_Count
	//	*QueryResult_Path
	Result isQueryResult_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*QueryResult) Descriptor deprecated

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

Deprecated: Use QueryResult.ProtoReflect.Descriptor instead.

func (*QueryResult) GetAggregations

func (x *QueryResult) GetAggregations() *NamedAggregationResult

func (*QueryResult) GetCount

func (x *QueryResult) GetCount() uint32

func (*QueryResult) GetEdge

func (x *QueryResult) GetEdge() *Edge

func (*QueryResult) GetPath

func (x *QueryResult) GetPath() *structpb.ListValue

func (*QueryResult) GetRender

func (x *QueryResult) GetRender() *structpb.Value

func (*QueryResult) GetResult

func (m *QueryResult) GetResult() isQueryResult_Result

func (*QueryResult) GetSelections

func (x *QueryResult) GetSelections() *Selections

func (*QueryResult) GetVertex

func (x *QueryResult) GetVertex() *Vertex

func (*QueryResult) ProtoMessage

func (*QueryResult) ProtoMessage()

func (*QueryResult) ProtoReflect

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

func (*QueryResult) Reset

func (x *QueryResult) Reset()

func (*QueryResult) String

func (x *QueryResult) String() string

type QueryResult_Aggregations

type QueryResult_Aggregations struct {
	Aggregations *NamedAggregationResult `protobuf:"bytes,3,opt,name=aggregations,proto3,oneof"`
}

type QueryResult_Count

type QueryResult_Count struct {
	Count uint32 `protobuf:"varint,6,opt,name=count,proto3,oneof"`
}

type QueryResult_Edge

type QueryResult_Edge struct {
	Edge *Edge `protobuf:"bytes,2,opt,name=edge,proto3,oneof"`
}

type QueryResult_Path

type QueryResult_Path struct {
	Path *structpb.ListValue `protobuf:"bytes,7,opt,name=path,proto3,oneof"`
}

type QueryResult_Render

type QueryResult_Render struct {
	Render *structpb.Value `protobuf:"bytes,5,opt,name=render,proto3,oneof"`
}

type QueryResult_Selections

type QueryResult_Selections struct {
	Selections *Selections `protobuf:"bytes,4,opt,name=selections,proto3,oneof"`
}

type QueryResult_Vertex

type QueryResult_Vertex struct {
	Vertex *Vertex `protobuf:"bytes,1,opt,name=vertex,proto3,oneof"`
}

type QueryServer

type QueryServer interface {
	Traversal(*GraphQuery, Query_TraversalServer) error
	GetVertex(context.Context, *ElementID) (*Vertex, error)
	GetEdge(context.Context, *ElementID) (*Edge, error)
	GetTimestamp(context.Context, *GraphID) (*Timestamp, error)
	GetSchema(context.Context, *GraphID) (*Graph, error)
	GetMapping(context.Context, *GraphID) (*Graph, error)
	ListGraphs(context.Context, *Empty) (*ListGraphsResponse, error)
	ListIndices(context.Context, *GraphID) (*ListIndicesResponse, error)
	ListLabels(context.Context, *GraphID) (*ListLabelsResponse, error)
	ListTables(*Empty, Query_ListTablesServer) error
	// contains filtered or unexported methods
}

QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility

type QuerySet

type QuerySet struct {
	Query []*GraphStatement `protobuf:"bytes,1,rep,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*QuerySet) Descriptor deprecated

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

Deprecated: Use QuerySet.ProtoReflect.Descriptor instead.

func (*QuerySet) GetQuery

func (x *QuerySet) GetQuery() []*GraphStatement

func (*QuerySet) ProtoMessage

func (*QuerySet) ProtoMessage()

func (*QuerySet) ProtoReflect

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

func (*QuerySet) Reset

func (x *QuerySet) Reset()

func (*QuerySet) String

func (x *QuerySet) String() string

type Query_ListTablesClient

type Query_ListTablesClient interface {
	Recv() (*TableInfo, error)
	grpc.ClientStream
}

type Query_ListTablesServer

type Query_ListTablesServer interface {
	Send(*TableInfo) error
	grpc.ServerStream
}

type Query_TraversalClient

type Query_TraversalClient interface {
	Recv() (*QueryResult, error)
	grpc.ClientStream
}

type Query_TraversalServer

type Query_TraversalServer interface {
	Send(*QueryResult) error
	grpc.ServerStream
}

type Range

type Range struct {
	Start int32 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	Stop  int32 `protobuf:"varint,2,opt,name=stop,proto3" json:"stop,omitempty"`
	// contains filtered or unexported fields
}

func (*Range) Descriptor deprecated

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

Deprecated: Use Range.ProtoReflect.Descriptor instead.

func (*Range) GetStart

func (x *Range) GetStart() int32

func (*Range) GetStop

func (x *Range) GetStop() int32

func (*Range) ProtoMessage

func (*Range) ProtoMessage()

func (*Range) ProtoReflect

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

func (*Range) Reset

func (x *Range) Reset()

func (*Range) String

func (x *Range) String() string

type SelectStatement

type SelectStatement struct {
	Marks []string `protobuf:"bytes,1,rep,name=marks,proto3" json:"marks,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectStatement) Descriptor deprecated

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

Deprecated: Use SelectStatement.ProtoReflect.Descriptor instead.

func (*SelectStatement) GetMarks

func (x *SelectStatement) GetMarks() []string

func (*SelectStatement) ProtoMessage

func (*SelectStatement) ProtoMessage()

func (*SelectStatement) ProtoReflect

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

func (*SelectStatement) Reset

func (x *SelectStatement) Reset()

func (*SelectStatement) String

func (x *SelectStatement) String() string

type Selection

type Selection struct {

	// Types that are assignable to Result:
	//
	//	*Selection_Vertex
	//	*Selection_Edge
	Result isSelection_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*Selection) Descriptor deprecated

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

Deprecated: Use Selection.ProtoReflect.Descriptor instead.

func (*Selection) GetEdge

func (x *Selection) GetEdge() *Edge

func (*Selection) GetResult

func (m *Selection) GetResult() isSelection_Result

func (*Selection) GetVertex

func (x *Selection) GetVertex() *Vertex

func (*Selection) ProtoMessage

func (*Selection) ProtoMessage()

func (*Selection) ProtoReflect

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

func (*Selection) Reset

func (x *Selection) Reset()

func (*Selection) String

func (x *Selection) String() string

type Selection_Edge

type Selection_Edge struct {
	Edge *Edge `protobuf:"bytes,2,opt,name=edge,proto3,oneof"`
}

type Selection_Vertex

type Selection_Vertex struct {
	Vertex *Vertex `protobuf:"bytes,1,opt,name=vertex,proto3,oneof"`
}

type Selections

type Selections struct {
	Selections map[string]*Selection `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Selections) Descriptor deprecated

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

Deprecated: Use Selections.ProtoReflect.Descriptor instead.

func (*Selections) GetSelections

func (x *Selections) GetSelections() map[string]*Selection

func (*Selections) ProtoMessage

func (*Selections) ProtoMessage()

func (*Selections) ProtoReflect

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

func (*Selections) Reset

func (x *Selections) Reset()

func (*Selections) String

func (x *Selections) String() string

type Set

type Set struct {
	Key   string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *structpb.Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Set) Descriptor deprecated

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

Deprecated: Use Set.ProtoReflect.Descriptor instead.

func (*Set) GetKey

func (x *Set) GetKey() string

func (*Set) GetValue

func (x *Set) GetValue() *structpb.Value

func (*Set) ProtoMessage

func (*Set) ProtoMessage()

func (*Set) ProtoReflect

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

func (*Set) Reset

func (x *Set) Reset()

func (*Set) String

func (x *Set) String() string

type TableInfo

type TableInfo struct {
	Source  string            `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Name    string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Fields  []string          `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	LinkMap map[string]string `` /* 170-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TableInfo) Descriptor deprecated

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

Deprecated: Use TableInfo.ProtoReflect.Descriptor instead.

func (*TableInfo) GetFields

func (x *TableInfo) GetFields() []string

func (*TableInfo) GetLinkMap

func (x *TableInfo) GetLinkMap() map[string]string

func (*TableInfo) GetName

func (x *TableInfo) GetName() string

func (*TableInfo) GetSource

func (x *TableInfo) GetSource() string

func (*TableInfo) ProtoMessage

func (*TableInfo) ProtoMessage()

func (*TableInfo) ProtoReflect

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

func (*TableInfo) Reset

func (x *TableInfo) Reset()

func (*TableInfo) String

func (x *TableInfo) String() string

type TermAggregation

type TermAggregation struct {
	Field string `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	Size  uint32 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*TermAggregation) Descriptor deprecated

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

Deprecated: Use TermAggregation.ProtoReflect.Descriptor instead.

func (*TermAggregation) GetField

func (x *TermAggregation) GetField() string

func (*TermAggregation) GetSize

func (x *TermAggregation) GetSize() uint32

func (*TermAggregation) ProtoMessage

func (*TermAggregation) ProtoMessage()

func (*TermAggregation) ProtoReflect

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

func (*TermAggregation) Reset

func (x *TermAggregation) Reset()

func (*TermAggregation) String

func (x *TermAggregation) String() string

type Timestamp

type Timestamp struct {
	Timestamp string `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Timestamp) Descriptor deprecated

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

Deprecated: Use Timestamp.ProtoReflect.Descriptor instead.

func (*Timestamp) GetTimestamp

func (x *Timestamp) GetTimestamp() string

func (*Timestamp) ProtoMessage

func (*Timestamp) ProtoMessage()

func (*Timestamp) ProtoReflect

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

func (*Timestamp) Reset

func (x *Timestamp) Reset()

func (*Timestamp) String

func (x *Timestamp) String() string

type TypeAggregation

type TypeAggregation struct {
	Field string `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*TypeAggregation) Descriptor deprecated

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

Deprecated: Use TypeAggregation.ProtoReflect.Descriptor instead.

func (*TypeAggregation) GetField

func (x *TypeAggregation) GetField() string

func (*TypeAggregation) ProtoMessage

func (*TypeAggregation) ProtoMessage()

func (*TypeAggregation) ProtoReflect

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

func (*TypeAggregation) Reset

func (x *TypeAggregation) Reset()

func (*TypeAggregation) String

func (x *TypeAggregation) String() string

type UnimplementedConfigureServer

type UnimplementedConfigureServer struct {
}

UnimplementedConfigureServer must be embedded to have forward compatible implementations.

func (UnimplementedConfigureServer) ListDrivers

func (UnimplementedConfigureServer) ListPlugins

func (UnimplementedConfigureServer) StartPlugin

type UnimplementedEditServer

type UnimplementedEditServer struct {
}

UnimplementedEditServer must be embedded to have forward compatible implementations.

func (UnimplementedEditServer) AddEdge

func (UnimplementedEditServer) AddGraph

func (UnimplementedEditServer) AddIndex

func (UnimplementedEditServer) AddMapping

func (UnimplementedEditServer) AddSchema

func (UnimplementedEditServer) AddVertex

func (UnimplementedEditServer) BulkAdd

func (UnimplementedEditServer) DeleteEdge

func (UnimplementedEditServer) DeleteGraph

func (UnimplementedEditServer) DeleteIndex

func (UnimplementedEditServer) DeleteVertex

func (UnimplementedEditServer) SampleSchema

type UnimplementedJobServer

type UnimplementedJobServer struct {
}

UnimplementedJobServer must be embedded to have forward compatible implementations.

func (UnimplementedJobServer) DeleteJob

func (UnimplementedJobServer) GetJob

func (UnimplementedJobServer) ListJobs

func (UnimplementedJobServer) ResumeJob

func (UnimplementedJobServer) SearchJobs

func (UnimplementedJobServer) Submit

func (UnimplementedJobServer) ViewJob

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer must be embedded to have forward compatible implementations.

func (UnimplementedQueryServer) GetEdge

func (UnimplementedQueryServer) GetMapping

func (UnimplementedQueryServer) GetSchema

func (UnimplementedQueryServer) GetTimestamp

func (UnimplementedQueryServer) GetVertex

func (UnimplementedQueryServer) ListGraphs

func (UnimplementedQueryServer) ListIndices

func (UnimplementedQueryServer) ListLabels

func (UnimplementedQueryServer) ListTables

func (UnimplementedQueryServer) Traversal

type UnsafeConfigureServer

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

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

type UnsafeEditServer

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

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

type UnsafeJobServer

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

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

type UnsafeQueryServer

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

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

type Vertex

type Vertex struct {
	Gid   string           `protobuf:"bytes,1,opt,name=gid,proto3" json:"gid,omitempty"`
	Label string           `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Data  *structpb.Struct `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Vertex) Descriptor deprecated

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

Deprecated: Use Vertex.ProtoReflect.Descriptor instead.

func (*Vertex) GetData

func (x *Vertex) GetData() *structpb.Struct

func (*Vertex) GetDataMap

func (vertex *Vertex) GetDataMap() map[string]interface{}

GetDataMap obtains data attached to vertex in the form of a map

func (*Vertex) GetGid

func (x *Vertex) GetGid() string

func (*Vertex) GetLabel

func (x *Vertex) GetLabel() string

func (*Vertex) GetProperty

func (vertex *Vertex) GetProperty(key string) interface{}

GetProperty get named field from vertex data

func (*Vertex) HasProperty

func (vertex *Vertex) HasProperty(key string) bool

HasProperty returns true is field is defined

func (*Vertex) ProtoMessage

func (*Vertex) ProtoMessage()

func (*Vertex) ProtoReflect

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

func (*Vertex) Reset

func (x *Vertex) Reset()

func (*Vertex) SetDataMap

func (vertex *Vertex) SetDataMap(i map[string]interface{})

SetDataMap obtains data attached to vertex in the form of a map

func (*Vertex) SetProperty

func (vertex *Vertex) SetProperty(key string, value interface{})

SetProperty sets named field in Vertex data

func (*Vertex) String

func (x *Vertex) String() string

func (*Vertex) Validate

func (vertex *Vertex) Validate() error

Validate returns an error if the vertex is invalid

Directories

Path Synopsis
Code generated for package gripqljs by go-bindata DO NOT EDIT.
Code generated for package gripqljs by go-bindata DO NOT EDIT.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL