query

package
v0.8.3 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2017 License: AGPL-3.0, Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrEmptyVal = errors.New("query: harmless error, e.g. task.Val is nil")
	ErrWrongAgg = errors.New("Wrong level for var aggregation.")
)
View Source 
var ErrFacet = x.Errorf("Skip the edge")
View Source 
var ErrStop = x.Errorf("STOP")
View Source 
var ErrTooBig = x.Errorf("Query exceeded memory limit. Please modify the query")
View Source 
var MutationNotAllowedErr = x.Errorf("Mutations are forbidden on this server.")

Functions

func ApplyMutations added in v0.8.2 

func ApplyMutations(ctx context.Context, m *protos.Mutations) error

func AssignUids added in v0.8.2 

func AssignUids(ctx context.Context, nquads gql.NQuads) (map[string]uint64, error)

func ConvertUidsToHex added in v0.8.2 

func ConvertUidsToHex(m map[string]uint64) (res map[string]string)

convert the new UIDs to hex string.

func GetAllPredicates added in v0.8.2 

func GetAllPredicates(subGraphs []*SubGraph) (predicates []string)

func ProcessGraph 

func ProcessGraph(ctx context.Context, sg, parent *SubGraph, rch chan error)

ProcessGraph processes the SubGraph instance accumulating result for the query from different instances. Note: taskQuery is nil for root node.

func Recurse added in v0.8.2 

func Recurse(ctx context.Context, sg *SubGraph) error

func StripBlankNode added in v0.8.2 

func StripBlankNode(mp map[string]uint64) map[string]uint64

func ToJson added in v0.7.2 

func ToJson(l *Latency, sgl []*SubGraph, w io.Writer, allocIds map[string]string,
	addLatency bool) error

ToJson converts the list of subgraph into a JSON response by calling toFastJSON.

func ToProtocolBuf added in v0.7.2 

func ToProtocolBuf(l *Latency, sgl []*SubGraph) ([]*protos.Node, error)

ToProtocolBuf returns the list of protos.Node which would be returned to the go client.

Types

type Codec added in v0.4.3 

type Codec struct{}

Codec implements the custom codec interface.

func (*Codec) Marshal added in v0.4.3 

func (c *Codec) Marshal(v interface{}) ([]byte, error)

Marshal release the protos.Node pointers after marshalling the response.

func (*Codec) String added in v0.4.3 

func (c *Codec) String() string

func (*Codec) Unmarshal added in v0.4.3 

func (c *Codec) Unmarshal(data []byte, v interface{}) error

Unmarshal constructs protos.Request from the byte slice.

type ExecuteResult added in v0.8.2 

type ExecuteResult struct {
	Subgraphs   []*SubGraph
	SchemaNode  []*protos.SchemaNode
	Allocations map[string]uint64 // Blank node => uid map returned for a mutation request.
}

type Extensions added in v0.8.2 

type Extensions struct {
	Latency map[string]string `json:"server_latency"`
}

type Function added in v0.8.2 

type Function struct {
	Name       string    // Specifies the name of the function.
	Args       []gql.Arg // Contains the arguments of the function.
	IsCount    bool      // gt(count(friends),0)
	IsValueVar bool      // eq(val(s), 10)
}

Function holds the information about gql functions.

type InternalError added in v0.8.2 

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

func (*InternalError) Error added in v0.8.2 

func (e *InternalError) Error() string

type InternalMutation added in v0.8.2 

type InternalMutation struct {
	Edges []*protos.DirectedEdge
}

func ToInternal added in v0.8.2 

func ToInternal(ctx context.Context,
	nquads gql.NQuads,
	vars map[string]varValue, newUids map[string]uint64) (InternalMutation, error)

func (*InternalMutation) AddEdge added in v0.8.2 

func (mr *InternalMutation) AddEdge(edge *protos.DirectedEdge, op protos.DirectedEdge_Op)

type InvalidRequestError added in v0.8.2 

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

func (*InvalidRequestError) Error added in v0.8.2 

func (e *InvalidRequestError) Error() string

type Item added in v0.7.3 

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

type Latency 

type Latency struct {
	Start          time.Time     `json:"-"`
	Parsing        time.Duration `json:"query_parsing"`
	Processing     time.Duration `json:"processing"`
	Json           time.Duration `json:"json_conversion"`
	ProtocolBuffer time.Duration `json:"pb_conversion"`
}

Latency is used to keep track of the latency involved in parsing and processing the query. It also contains information about the time it took to convert the result into a format(JSON/Protocol Buffer) that the client expects.

func (*Latency) ToMap 

func (l *Latency) ToMap() map[string]string

ToMap converts the latency object to a map.

type QueryRequest added in v0.8.2 

type QueryRequest struct {
	Latency  *Latency
	GqlQuery *gql.Result

	Subgraphs []*SubGraph

	SchemaUpdate []*protos.SchemaUpdate
	// contains filtered or unexported fields
}

QueryRequest wraps the state that is used when executing query. Initially Latency and GqlQuery needs to be set. Subgraphs, Vars and schemaUpdate are filled when processing query.

func (*QueryRequest) ProcessQuery added in v0.8.2 

func (req *QueryRequest) ProcessQuery(ctx context.Context) (map[string]uint64, error)

ProcessQuery processes query part of the request (without mutations). Fills Subgraphs and Vars. It optionally also returns a map of the allocated uids in case of an upsert request.

func (*QueryRequest) ProcessWithMutation added in v0.8.2 

func (qr *QueryRequest) ProcessWithMutation(ctx context.Context) (er ExecuteResult, err error)

type SubGraph 

type SubGraph struct {
	Attr   string
	Params params

	ExpandPreds []*protos.ValueList
	GroupbyRes  *groupResults

	// SrcUIDs is a list of unique source UIDs. They are always copies of destUIDs
	// of parent nodes in GraphQL structure.
	SrcUIDs *protos.List
	SrcFunc *Function

	FilterOp string
	Filters  []*SubGraph

	MathExp  *mathTree
	Children []*SubGraph

	// destUIDs is a list of destination UIDs, after applying filters, pagination.
	DestUIDs *protos.List
	// contains filtered or unexported fields
}

SubGraph is the way to represent data internally. It contains both the query and the response. Once generated, this can then be encoded to other client convenient formats, like GraphQL / JSON.

func KShortestPath added in v0.8.2 

func KShortestPath(ctx context.Context, sg *SubGraph) ([]*SubGraph, error)

func ShortestPath added in v0.7.3 

func ShortestPath(ctx context.Context, sg *SubGraph) ([]*SubGraph, error)

func ToSubGraph 

func ToSubGraph(ctx context.Context, gq *gql.GraphQuery) (*SubGraph, error)

ToSubGraph converts the GraphQuery into the internal SubGraph instance type.

func (*SubGraph) ApplyIneqFunc added in v0.8.2 

func (sg *SubGraph) ApplyIneqFunc() error

func (*SubGraph) DebugPrint added in v0.7.0 

func (sg *SubGraph) DebugPrint(prefix string)

DebugPrint prints out the SubGraph tree in a nice format for debugging purposes.

func (*SubGraph) IsGroupBy added in v0.8.2 

func (sg *SubGraph) IsGroupBy() bool

func (*SubGraph) IsInternal added in v0.8.2 

func (sg *SubGraph) IsInternal() bool

func (*SubGraph) ToProtocolBuffer 

func (sg *SubGraph) ToProtocolBuffer(l *Latency) (*protos.Node, error)

ToProtocolBuffer does preorder traversal to build a proto buffer. We have used postorder traversal before, but preorder seems simpler and faster for most cases.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.