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: 9

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 

func (Condition) Type() protoreflect.EnumType

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 

func (FieldType) Type() protoreflect.EnumType

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 

func (JobState) Type() protoreflect.EnumType

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) ListDrivers(context.Context, *Empty) (*ListDriversResponse, error)

func (UnimplementedConfigureServer) ListPlugins 

func (UnimplementedConfigureServer) ListPlugins(context.Context, *Empty) (*ListPluginsResponse, error)

func (UnimplementedConfigureServer) StartPlugin 

func (UnimplementedConfigureServer) StartPlugin(context.Context, *PluginConfig) (*PluginStatus, error)

type UnimplementedEditServer 

type UnimplementedEditServer struct {
}

UnimplementedEditServer must be embedded to have forward compatible implementations.

func (UnimplementedEditServer) AddEdge 

func (UnimplementedEditServer) AddEdge(context.Context, *GraphElement) (*EditResult, error)

func (UnimplementedEditServer) AddGraph 

func (UnimplementedEditServer) AddGraph(context.Context, *GraphID) (*EditResult, error)

func (UnimplementedEditServer) AddIndex 

func (UnimplementedEditServer) AddIndex(context.Context, *IndexID) (*EditResult, error)

func (UnimplementedEditServer) AddMapping 

func (UnimplementedEditServer) AddMapping(context.Context, *Graph) (*EditResult, error)

func (UnimplementedEditServer) AddSchema 

func (UnimplementedEditServer) AddSchema(context.Context, *Graph) (*EditResult, error)

func (UnimplementedEditServer) AddVertex 

func (UnimplementedEditServer) AddVertex(context.Context, *GraphElement) (*EditResult, error)

func (UnimplementedEditServer) BulkAdd 

func (UnimplementedEditServer) BulkAdd(Edit_BulkAddServer) error

func (UnimplementedEditServer) DeleteEdge 

func (UnimplementedEditServer) DeleteEdge(context.Context, *ElementID) (*EditResult, error)

func (UnimplementedEditServer) DeleteGraph 

func (UnimplementedEditServer) DeleteGraph(context.Context, *GraphID) (*EditResult, error)

func (UnimplementedEditServer) DeleteIndex 

func (UnimplementedEditServer) DeleteIndex(context.Context, *IndexID) (*EditResult, error)

func (UnimplementedEditServer) DeleteVertex 

func (UnimplementedEditServer) DeleteVertex(context.Context, *ElementID) (*EditResult, error)

func (UnimplementedEditServer) SampleSchema 

func (UnimplementedEditServer) SampleSchema(context.Context, *GraphID) (*Graph, error)

type UnimplementedJobServer 

type UnimplementedJobServer struct {
}

UnimplementedJobServer must be embedded to have forward compatible implementations.

func (UnimplementedJobServer) DeleteJob 

func (UnimplementedJobServer) DeleteJob(context.Context, *QueryJob) (*JobStatus, error)

func (UnimplementedJobServer) GetJob 

func (UnimplementedJobServer) GetJob(context.Context, *QueryJob) (*JobStatus, error)

func (UnimplementedJobServer) ListJobs 

func (UnimplementedJobServer) ListJobs(*GraphID, Job_ListJobsServer) error

func (UnimplementedJobServer) ResumeJob 

func (UnimplementedJobServer) ResumeJob(*ExtendQuery, Job_ResumeJobServer) error

func (UnimplementedJobServer) SearchJobs 

func (UnimplementedJobServer) SearchJobs(*GraphQuery, Job_SearchJobsServer) error

func (UnimplementedJobServer) Submit 

func (UnimplementedJobServer) Submit(context.Context, *GraphQuery) (*QueryJob, error)

func (UnimplementedJobServer) ViewJob 

func (UnimplementedJobServer) ViewJob(*QueryJob, Job_ViewJobServer) error

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer must be embedded to have forward compatible implementations.

func (UnimplementedQueryServer) GetEdge 

func (UnimplementedQueryServer) GetEdge(context.Context, *ElementID) (*Edge, error)

func (UnimplementedQueryServer) GetMapping 

func (UnimplementedQueryServer) GetMapping(context.Context, *GraphID) (*Graph, error)

func (UnimplementedQueryServer) GetSchema 

func (UnimplementedQueryServer) GetSchema(context.Context, *GraphID) (*Graph, error)

func (UnimplementedQueryServer) GetTimestamp 

func (UnimplementedQueryServer) GetTimestamp(context.Context, *GraphID) (*Timestamp, error)

func (UnimplementedQueryServer) GetVertex 

func (UnimplementedQueryServer) GetVertex(context.Context, *ElementID) (*Vertex, error)

func (UnimplementedQueryServer) ListGraphs 

func (UnimplementedQueryServer) ListGraphs(context.Context, *Empty) (*ListGraphsResponse, error)

func (UnimplementedQueryServer) ListIndices 

func (UnimplementedQueryServer) ListIndices(context.Context, *GraphID) (*ListIndicesResponse, error)

func (UnimplementedQueryServer) ListLabels 

func (UnimplementedQueryServer) ListLabels(context.Context, *GraphID) (*ListLabelsResponse, error)

func (UnimplementedQueryServer) ListTables 

func (UnimplementedQueryServer) ListTables(*Empty, Query_ListTablesServer) error

func (UnimplementedQueryServer) Traversal 

func (UnimplementedQueryServer) Traversal(*GraphQuery, Query_TraversalServer) error

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

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.