aggregate

Documentation

Overview

_       _

*__ _____ __ ___ ___ __ _| |_ ___ *\ \ /\ / / _ \/ _` \ \ / / |/ _` | __/ _ \ * \ V V / __/ (_| |\ V /| | (_| | || __/ * \_/\_/ \___|\__,_| \_/ |_|\__,_|\__\___| * * Copyright © 2016 - 2019 Weaviate. All rights reserved. * LICENSE: https://github.com/creativesoftwarefdn/weaviate/blob/develop/LICENSE.md * DESIGN & CONCEPT: Bob van Luijt (@bobvanluijt) * CONTACT: hello@creativesoftwarefdn.org

_       _

*__ _____ __ ___ ___ __ _| |_ ___ *\ \ /\ / / _ \/ _` \ \ / / |/ _` | __/ _ \ * \ V V / __/ (_| |\ V /| | (_| | || __/ * \_/\_/ \___|\__,_| \_/ |_|\__,_|\__\___| * * Copyright © 2016 - 2019 Weaviate. All rights reserved. * LICENSE: https://github.com/creativesoftwarefdn/weaviate/blob/develop/LICENSE.md * DESIGN & CONCEPT: Bob van Luijt (@bobvanluijt) * CONTACT: hello@creativesoftwarefdn.org

_       _

*__ _____ __ ___ ___ __ _| |_ ___ *\ \ /\ / / _ \/ _` \ \ / / |/ _` | __/ _ \ * \ V V / __/ (_| |\ V /| | (_| | || __/ * \_/\_/ \___|\__,_| \_/ |_|\__,_|\__\___| * * Copyright © 2016 - 2019 Weaviate. All rights reserved. * LICENSE: https://github.com/creativesoftwarefdn/weaviate/blob/develop/LICENSE.md * DESIGN & CONCEPT: Bob van Luijt (@bobvanluijt) * CONTACT: hello@creativesoftwarefdn.org

Index

• type Processor
  • func NewProcessor(executor executor) *Processor
  • func (p *Processor) Process(query *gremlin.Query, groupBy *common_filters.Path) (interface{}, error)
• type Query
  • func NewQuery(params *aggregate.Params, nameSource nameSource, typeSource typeSource, ...) *Query
  • func (b *Query) String() (string, error)

Types

type Processor

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

Processor is a simple Gremlin-Query Executor that is specific to GetMeta in that it merges the results into the expected format and applies post-processing where necessary

func NewProcessor

func NewProcessor(executor executor) *Processor

NewProcessor of type Processor

func (*Processor) Process

func (p *Processor) Process(query *gremlin.Query, groupBy *common_filters.Path) (interface{}, error)

Process the query (i.e. execute it), then post-process it, i.e. transform the structure we get from janusgraph into the structure we need for the graphQL API

type Query

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

func NewQuery

func NewQuery(params *aggregate.Params, nameSource nameSource, typeSource typeSource,
	filterSource filterSource) *Query

func (*Query) String

func (b *Query) String() (string, error)