fragments

package
v0.3.0 Latest Latest
Warning

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

Go to latest
Published: Aug 31, 2022 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

View Source
const FRAGMENT_SIZE = 100

FRAGMENT_SIZE of the fragments returned

View Source
const FragmentDocType = "fragment"

FragmentDocType is the ElasticSearch doctype for the Fragment

View Source
const FragmentGraphDocType = "graph"

FragmentGraphDocType is the ElasticSearch doctype for the FragmentGraph

View Source
const RDFType = "http://www.w3.org/1999/02/22-rdf-syntax-ns#type"

RDFType is the URI for RDF:type

Variables

View Source
var (
	ResponseFormatType_name = map[int32]string{
		0: "JSON",
		1: "PROTOBUF",
		2: "XML",
		3: "JSONP",
		4: "KML",
		5: "GEOCLUSTER",
		6: "GEOJSON",
		7: "GEOBUF",
		8: "LDJSON",
		9: "BULKACTION",
	}
	ResponseFormatType_value = map[string]int32{
		"JSON":       0,
		"PROTOBUF":   1,
		"XML":        2,
		"JSONP":      3,
		"KML":        4,
		"GEOCLUSTER": 5,
		"GEOJSON":    6,
		"GEOBUF":     7,
		"LDJSON":     8,
		"BULKACTION": 9,
	}
)

Enum value maps for ResponseFormatType.

View Source
var (
	ItemFormatType_name = map[int32]string{
		0: "SUMMARY",
		1: "FRAGMENTGRAPH",
		2: "GROUPED",
		3: "JSONLD",
		4: "FLAT",
		5: "TREE",
	}
	ItemFormatType_value = map[string]int32{
		"SUMMARY":       0,
		"FRAGMENTGRAPH": 1,
		"GROUPED":       2,
		"JSONLD":        3,
		"FLAT":          4,
		"TREE":          5,
	}
)

Enum value maps for ItemFormatType.

View Source
var (
	ResponseBlockType_name = map[int32]string{
		0: "QUERY",
		1: "ITEMS",
		2: "FACETS",
		3: "LAYOUT",
		4: "PAGINATION",
	}
	ResponseBlockType_value = map[string]int32{
		"QUERY":      0,
		"ITEMS":      1,
		"FACETS":     2,
		"LAYOUT":     3,
		"PAGINATION": 4,
	}
)

Enum value maps for ResponseBlockType.

View Source
var (
	FacetType_name = map[int32]string{
		0: "TERMS",
		1: "HISTOGRAM",
		2: "MINMAX",
		3: "TREEFACET",
		4: "TAGS",
		5: "METATAGS",
		6: "FIELDS",
	}
	FacetType_value = map[string]int32{
		"TERMS":     0,
		"HISTOGRAM": 1,
		"MINMAX":    2,
		"TREEFACET": 3,
		"TAGS":      4,
		"METATAGS":  5,
		"FIELDS":    6,
	}
)

Enum value maps for FacetType.

View Source
var (
	QueryFilterType_name = map[int32]string{
		0: "TEXT",
		1: "ID",
		2: "EXCLUDE",
		3: "EXISTS",
		4: "RANGE",
		5: "DATERANGE",
		6: "ISODATE",
		7: "TREEITEM",
		8: "ENTRYTAG",
		9: "SEARCHLABEL",
	}
	QueryFilterType_value = map[string]int32{
		"TEXT":        0,
		"ID":          1,
		"EXCLUDE":     2,
		"EXISTS":      3,
		"RANGE":       4,
		"DATERANGE":   5,
		"ISODATE":     6,
		"TREEITEM":    7,
		"ENTRYTAG":    8,
		"SEARCHLABEL": 9,
	}
)

Enum value maps for QueryFilterType.

View Source
var (
	GeoType_name = map[int32]string{
		0: "BBOX",
		1: "GEOFILT",
		2: "CLUSTER",
	}
	GeoType_value = map[string]int32{
		"BBOX":    0,
		"GEOFILT": 1,
		"CLUSTER": 2,
	}
)

Enum value maps for GeoType.

View Source
var (
	IdType_name = map[int32]string{
		0: "HUDID",
		1: "IDCI",
		2: "NAMEDGRAPH",
	}
	IdType_value = map[string]int32{
		"HUDID":      0,
		"IDCI":       1,
		"NAMEDGRAPH": 2,
	}
)

Enum value maps for IdType.

View Source
var (
	RecordType_name = map[int32]string{
		0: "NARTHEX",
		1: "SCHEMA",
		2: "VOCABULARY",
		3: "SOURCE",
		4: "CACHE",
	}
	RecordType_value = map[string]int32{
		"NARTHEX":    0,
		"SCHEMA":     1,
		"VOCABULARY": 2,
		"SOURCE":     3,
		"CACHE":      4,
	}
)

Enum value maps for RecordType.

View Source
var (
	DataSetType_name = map[int32]string{
		0: "SINGLE",
		1: "MULTIPLE",
		2: "BYQUERY",
	}
	DataSetType_value = map[string]int32{
		"SINGLE":   0,
		"MULTIPLE": 1,
		"BYQUERY":  2,
	}
)

Enum value maps for DataSetType.

View Source
var (
	ResultType_name = map[int32]string{
		0: "GRID",
		1: "TABLE",
		2: "MAP",
		3: "ARCHIVE",
	}
	ResultType_value = map[string]int32{
		"GRID":    0,
		"TABLE":   1,
		"MAP":     2,
		"ARCHIVE": 3,
	}
)

Enum value maps for ResultType.

View Source
var (
	FieldType_name = map[int32]string{
		0: "LITERAL",
		1: "RESOURCE",
		2: "DATE",
		3: "POINT",
		4: "DIGITAL_OBJECT",
		5: "MANIFEST",
	}
	FieldType_value = map[string]int32{
		"LITERAL":        0,
		"RESOURCE":       1,
		"DATE":           2,
		"POINT":          3,
		"DIGITAL_OBJECT": 4,
		"MANIFEST":       5,
	}
)

Enum value maps for FieldType.

View Source
var (
	InlineType_name = map[int32]string{
		0: "NONE",
		4: "URI_ONLY",
		1: "LABEL",
		2: "MODAL",
		3: "INLINE_DETAIL_BLOCK",
	}
	InlineType_value = map[string]int32{
		"NONE":                0,
		"URI_ONLY":            4,
		"LABEL":               1,
		"MODAL":               2,
		"INLINE_DETAIL_BLOCK": 3,
	}
)

Enum value maps for InlineType.

View Source
var ESSettings = `` /* 191-byte string literal not displayed */

ESSettings are the default settings for a Hub3 index

View Source
var (
	ErrUrnNotFound = errors.New("remote urn not found")
)
View Source
var File_hub3_fragments_api_proto protoreflect.FileDescriptor
View Source
var File_hub3_fragments_viewconfig_proto protoreflect.FileDescriptor

Functions

func ConvertTriple

func ConvertTriple(triple rdf.Triple) *r.Triple

ConvertTriple converts a knakk/rdf Triple to a kiivihal/rdf2go Triple

func CreateAggregationBySearchLabel

func CreateAggregationBySearchLabel(path string, facet *FacetField, facetAndBoolType bool, fub *FacetURIBuilder) (elastic.Aggregation, error)

CreateAggregationBySearchLabel creates Elastic aggregations for the nested fragment resources

func CreateESAction

func CreateESAction(indexDoc map[string]interface{}, id, orgID string) (*elastic.BulkIndexRequest, error)

CreateESAction creates bulkAPIRequest from map[string]interface{}

func CreateHash

func CreateHash(input string) string

CreateHash creates an xxhash-based hash of a string

func CreateV1IndexDoc

func CreateV1IndexDoc(fb *FragmentBuilder, recordTypes ...string) (map[string]interface{}, error)

CreateV1IndexDoc creates a map that can me marshaled to json

func DecodeRDFXML

func DecodeRDFXML(r io.Reader) ([]rdf.Triple, error)

DecodeRDFXML parses RDF-XML into triples

func ExpandedIDs

func ExpandedIDs(node *Tree) map[string]bool

ExpandedIDs expands all the parent identifiers in a CLevel path and returns it as a map.

func GetEDMField

func GetEDMField(s string) r.Term

GetEDMField returns a rdf2go.Resource for a field

func GetFieldKey

func GetFieldKey(t *r.Triple) (string, error)

GetFieldKey returns the namespaced version of the Predicate of the Triple

func GetNSField

func GetNSField(nsKey, label string) string

GetNSField get as namespace field. It is a utility function

func GetNaveField

func GetNaveField(s string) r.Term

GetNaveField returns a rdf2go.Resource for a field

func IndexFragments

func IndexFragments(rm *ResourceMap, fg *FragmentGraph, bi BulkIndex) error

IndexFragments updates the Fragments for standalone indexing and adds them to the Elastic BulkProcessorService

func KeyAsString

func KeyAsString(b *elastic.AggregationBucketKeyItem) string

KeyAsString extracts the key as string from the elastic.AggregationBucketKeyItem.

func LastModified added in v0.3.0

func LastModified(millis int64) time.Time

LastModified converts millis into time.Time

func NewGraphFromTurtle

func NewGraphFromTurtle(re io.Reader) (*r.Graph, error)

NewGraphFromTurtle creates a RDF graph from the 'text/turtle' format

func NowInMillis

func NowInMillis() int64

NowInMillis returns time.Now() in miliseconds

func QueryFromSearchFields added in v0.1.4

func QueryFromSearchFields(query string, fields ...string) (elastic.Query, error)

func RDFBulkInsert

func RDFBulkInsert(orgID string, sparqlUpdates []SparqlUpdate) (int, []error)

func RandSeq

func RandSeq(n int) string

RandSeq returns a random string of letters with the size of 'n'

func SaveDataSet

func SaveDataSet(orgID, spec string, p *elastic.BulkProcessor) error

SaveDataSet creates a fragment entry for a Dataset

func TypeClassAsURI

func TypeClassAsURI(uri string) (string, error)

TypeClassAsURI resolves the type class formatted as "prefix_label" as fully qualified URI

func UpdateViaSparql

func UpdateViaSparql(orgID, update string) []error

UpdateViaSparql is a post to sparql function that tasks a valid SPARQL update query

Types

type BreadCrumb struct {
	Href           string `protobuf:"bytes,1,opt,name=href,proto3" json:"href,omitempty"`
	Display        string `protobuf:"bytes,2,opt,name=display,proto3" json:"display,omitempty"`
	Field          string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
	LocalisedField string `protobuf:"bytes,4,opt,name=localised_field,json=localisedField,proto3" json:"localised_field,omitempty"`
	Value          string `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	IsLast         bool   `protobuf:"varint,6,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"`
	// contains filtered or unexported fields
}
func (*BreadCrumb) Descriptor() ([]byte, []int)

Deprecated: Use BreadCrumb.ProtoReflect.Descriptor instead.

func (x *BreadCrumb) GetDisplay() string
func (x *BreadCrumb) GetField() string
func (x *BreadCrumb) GetHref() string
func (x *BreadCrumb) GetIsLast() bool
func (x *BreadCrumb) GetLocalisedField() string
func (x *BreadCrumb) GetValue() string
func (*BreadCrumb) ProtoMessage()
func (x *BreadCrumb) ProtoReflect() protoreflect.Message
func (x *BreadCrumb) Reset()
func (x *BreadCrumb) String() string
type BreadCrumbBuilder struct {
	// contains filtered or unexported fields
}

BreadCrumbBuilder is a struct that holds all the information to build a BreadCrumb trail

func (bcb *BreadCrumbBuilder) AppendBreadCrumb(param string, qf *QueryFilter)

AppendBreadCrumb creates a BreadCrumb

func (bcb *BreadCrumbBuilder) BreadCrumbs() []*BreadCrumb
func (bcb *BreadCrumbBuilder) GetLast() *BreadCrumb

GetLast returns the last BreadCrumb from the trail

func (bcb *BreadCrumbBuilder) GetPath() string

GetPath returns the path for the BreadCrumb

type BulkIndex added in v0.1.8

type BulkIndex interface {
	Publish(ctx context.Context, message ...*domainpb.IndexMessage) error
}

type BySortOrder added in v0.2.0

type BySortOrder []*FragmentResource

BySortOrder implements sort.Interface for []*FragmentResource based on the Order field in the first FragmentEntry.

func (BySortOrder) Len added in v0.2.0

func (a BySortOrder) Len() int

func (BySortOrder) Less added in v0.2.0

func (a BySortOrder) Less(i, j int) bool

func (BySortOrder) Swap added in v0.2.0

func (a BySortOrder) Swap(i, j int)

type CSVConvertor

type CSVConvertor struct {
	SubjectColumn         string    `json:"subjectColumn"`
	Separator             string    `json:"separator"`
	PredicateURIBase      string    `json:"predicateURIBase"`
	SubjectClass          string    `json:"subjectClass"`
	SubjectURIBase        string    `json:"subjectURIBase"`
	ObjectURIFormat       string    `json:"objectURIFormat"`
	ObjectResourceColumns []string  `json:"objectResourceColumns"`
	ObjectIntegerColumns  []string  `json:"objectIntegerColumns"`
	ThumbnailURIBase      string    `json:"thumbnailURIBase"`
	ThumbnailColumn       string    `json:"thumbnailColumn"`
	ManifestURIBase       string    `json:"manifestURIBase"`
	ManifestColumn        string    `json:"manifestColumn"`
	ManifestLocale        string    `json:"manifestLocale"`
	DefaultSpec           string    `json:"defaultSpec"`
	InputFile             io.Reader `json:"-"`
	RowsProcessed         int       `json:"rowsProcessed"`
	TriplesCreated        int       `json:"triplesCreated"`
	// contains filtered or unexported fields
}

CSVConvertor holds all values to convert a CSV to RDF

func NewCSVConvertor

func NewCSVConvertor(orgID string) *CSVConvertor

NewCSVConvertor creates a CSV convertor from an net/http Form

func (*CSVConvertor) Convert

func (con *CSVConvertor) Convert() (*ResourceMap, int, error)

Convert converts the CSV InputFile to an RDF ResourceMap

func (*CSVConvertor) CreateHeader

func (con *CSVConvertor) CreateHeader(row []string)

CreateHeader creates a map based on column id for the predicates

func (*CSVConvertor) CreateSubjectResource

func (con *CSVConvertor) CreateSubjectResource(subjectID string) (r.Term, *r.Triple)

CreateSubjectResource creates the Subject URI and type triple for the subject column

func (*CSVConvertor) CreateTriple

func (con *CSVConvertor) CreateTriple(subject r.Term, idx int, column string) *r.Triple

CreateTriple creates a rdf2go.Triple from the CSV column

func (*CSVConvertor) CreateTriples

func (con *CSVConvertor) CreateTriples() ([]*r.Triple, int, error)

CreateTriples converts a csv file to a list of Triples

func (*CSVConvertor) GetReader

func (con *CSVConvertor) GetReader() ([][]string, error)

GetReader returns a nested array of strings

func (*CSVConvertor) GetSubjectColumn

func (con *CSVConvertor) GetSubjectColumn(headers []string, columnLabel string) (int, error)

GetSubjectColumn returns the index of the subject column

func (CSVConvertor) HeaderMap

func (con CSVConvertor) HeaderMap() map[int]r.Term

HeaderMap gives access to a read-only version of the header map

func (*CSVConvertor) IndexFragments

func (con *CSVConvertor) IndexFragments(bi BulkIndex, revision int) (int, int, error)

IndexFragments stores the fragments generated from the CSV into ElasticSearch

type Cattr

type Cattr struct {
	XMLName            xml.Name            `xml:"attr,omitempty" json:"attr,omitempty"`
	Attrtag            string              `xml:"tag,attr"  json:",omitempty"`
	AttruriCheck       string              `xml:"uriCheck,attr"  json:",omitempty"`
	Cnode_dash_mapping *Cnode_dash_mapping `xml:"node-mapping,omitempty" json:"node-mapping,omitempty"`
}

// Generated structs for parsing the XML record definition

type Cattrs

type Cattrs struct {
	XMLName xml.Name `xml:"attrs,omitempty" json:"attrs,omitempty"`
	Cattr   []*Cattr `xml:"attr,omitempty" json:"attr,omitempty"`
}

type Cdoc

type Cdoc struct {
	XMLName  xml.Name `xml:"doc,omitempty" json:"doc,omitempty"`
	Attrpath string   `xml:"path,attr"  json:",omitempty"`
	Cpara    []*Cpara `xml:"para,omitempty" json:"para,omitempty"`
}

type Cdocs

type Cdocs struct {
	XMLName xml.Name `xml:"docs,omitempty" json:"docs,omitempty"`
	Cdoc    []*Cdoc  `xml:"doc,omitempty" json:"doc,omitempty"`
}

type Celem

type Celem struct {
	XMLName            xml.Name            `xml:"elem,omitempty" json:"elem,omitempty"`
	Attrattrs          string              `xml:"attrs,attr"  json:",omitempty"`
	Attrtag            string              `xml:"tag,attr"  json:",omitempty"`
	Cattr              []*Cattr            `xml:"attr,omitempty" json:"attr,omitempty"`
	Celem              []*Celem            `xml:"elem,omitempty" json:"elem,omitempty"`
	Cnode_dash_mapping *Cnode_dash_mapping `xml:"node-mapping,omitempty" json:"node-mapping,omitempty"`
}

type Cfield_dash_markers

type Cfield_dash_markers struct {
	XMLName xml.Name `xml:"field-markers,omitempty" json:"field-markers,omitempty"`
}

type Cfunctions

type Cfunctions struct {
	XMLName                xml.Name                  `xml:"functions,omitempty" json:"functions,omitempty"`
	Cmapping_dash_function []*Cmapping_dash_function `xml:"mapping-function,omitempty" json:"mapping-function,omitempty"`
}

type Cgroovy_dash_code

type Cgroovy_dash_code struct {
	XMLName xml.Name   `xml:"groovy-code,omitempty" json:"groovy-code,omitempty"`
	Cstring []*Cstring `xml:"string,omitempty" json:"string,omitempty"`
}

type Cmapping_dash_function

type Cmapping_dash_function struct {
	XMLName            xml.Name            `xml:"mapping-function,omitempty" json:"mapping-function,omitempty"`
	Attrname           string              `xml:"name,attr"  json:",omitempty"`
	Cgroovy_dash_code  *Cgroovy_dash_code  `xml:"groovy-code,omitempty" json:"groovy-code,omitempty"`
	Csample_dash_input *Csample_dash_input `xml:"sample-input,omitempty" json:"sample-input,omitempty"`
}

type Cnamespace

type Cnamespace struct {
	XMLName    xml.Name `xml:"namespace,omitempty" json:"namespace,omitempty"`
	Attrprefix string   `xml:"prefix,attr"  json:",omitempty"`
	Attruri    string   `xml:"uri,attr"  json:",omitempty"`
}

type Cnamespaces

type Cnamespaces struct {
	XMLName    xml.Name      `xml:"namespaces,omitempty" json:"namespaces,omitempty"`
	Cnamespace []*Cnamespace `xml:"namespace,omitempty" json:"namespace,omitempty"`
}

type Cnode_dash_mapping

type Cnode_dash_mapping struct {
	XMLName           xml.Name           `xml:"node-mapping,omitempty" json:"node-mapping,omitempty"`
	AttrinputPath     string             `xml:"inputPath,attr"  json:",omitempty"`
	AttroutputPath    string             `xml:"outputPath,attr"  json:",omitempty"`
	Cgroovy_dash_code *Cgroovy_dash_code `xml:"groovy-code,omitempty" json:"groovy-code,omitempty"`
}

type Collapsed

type Collapsed struct {
	Field    string           `json:"field"`
	Title    string           `json:"title"`
	HitCount int64            `json:"hitCount"`
	Items    []*FragmentGraph `json:"items"`
}

Collapsed holds each entry of a FieldCollapse elasticsearch result

type ContextQueryFilter

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

func (*ContextQueryFilter) Descriptor deprecated

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

Deprecated: Use ContextQueryFilter.ProtoReflect.Descriptor instead.

func (*ContextQueryFilter) GetSearchLabel

func (x *ContextQueryFilter) GetSearchLabel() string

func (*ContextQueryFilter) GetTypeClass

func (x *ContextQueryFilter) GetTypeClass() string

func (*ContextQueryFilter) ProtoMessage

func (*ContextQueryFilter) ProtoMessage()

func (*ContextQueryFilter) ProtoReflect added in v0.1.8

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

func (*ContextQueryFilter) Reset

func (x *ContextQueryFilter) Reset()

func (*ContextQueryFilter) String

func (x *ContextQueryFilter) String() string

type Copts

type Copts struct {
	XMLName xml.Name `xml:"opts,omitempty" json:"opts,omitempty"`
}

type Cpara

type Cpara struct {
	XMLName  xml.Name `xml:"para,omitempty" json:"para,omitempty"`
	Attrname string   `xml:"name,attr"  json:",omitempty"`
	// contains filtered or unexported fields
}

type Crecord_dash_definition

type Crecord_dash_definition struct {
	XMLName             xml.Name             `xml:"record-definition,omitempty" json:"record-definition,omitempty"`
	Attrflat            string               `xml:"flat,attr"  json:",omitempty"`
	Attrprefix          string               `xml:"prefix,attr"  json:",omitempty"`
	Attrversion         string               `xml:"version,attr"  json:",omitempty"`
	Cattrs              *Cattrs              `xml:"attrs,omitempty" json:"attrs,omitempty"`
	Cdocs               *Cdocs               `xml:"docs,omitempty" json:"docs,omitempty"`
	Cfield_dash_markers *Cfield_dash_markers `xml:"field-markers,omitempty" json:"field-markers,omitempty"`
	Cfunctions          *Cfunctions          `xml:"functions,omitempty" json:"functions,omitempty"`
	Cnamespaces         *Cnamespaces         `xml:"namespaces,omitempty" json:"namespaces,omitempty"`
	Copts               *Copts               `xml:"opts,omitempty" json:"opts,omitempty"`
	Croot               *Croot               `xml:"root,omitempty" json:"root,omitempty"`
}

func NewRecDef

func NewRecDef(r io.Reader) (*Crecord_dash_definition, error)

NewRecDef takes a []byte and creates a record definition

type Croot

type Croot struct {
	XMLName            xml.Name            `xml:"root,omitempty" json:"root,omitempty"`
	Attrtag            string              `xml:"tag,attr"  json:",omitempty"`
	Celem              []*Celem            `xml:"elem,omitempty" json:"elem,omitempty"`
	Cnode_dash_mapping *Cnode_dash_mapping `xml:"node-mapping,omitempty" json:"node-mapping,omitempty"`
}

type Csample_dash_input

type Csample_dash_input struct {
	XMLName xml.Name   `xml:"sample-input,omitempty" json:"sample-input,omitempty"`
	Cstring []*Cstring `xml:"string,omitempty" json:"string,omitempty"`
}

type Cstring

type Cstring struct {
	XMLName xml.Name `xml:"string,omitempty" json:"string,omitempty"`
	// contains filtered or unexported fields
}

type DataSetConfig

type DataSetConfig struct {
	ID           string            `protobuf:"bytes,11,opt,name=ID,proto3" json:"ID,omitempty"`
	Title        string            `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Markdown     string            `protobuf:"bytes,2,opt,name=markdown,proto3" json:"markdown,omitempty"`
	DataSetType  DataSetType       `protobuf:"varint,3,opt,name=dataSetType,proto3,enum=fragments.DataSetType" json:"dataSetType,omitempty"`
	Facets       []*FacetField     `protobuf:"bytes,4,rep,name=facets,proto3" json:"facets,omitempty"`
	Spec         []string          `protobuf:"bytes,5,rep,name=spec,proto3" json:"spec,omitempty"`
	ExcludeSpec  []string          `protobuf:"bytes,10,rep,name=excludeSpec,proto3" json:"excludeSpec,omitempty"`
	ViewConfig   *DetailViewConfig `protobuf:"bytes,6,opt,name=viewConfig,proto3" json:"viewConfig,omitempty"`
	ResultConfig *ResultViewConfig `protobuf:"bytes,7,opt,name=resultConfig,proto3" json:"resultConfig,omitempty"`
	Filter       *DataSetFilter    `protobuf:"bytes,8,opt,name=filter,proto3" json:"filter,omitempty"`
	OrgID        string            `protobuf:"bytes,9,opt,name=orgID,proto3" json:"orgID,omitempty"`
	// contains filtered or unexported fields
}

func (*DataSetConfig) Descriptor deprecated

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

Deprecated: Use DataSetConfig.ProtoReflect.Descriptor instead.

func (*DataSetConfig) GetDataSetType

func (x *DataSetConfig) GetDataSetType() DataSetType

func (*DataSetConfig) GetExcludeSpec

func (x *DataSetConfig) GetExcludeSpec() []string

func (*DataSetConfig) GetFacets

func (x *DataSetConfig) GetFacets() []*FacetField

func (*DataSetConfig) GetFilter

func (x *DataSetConfig) GetFilter() *DataSetFilter

func (*DataSetConfig) GetID

func (x *DataSetConfig) GetID() string

func (*DataSetConfig) GetMarkdown

func (x *DataSetConfig) GetMarkdown() string

func (*DataSetConfig) GetOrgID

func (x *DataSetConfig) GetOrgID() string

func (*DataSetConfig) GetResultConfig

func (x *DataSetConfig) GetResultConfig() *ResultViewConfig

func (*DataSetConfig) GetSpec

func (x *DataSetConfig) GetSpec() []string

func (*DataSetConfig) GetTitle

func (x *DataSetConfig) GetTitle() string

func (*DataSetConfig) GetViewConfig

func (x *DataSetConfig) GetViewConfig() *DetailViewConfig

func (*DataSetConfig) ProtoMessage

func (*DataSetConfig) ProtoMessage()

func (*DataSetConfig) ProtoReflect added in v0.1.8

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

func (*DataSetConfig) Reset

func (x *DataSetConfig) Reset()

func (*DataSetConfig) String

func (x *DataSetConfig) String() string

type DataSetFilter

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

func (*DataSetFilter) Descriptor deprecated

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

Deprecated: Use DataSetFilter.ProtoReflect.Descriptor instead.

func (*DataSetFilter) GetQuery

func (x *DataSetFilter) GetQuery() string

func (*DataSetFilter) GetQueryFilter

func (x *DataSetFilter) GetQueryFilter() []*QueryFilter

func (*DataSetFilter) ProtoMessage

func (*DataSetFilter) ProtoMessage()

func (*DataSetFilter) ProtoReflect added in v0.1.8

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

func (*DataSetFilter) Reset

func (x *DataSetFilter) Reset()

func (*DataSetFilter) String

func (x *DataSetFilter) String() string

type DataSetType

type DataSetType int32
const (
	DataSetType_SINGLE   DataSetType = 0
	DataSetType_MULTIPLE DataSetType = 1
	DataSetType_BYQUERY  DataSetType = 2
)

func (DataSetType) Descriptor added in v0.1.8

func (DataSetType) Enum added in v0.1.8

func (x DataSetType) Enum() *DataSetType

func (DataSetType) EnumDescriptor deprecated

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

Deprecated: Use DataSetType.Descriptor instead.

func (DataSetType) Number added in v0.1.8

func (x DataSetType) Number() protoreflect.EnumNumber

func (DataSetType) String

func (x DataSetType) String() string

func (DataSetType) Type added in v0.1.8

type DetailBlock

type DetailBlock struct {
	I18NLabel     *I18NLabel           `protobuf:"bytes,1,opt,name=i18nLabel,proto3" json:"i18nLabel,omitempty"`
	ResourceLabel string               `protobuf:"bytes,2,opt,name=resourceLabel,proto3" json:"resourceLabel,omitempty"` // label of link
	Order         int32                `protobuf:"varint,3,opt,name=order,proto3" json:"order,omitempty"`
	ResourceType  string               `protobuf:"bytes,4,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	Fields        []*PresentationField `protobuf:"bytes,5,rep,name=fields,proto3" json:"fields,omitempty"`
	InlineCSS     string               `protobuf:"bytes,6,opt,name=inlineCSS,proto3" json:"inlineCSS,omitempty"`
	// contains filtered or unexported fields
}

func (*DetailBlock) Descriptor deprecated

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

Deprecated: Use DetailBlock.ProtoReflect.Descriptor instead.

func (*DetailBlock) GetFields

func (x *DetailBlock) GetFields() []*PresentationField

func (*DetailBlock) GetI18NLabel

func (x *DetailBlock) GetI18NLabel() *I18NLabel

func (*DetailBlock) GetInlineCSS

func (x *DetailBlock) GetInlineCSS() string

func (*DetailBlock) GetOrder

func (x *DetailBlock) GetOrder() int32

func (*DetailBlock) GetResourceLabel

func (x *DetailBlock) GetResourceLabel() string

func (*DetailBlock) GetResourceType

func (x *DetailBlock) GetResourceType() string

func (*DetailBlock) ProtoMessage

func (*DetailBlock) ProtoMessage()

func (*DetailBlock) ProtoReflect added in v0.1.8

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

func (*DetailBlock) Reset

func (x *DetailBlock) Reset()

func (*DetailBlock) String

func (x *DetailBlock) String() string

type DetailRequest

type DetailRequest struct {

	// option: any valid identifier specified by the idType
	// description: Will output a full-view. Default idType is hubId taken from the delving_hubId field.
	Id             string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Mlt            bool               `protobuf:"varint,2,opt,name=mlt,proto3" json:"mlt,omitempty"`
	Format         ResponseFormatType `protobuf:"varint,3,opt,name=format,proto3,enum=fragments.ResponseFormatType" json:"format,omitempty"`
	MltCount       int32              `protobuf:"varint,4,opt,name=mltCount,proto3" json:"mltCount,omitempty"`
	MltQueryFilter string             `protobuf:"bytes,5,opt,name=mltQueryFilter,proto3" json:"mltQueryFilter,omitempty"`
	MltFilterKey   string             `protobuf:"bytes,6,opt,name=mltFilterKey,proto3" json:"mltFilterKey,omitempty"`
	// searchRequest is a serialised form of the search result and is the return
	// to results link
	SearchRequest string `protobuf:"bytes,7,opt,name=searchRequest,proto3" json:"searchRequest,omitempty"`
	// resultIndex is the point where this detail object is in the search result order
	ResultIndex int32 `protobuf:"varint,8,opt,name=resultIndex,proto3" json:"resultIndex,omitempty"`
	// converter for result fields
	Converter string `protobuf:"bytes,9,opt,name=converter,proto3" json:"converter,omitempty"`
	// the type of id used in the ?id field
	IdType IdType `protobuf:"varint,10,opt,name=idType,proto3,enum=fragments.IdType" json:"idType,omitempty"`
	// contains filtered or unexported fields
}

func (*DetailRequest) Descriptor deprecated

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

Deprecated: Use DetailRequest.ProtoReflect.Descriptor instead.

func (*DetailRequest) GetConverter

func (x *DetailRequest) GetConverter() string

func (*DetailRequest) GetFormat

func (x *DetailRequest) GetFormat() ResponseFormatType

func (*DetailRequest) GetId

func (x *DetailRequest) GetId() string

func (*DetailRequest) GetIdType

func (x *DetailRequest) GetIdType() IdType

func (*DetailRequest) GetMlt

func (x *DetailRequest) GetMlt() bool

func (*DetailRequest) GetMltCount

func (x *DetailRequest) GetMltCount() int32

func (*DetailRequest) GetMltFilterKey

func (x *DetailRequest) GetMltFilterKey() string

func (*DetailRequest) GetMltQueryFilter

func (x *DetailRequest) GetMltQueryFilter() string

func (*DetailRequest) GetResultIndex

func (x *DetailRequest) GetResultIndex() int32

func (*DetailRequest) GetSearchRequest

func (x *DetailRequest) GetSearchRequest() string

func (*DetailRequest) ProtoMessage

func (*DetailRequest) ProtoMessage()

func (*DetailRequest) ProtoReflect added in v0.1.8

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

func (*DetailRequest) Reset

func (x *DetailRequest) Reset()

func (*DetailRequest) String

func (x *DetailRequest) String() string

type DetailResult

type DetailResult struct {
	Item *MetadataItemV1 `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

The structure of the detail page

func (*DetailResult) Descriptor deprecated

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

Deprecated: Use DetailResult.ProtoReflect.Descriptor instead.

func (*DetailResult) GetItem

func (x *DetailResult) GetItem() *MetadataItemV1

func (*DetailResult) ProtoMessage

func (*DetailResult) ProtoMessage()

func (*DetailResult) ProtoReflect added in v0.1.8

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

func (*DetailResult) Reset

func (x *DetailResult) Reset()

func (*DetailResult) String

func (x *DetailResult) String() string

type DetailViewConfig

type DetailViewConfig struct {
	Blocks    []*DetailBlock `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	EntryType string         `protobuf:"bytes,2,opt,name=entryType,proto3" json:"entryType,omitempty"`
	// contains filtered or unexported fields
}

func (*DetailViewConfig) Descriptor deprecated

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

Deprecated: Use DetailViewConfig.ProtoReflect.Descriptor instead.

func (*DetailViewConfig) GetBlocks

func (x *DetailViewConfig) GetBlocks() []*DetailBlock

func (*DetailViewConfig) GetEntryType

func (x *DetailViewConfig) GetEntryType() string

func (*DetailViewConfig) ProtoMessage

func (*DetailViewConfig) ProtoMessage()

func (*DetailViewConfig) ProtoReflect added in v0.1.8

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

func (*DetailViewConfig) Reset

func (x *DetailViewConfig) Reset()

func (*DetailViewConfig) String

func (x *DetailViewConfig) String() string
type FaceLink struct {
	Url           string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	IsSelected    bool   `protobuf:"varint,2,opt,name=isSelected,proto3" json:"isSelected,omitempty"`
	Value         string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Count         int32  `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	DisplayString string `protobuf:"bytes,5,opt,name=displayString,proto3" json:"displayString,omitempty"`
	// contains filtered or unexported fields
}

func (*FaceLink) Descriptor deprecated

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

Deprecated: Use FaceLink.ProtoReflect.Descriptor instead.

func (*FaceLink) GetCount

func (x *FaceLink) GetCount() int32

func (*FaceLink) GetDisplayString

func (x *FaceLink) GetDisplayString() string

func (*FaceLink) GetIsSelected

func (x *FaceLink) GetIsSelected() bool

func (*FaceLink) GetUrl

func (x *FaceLink) GetUrl() string

func (*FaceLink) GetValue

func (x *FaceLink) GetValue() string

func (*FaceLink) ProtoMessage

func (*FaceLink) ProtoMessage()

func (*FaceLink) ProtoReflect added in v0.1.8

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

func (*FaceLink) Reset

func (x *FaceLink) Reset()

func (*FaceLink) String

func (x *FaceLink) String() string

type Facet

type Facet struct {
	Name        string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IsSelected  bool        `protobuf:"varint,2,opt,name=isSelected,proto3" json:"isSelected,omitempty"`
	I18N        string      `protobuf:"bytes,3,opt,name=i18n,proto3" json:"i18n,omitempty"`
	Total       int32       `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
	MissingDocs int32       `protobuf:"varint,5,opt,name=missingDocs,proto3" json:"missingDocs,omitempty"`
	OtherDocs   int32       `protobuf:"varint,6,opt,name=otherDocs,proto3" json:"otherDocs,omitempty"`
	Links       []*FaceLink `protobuf:"bytes,7,rep,name=links,proto3" json:"links,omitempty"`
	// contains filtered or unexported fields
}

func (*Facet) Descriptor deprecated

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

Deprecated: Use Facet.ProtoReflect.Descriptor instead.

func (*Facet) GetI18N

func (x *Facet) GetI18N() string

func (*Facet) GetIsSelected

func (x *Facet) GetIsSelected() bool
func (x *Facet) GetLinks() []*FaceLink

func (*Facet) GetMissingDocs

func (x *Facet) GetMissingDocs() int32

func (*Facet) GetName

func (x *Facet) GetName() string

func (*Facet) GetOtherDocs

func (x *Facet) GetOtherDocs() int32

func (*Facet) GetTotal

func (x *Facet) GetTotal() int32

func (*Facet) ProtoMessage

func (*Facet) ProtoMessage()

func (*Facet) ProtoReflect added in v0.1.8

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

func (*Facet) Reset

func (x *Facet) Reset()

func (*Facet) String

func (x *Facet) String() string

type FacetField

type FacetField struct {
	Field        string    `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Asc          bool      `protobuf:"varint,2,opt,name=asc,proto3" json:"asc,omitempty"`
	ByName       bool      `protobuf:"varint,3,opt,name=byName,proto3" json:"byName,omitempty"`
	Size         int32     `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	ById         bool      `protobuf:"varint,5,opt,name=byId,proto3" json:"byId,omitempty"`
	Name         string    `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Type         FacetType `protobuf:"varint,7,opt,name=type,proto3,enum=fragments.FacetType" json:"type,omitempty"`
	DateInterval string    `protobuf:"bytes,8,opt,name=dateInterval,proto3" json:"dateInterval,omitempty"`
	AggField     string    `protobuf:"bytes,9,opt,name=aggField,proto3" json:"aggField,omitempty"`
	// contains filtered or unexported fields
}

func NewFacetField

func NewFacetField(field string) (*FacetField, error)

NewFacetField parses the QueryString and creates a FacetField

func (*FacetField) Descriptor deprecated

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

Deprecated: Use FacetField.ProtoReflect.Descriptor instead.

func (*FacetField) GetAggField

func (x *FacetField) GetAggField() string

func (*FacetField) GetAsc

func (x *FacetField) GetAsc() bool

func (*FacetField) GetById

func (x *FacetField) GetById() bool

func (*FacetField) GetByName

func (x *FacetField) GetByName() bool

func (*FacetField) GetDateInterval

func (x *FacetField) GetDateInterval() string

func (*FacetField) GetField

func (x *FacetField) GetField() string

func (*FacetField) GetName

func (x *FacetField) GetName() string

func (*FacetField) GetSize

func (x *FacetField) GetSize() int32

func (*FacetField) GetType

func (x *FacetField) GetType() FacetType

func (*FacetField) ProtoMessage

func (*FacetField) ProtoMessage()

func (*FacetField) ProtoReflect added in v0.1.8

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

func (*FacetField) Reset

func (x *FacetField) Reset()

func (*FacetField) String

func (x *FacetField) String() string
type FacetLink struct {
	URL           string `json:"url"`
	IsSelected    bool   `json:"isSelected"`
	Value         string `json:"value"`
	DisplayString string `json:"displayString"`
	Count         int64  `json:"count"`
}

FacetLink contains all the information for creating a filter for this facet

type FacetType

type FacetType int32
const (
	FacetType_TERMS     FacetType = 0
	FacetType_HISTOGRAM FacetType = 1
	FacetType_MINMAX    FacetType = 2
	FacetType_TREEFACET FacetType = 3
	FacetType_TAGS      FacetType = 4
	FacetType_METATAGS  FacetType = 5
	FacetType_FIELDS    FacetType = 6
)

func (FacetType) Descriptor added in v0.1.8

func (FacetType) Descriptor() protoreflect.EnumDescriptor

func (FacetType) Enum added in v0.1.8

func (x FacetType) Enum() *FacetType

func (FacetType) EnumDescriptor deprecated

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

Deprecated: Use FacetType.Descriptor instead.

func (FacetType) Number added in v0.1.8

func (x FacetType) Number() protoreflect.EnumNumber

func (FacetType) String

func (x FacetType) String() string

func (FacetType) Type added in v0.1.8

type FacetURIBuilder

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

FacetURIBuilder is used for creating facet filter fields TODO implement pop and push for creating facets links

func NewFacetURIBuilder

func NewFacetURIBuilder(query string, filters []*QueryFilter) (*FacetURIBuilder, error)

NewFacetURIBuilder creates a builder for Facet links

func (*FacetURIBuilder) AddFilter

func (fub *FacetURIBuilder) AddFilter(f *QueryFilter) error

AddFilter adds a QueryFilter to a multi dimensional map

func (FacetURIBuilder) CreateFacetFilterQuery

func (fub FacetURIBuilder) CreateFacetFilterQuery(filterField string, andQuery bool) (elastic.Query, error)

CreateFacetFilterQuery creates an elasticsearch Query to filter facets for the Facet Aggregation specified by 'filterfield'.

func (FacetURIBuilder) CreateFacetFilterURI

func (fub FacetURIBuilder) CreateFacetFilterURI(field, value string) (string, bool)

CreateFacetFilterURI generates a facetquery for each FacetLink and determines if it is selected

type FieldType

type FieldType int32
const (
	FieldType_LITERAL        FieldType = 0
	FieldType_RESOURCE       FieldType = 1
	FieldType_DATE           FieldType = 2
	FieldType_POINT          FieldType = 3
	FieldType_DIGITAL_OBJECT FieldType = 4
	FieldType_MANIFEST       FieldType = 5
)

func (FieldType) Descriptor added in v0.1.8

func (FieldType) Descriptor() protoreflect.EnumDescriptor

func (FieldType) Enum added in v0.1.8

func (x FieldType) Enum() *FieldType

func (FieldType) EnumDescriptor deprecated

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

Deprecated: Use FieldType.Descriptor instead.

func (FieldType) Number added in v0.1.8

func (x FieldType) Number() protoreflect.EnumNumber

func (FieldType) String

func (x FieldType) String() string

func (FieldType) Type added in v0.1.8

type FilterValue

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

func (*FilterValue) Descriptor deprecated

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

Deprecated: Use FilterValue.ProtoReflect.Descriptor instead.

func (*FilterValue) GetValue

func (x *FilterValue) GetValue() []string

func (*FilterValue) ProtoMessage

func (*FilterValue) ProtoMessage()

func (*FilterValue) ProtoReflect added in v0.1.8

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

func (*FilterValue) Reset

func (x *FilterValue) Reset()

func (*FilterValue) String

func (x *FilterValue) String() string

type Fragment

type Fragment struct {

	// Generic Header for all ElasticSearch records
	Meta *Header `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// RDF core
	// URI of the Triple subject
	Subject string `protobuf:"bytes,7,opt,name=subject,proto3" json:"subject,omitempty"`
	// URI of the Triple predicate
	Predicate string `protobuf:"bytes,8,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// An underscore delimited version of the namespace and the label of the URI
	// This is used in the Search DSL, for example dc:title becomes dc_title
	SearchLabel string `protobuf:"bytes,9,opt,name=searchLabel,proto3" json:"searchLabel,omitempty"`
	// The triple object. Can be both literal or resource (including Blank Nodes)
	Object string `protobuf:"bytes,10,opt,name=object,proto3" json:"object,omitempty"`
	// ISO 693 represenation of language code
	Language string `protobuf:"bytes,11,opt,name=language,proto3" json:"language,omitempty"`
	// Human readable version of the xsd:dataType
	DataType string `protobuf:"bytes,12,opt,name=dataType,proto3" json:"dataType,omitempty"`
	// The n-triples representation of the triple. Used to quickly render
	// RDF from a FragmentQuery
	Triple string `protobuf:"bytes,13,opt,name=triple,proto3" json:"triple,omitempty"`
	// the type of the object
	ObjectType string `protobuf:"bytes,14,opt,name=objectType,proto3" json:"objectType,omitempty"`
	// the relative key that is used to resolve a SPARQL describe for a Subject
	LodKey string `protobuf:"bytes,15,opt,name=lodKey,proto3" json:"lodKey,omitempty"`
	// path is used for generating statistics. It is repeated because @type, @lang
	// and @xsd:type must be added in addition to the normal fields.
	Path []string `protobuf:"bytes,16,rep,name=path,proto3" json:"path,omitempty"`
	// nestedPath is used for generating statistics with the graph path.
	// It is repeated because @type, @lang and @xsd:type must be added in addition to the normal fields.
	NestedPath []string `protobuf:"bytes,20,rep,name=nestedPath,proto3" json:"nestedPath,omitempty"`
	// order is the insert order of the source of the fragments
	Order int32 `protobuf:"varint,17,opt,name=order,proto3" json:"order,omitempty"`
	// resourceType is the RDF type of the resource
	ResourceType []string `protobuf:"bytes,18,rep,name=resourceType,proto3" json:"resourceType,omitempty"`
	// level shows the relative depth to the root RDF subject
	Level int32 `protobuf:"varint,19,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

Fragment are used and stored in ElasticSearch for the Linked Data Fragments API

func (Fragment) AddTo

func (f Fragment) AddTo(bi BulkIndex) error

AddTo adds the BulkableRequest to the Storage interface where it is flushed periodically.

func (*Fragment) CreateTriple

func (f *Fragment) CreateTriple() *r.Triple

CreateTriple creates a *rdf2go.Triple from a Fragment

func (*Fragment) Descriptor deprecated

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

Deprecated: Use Fragment.ProtoReflect.Descriptor instead.

func (*Fragment) GetDataType

func (x *Fragment) GetDataType() string

func (*Fragment) GetLanguage

func (x *Fragment) GetLanguage() string

func (*Fragment) GetLevel

func (x *Fragment) GetLevel() int32

func (*Fragment) GetLodKey

func (x *Fragment) GetLodKey() string

func (*Fragment) GetMeta

func (x *Fragment) GetMeta() *Header

func (*Fragment) GetNestedPath

func (x *Fragment) GetNestedPath() []string

func (*Fragment) GetObject

func (x *Fragment) GetObject() string

func (*Fragment) GetObjectType

func (x *Fragment) GetObjectType() string

func (*Fragment) GetOrder

func (x *Fragment) GetOrder() int32

func (*Fragment) GetPath

func (x *Fragment) GetPath() []string

func (*Fragment) GetPredicate

func (x *Fragment) GetPredicate() string

func (*Fragment) GetResourceType

func (x *Fragment) GetResourceType() []string

func (*Fragment) GetSearchLabel

func (x *Fragment) GetSearchLabel() string

func (*Fragment) GetSubject

func (x *Fragment) GetSubject() string

func (*Fragment) GetTriple

func (x *Fragment) GetTriple() string

func (*Fragment) ID

func (f *Fragment) ID() string

ID is the hashed identifier of the Fragment Quad field. This is used as identifier by the storage layer.

func (Fragment) IndexMessage added in v0.1.8

func (f Fragment) IndexMessage() (*domainpb.IndexMessage, error)

CreateBulkIndexRequest converts the fragment into a request that can be submitted to the ElasticSearch BulkIndexService

func (f Fragment) IsTypeLink() bool

IsTypeLink checks if the Predicate is a RDF type link

func (*Fragment) ProtoMessage

func (*Fragment) ProtoMessage()

func (*Fragment) ProtoReflect added in v0.1.8

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

func (*Fragment) Quad

func (f *Fragment) Quad() string

Quad returns a RDF Quad from the Fragment

func (*Fragment) Reset

func (x *Fragment) Reset()

func (*Fragment) SetPath

func (f *Fragment) SetPath(contextPath string)

SetPath sets the full context path for the Fragment that can be used for statistics aggregations.

func (*Fragment) String

func (x *Fragment) String() string

type FragmentBuilder

type FragmentBuilder struct {
	Graph          *r.Graph
	ResourceLabels map[string]string
	// contains filtered or unexported fields
}

FragmentBuilder holds all the information to build and store Fragments

func NewFragmentBuilder

func NewFragmentBuilder(fg *FragmentGraph) *FragmentBuilder

NewFragmentBuilder creates a new instance of the FragmentBuilder

func (*FragmentBuilder) AddDefaults

func (fb *FragmentBuilder) AddDefaults(wr r.Term, s r.Term, g *r.Graph)

AddDefaults add default thumbnail fields to a edm:WebResource

func (*FragmentBuilder) ByPredicate added in v0.3.0

func (fb *FragmentBuilder) ByPredicate(predicate r.Term) []*r.Triple

ByPredicate returns a list of triples that have the same predicate

func (*FragmentBuilder) CleanWebResourceGraph

func (fb *FragmentBuilder) CleanWebResourceGraph(hasUrns bool) (
	sortedResources []ResourceSortOrder,
	aggregates []r.Term,
	webTriples *WebTriples,
)

CleanWebResourceGraph remove mapped webresources when urns are used for WebResource Subjects

func (*FragmentBuilder) CreateV1IndexEntry

func (fb *FragmentBuilder) CreateV1IndexEntry(t *r.Triple) (*IndexEntry, error)

CreateV1IndexEntry creates an IndexEntry from a r.Triple

func (*FragmentBuilder) Doc

func (fb *FragmentBuilder) Doc() *FragmentGraph

Doc is a helper function to return an index document

func (*FragmentBuilder) FragmentGraph

func (fb *FragmentBuilder) FragmentGraph() *FragmentGraph

FragmentGraph gives access to the FragmentGraph object from the Builder struct

func (*FragmentBuilder) GetObject

func (fb *FragmentBuilder) GetObject(s r.Term, p r.Term) r.Term

GetObject returns a single object from the rdf2go.Graph

func (*FragmentBuilder) GetRDF

func (fb *FragmentBuilder) GetRDF() ([]byte, error)

GetRDF returns a byte Array for the Flat JSON-LD serialized RDF

func (*FragmentBuilder) GetRemoteWebResource

func (fb *FragmentBuilder) GetRemoteWebResource(urn string, orgID string) (rdf io.ReadCloser, err error)

GetRemoteWebResource retrieves a remote Graph from the MediaManare and inserts it into the Graph

func (*FragmentBuilder) GetResourceLabel

func (fb *FragmentBuilder) GetResourceLabel(t *r.Triple) (string, bool)

GetResourceLabel returns the label for a resource

func (*FragmentBuilder) GetSortedWebResources

func (fb *FragmentBuilder) GetSortedWebResources(ctx context.Context) []ResourceSortOrder

GetSortedWebResources returns a list of subjects sorted by nave:resourceSortOrder. WebResources without a sortKey will appended in order they are found to the end of the list.

func (*FragmentBuilder) GetUrns

func (fb *FragmentBuilder) GetUrns() []string

GetUrns returs a list of WebResource urns

func (*FragmentBuilder) IndexFragments

func (fb *FragmentBuilder) IndexFragments(bi BulkIndex) error

IndexFragments updates the Fragments for standalone indexing and adds them to the Elastic BulkProcessorService

func (*FragmentBuilder) IsDomainExternal

func (fb *FragmentBuilder) IsDomainExternal(obj string) (bool, error)

IsDomainExternal checks if the object link points to another domain

func (*FragmentBuilder) IsGraphExternal

func (fb *FragmentBuilder) IsGraphExternal(obj r.Term) bool

IsGraphExternal checks if the object link points outside the current graph

func (*FragmentBuilder) MediaManagerURL

func (fb *FragmentBuilder) MediaManagerURL(urn string, orgID string) string

MediaManagerURL returns the URL for the Remote WebResource call.

func (*FragmentBuilder) ParseGraph

func (fb *FragmentBuilder) ParseGraph(rdf io.Reader, mimeType string) error

ParseGraph creates a RDF2Go Graph

func (*FragmentBuilder) ResolveWebResources

func (fb *FragmentBuilder) ResolveWebResources(ctx context.Context) error

ResolveWebResources retrieves RDF graph from remote MediaManager Only RDF Resources that start with 'urn:' are currently supported

func (*FragmentBuilder) ResourceMap

func (fb *FragmentBuilder) ResourceMap() (*ResourceMap, error)

ResourceMap returns a *ResourceMap for the Graph in the FragmentBuilder

func (*FragmentBuilder) SetResourceLabels

func (fb *FragmentBuilder) SetResourceLabels() error

SetResourceLabels extracts resource labels from the graph which is used for presenting labels for Triple.Object instances that are resources.

type FragmentEntry

type FragmentEntry struct {
	ID        string `json:"@id,omitempty"`
	Value     string `json:"@value,omitempty"`
	Language  string `json:"@language,omitempty"`
	DataType  string `json:"@type,omitempty"`
	EntryType string `json:"entrytype"`
	Triple    string `json:"triple"`
	Resolved  bool   `json:"resolved"`
	Order     int    `json:"order"`
}

FragmentEntry holds all the information for the object of a rdf2go.Triple

func CreateFragmentEntry

func CreateFragmentEntry(t *r.Triple, resolved bool, order int) (*FragmentEntry, string)

CreateFragmentEntry creates a FragmentEntry from a triple

func (*FragmentEntry) AsLdObject

func (fe *FragmentEntry) AsLdObject() *r.LdObject

AsLdObject generates an rdf2go.LdObject for JSON-LD generation

func (*FragmentEntry) GetXSDLabel

func (fe *FragmentEntry) GetXSDLabel() string

GetXSDLabel returns a namespaced label for the RDF datatype

func (*FragmentEntry) NewResourceEntry

func (fe *FragmentEntry) NewResourceEntry(predicate string, level int32, rm *ResourceMap) (*ResourceEntry, error)

NewResourceEntry creates a resource entry for indexing

type FragmentEntryDoc

type FragmentEntryDoc struct {
	ID          string               `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Value       string               `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	Language    string               `protobuf:"bytes,3,opt,name=Language,proto3" json:"Language,omitempty"`
	Datatype    string               `protobuf:"bytes,4,opt,name=Datatype,proto3" json:"Datatype,omitempty"`
	Entrytype   string               `protobuf:"bytes,5,opt,name=Entrytype,proto3" json:"Entrytype,omitempty"`
	Triple      string               `protobuf:"bytes,6,opt,name=Triple,proto3" json:"Triple,omitempty"`
	Inline      *FragmentResourceDoc `protobuf:"bytes,7,opt,name=Inline,proto3" json:"Inline,omitempty"`
	Predicate   string               `protobuf:"bytes,8,opt,name=Predicate,proto3" json:"Predicate,omitempty"`
	SearchLabel string               `protobuf:"bytes,9,opt,name=SearchLabel,proto3" json:"SearchLabel,omitempty"`
	Tags        []string             `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"` // Content Index
	// contains filtered or unexported fields
}

func (*FragmentEntryDoc) Descriptor deprecated

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

Deprecated: Use FragmentEntryDoc.ProtoReflect.Descriptor instead.

func (*FragmentEntryDoc) GetDatatype

func (x *FragmentEntryDoc) GetDatatype() string

func (*FragmentEntryDoc) GetEntrytype

func (x *FragmentEntryDoc) GetEntrytype() string

func (*FragmentEntryDoc) GetID

func (x *FragmentEntryDoc) GetID() string

func (*FragmentEntryDoc) GetInline

func (x *FragmentEntryDoc) GetInline() *FragmentResourceDoc

func (*FragmentEntryDoc) GetLanguage

func (x *FragmentEntryDoc) GetLanguage() string

func (*FragmentEntryDoc) GetPredicate

func (x *FragmentEntryDoc) GetPredicate() string

func (*FragmentEntryDoc) GetSearchLabel

func (x *FragmentEntryDoc) GetSearchLabel() string

func (*FragmentEntryDoc) GetTags

func (x *FragmentEntryDoc) GetTags() []string

func (*FragmentEntryDoc) GetTriple

func (x *FragmentEntryDoc) GetTriple() string

func (*FragmentEntryDoc) GetValue

func (x *FragmentEntryDoc) GetValue() string

func (*FragmentEntryDoc) ProtoMessage

func (*FragmentEntryDoc) ProtoMessage()

func (*FragmentEntryDoc) ProtoReflect added in v0.1.8

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

func (*FragmentEntryDoc) Reset

func (x *FragmentEntryDoc) Reset()

func (*FragmentEntryDoc) String

func (x *FragmentEntryDoc) String() string

type FragmentError

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

func (*FragmentError) Descriptor deprecated

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

Deprecated: Use FragmentError.ProtoReflect.Descriptor instead.

func (*FragmentError) ProtoMessage

func (*FragmentError) ProtoMessage()

func (*FragmentError) ProtoReflect added in v0.1.8

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

func (*FragmentError) Reset

func (x *FragmentError) Reset()

func (*FragmentError) String

func (x *FragmentError) String() string

type FragmentGraph

type FragmentGraph struct {
	Meta       *Header                   `json:"meta,omitempty"`
	Tree       *Tree                     `json:"tree,omitempty"`
	Resources  []*FragmentResource       `json:"resources,omitempty"`
	Summary    *ResultSummary            `json:"summary,omitempty"`
	JSONLD     []map[string]interface{}  `json:"jsonld,omitempty"`
	Fields     map[string][]string       `json:"fields,omitempty"`
	Highlights []*ResourceEntryHighlight `json:"highlights,omitempty"`
	ProtoBuf   *ProtoBuf                 `json:"protobuf,omitempty"`
}

FragmentGraph is a container for all entries of an RDF Named Graph

func NewFragmentGraph

func NewFragmentGraph() *FragmentGraph

NewFragmentGraph creates a new instance of FragmentGraph

func (*FragmentGraph) CreateHeader

func (fg *FragmentGraph) CreateHeader(docType string) *Header

CreateHeader Linked Data Fragment entry for ElasticSearch as described here: http://linkeddatafragments.org/.

The goal of this document is to support Linked Data Fragments based resolving for all stored RDF triples in the Hub3 system.

func (*FragmentGraph) GetAboutURI

func (fg *FragmentGraph) GetAboutURI() string

GetAboutURI returns the subject of the FragmentGraph

func (*FragmentGraph) Graph added in v0.3.0

func (fg *FragmentGraph) Graph() (*rdf.Graph, error)

func (*FragmentGraph) IndexMessage added in v0.1.8

func (fg *FragmentGraph) IndexMessage() (*domainpb.IndexMessage, error)

func (*FragmentGraph) Marshal added in v0.1.8

func (fg *FragmentGraph) Marshal() ([]byte, error)

func (*FragmentGraph) NewFields

func (fg *FragmentGraph) NewFields(tq *memory.TextQuery, fields ...string) map[string][]string

NewFields returns a map of the triples sorted by their searchLabel

func (*FragmentGraph) NewGrouped

func (fg *FragmentGraph) NewGrouped() (*FragmentResource, error)

NewGrouped returns an inlined version of the FragmentResources in the FragmentGraph

func (*FragmentGraph) NewJSONLD

func (fg *FragmentGraph) NewJSONLD() []map[string]interface{}

NewJSONLD creates a JSON-LD version of the FragmentGraph

func (*FragmentGraph) NewResultSummary

func (fg *FragmentGraph) NewResultSummary() *ResultSummary

NewResultSummary creates a Summary from the FragmentGraph based on the RDFTag configuration.

func (*FragmentGraph) NewTree

func (fg *FragmentGraph) NewTree() *Tree

NewTree returns the output as navigation tree

func (*FragmentGraph) NormalisedResource

func (fg *FragmentGraph) NormalisedResource(uri string) string

NormalisedResource creates a unique BlankNode key Normal resources are returned as is.

This function is used so that you can query via the Fragment API for unique BlankNodes

func (*FragmentGraph) Reader added in v0.2.0

func (fg *FragmentGraph) Reader() (io.Reader, error)

func (*FragmentGraph) SetResources

func (fg *FragmentGraph) SetResources(rm *ResourceMap) *FragmentGraph

SetResources returns the struct of the FragmentGraph object that is converted to a fragmentDoc record in ElasticSearch

type FragmentGraphDoc

type FragmentGraphDoc struct {
	Meta          *Header    `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	EntryURI      string     `protobuf:"bytes,2,opt,name=entryURI,proto3" json:"entryURI,omitempty"`
	NamedGraphURI string     `protobuf:"bytes,3,opt,name=namedGraphURI,proto3" json:"namedGraphURI,omitempty"`
	RecordType    RecordType `protobuf:"varint,4,opt,name=recordType,proto3,enum=fragments.RecordType" json:"recordType,omitempty"`
	//repeated Fragment fragments = 5;
	Summary   []*ResultSummary       `protobuf:"bytes,6,rep,name=summary,proto3" json:"summary,omitempty"`
	Resources []*FragmentResourceDoc `protobuf:"bytes,7,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*FragmentGraphDoc) Descriptor deprecated

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

Deprecated: Use FragmentGraphDoc.ProtoReflect.Descriptor instead.

func (*FragmentGraphDoc) GetEntryURI

func (x *FragmentGraphDoc) GetEntryURI() string

func (*FragmentGraphDoc) GetMeta

func (x *FragmentGraphDoc) GetMeta() *Header

func (*FragmentGraphDoc) GetNamedGraphURI

func (x *FragmentGraphDoc) GetNamedGraphURI() string

func (*FragmentGraphDoc) GetRecordType

func (x *FragmentGraphDoc) GetRecordType() RecordType

func (*FragmentGraphDoc) GetResources

func (x *FragmentGraphDoc) GetResources() []*FragmentResourceDoc

func (*FragmentGraphDoc) GetSummary

func (x *FragmentGraphDoc) GetSummary() []*ResultSummary

func (*FragmentGraphDoc) ProtoMessage

func (*FragmentGraphDoc) ProtoMessage()

func (*FragmentGraphDoc) ProtoReflect added in v0.1.8

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

func (*FragmentGraphDoc) Reset

func (x *FragmentGraphDoc) Reset()

func (*FragmentGraphDoc) String

func (x *FragmentGraphDoc) String() string

type FragmentPager

type FragmentPager struct {
	FirstPage    []byte `protobuf:"bytes,1,opt,name=firstPage,proto3" json:"firstPage,omitempty"`
	PreviousPage []byte `protobuf:"bytes,2,opt,name=previousPage,proto3" json:"previousPage,omitempty"`
	CurrentPage  []byte `protobuf:"bytes,3,opt,name=currentPage,proto3" json:"currentPage,omitempty"`
	NextPage     []byte `protobuf:"bytes,4,opt,name=nextPage,proto3" json:"nextPage,omitempty"`
	// contains filtered or unexported fields
}

func (*FragmentPager) Descriptor deprecated

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

Deprecated: Use FragmentPager.ProtoReflect.Descriptor instead.

func (*FragmentPager) GetCurrentPage

func (x *FragmentPager) GetCurrentPage() []byte

func (*FragmentPager) GetFirstPage

func (x *FragmentPager) GetFirstPage() []byte

func (*FragmentPager) GetNextPage

func (x *FragmentPager) GetNextPage() []byte

func (*FragmentPager) GetPreviousPage

func (x *FragmentPager) GetPreviousPage() []byte

func (*FragmentPager) ProtoMessage

func (*FragmentPager) ProtoMessage()

func (*FragmentPager) ProtoReflect added in v0.1.8

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

func (*FragmentPager) Reset

func (x *FragmentPager) Reset()

func (*FragmentPager) String

func (x *FragmentPager) String() string

type FragmentReferrerContext

type FragmentReferrerContext struct {
	Subject      string   `protobuf:"bytes,1,opt,name=Subject,proto3" json:"Subject,omitempty"`
	SubjectClass []string `protobuf:"bytes,2,rep,name=SubjectClass,proto3" json:"SubjectClass,omitempty"`
	Predicate    string   `protobuf:"bytes,3,opt,name=Predicate,proto3" json:"Predicate,omitempty"`
	SearchLabel  string   `protobuf:"bytes,4,opt,name=SearchLabel,proto3" json:"SearchLabel,omitempty"`
	Level        int32    `protobuf:"varint,5,opt,name=Level,proto3" json:"Level,omitempty"`
	ObjectID     string   `protobuf:"bytes,6,opt,name=ObjectID,proto3" json:"ObjectID,omitempty"`
	SortKey      int32    `protobuf:"varint,7,opt,name=SortKey,proto3" json:"SortKey,omitempty"`
	Label        string   `protobuf:"bytes,8,opt,name=Label,proto3" json:"Label,omitempty"`
	// contains filtered or unexported fields
}

FragmentReferrerContext holds the referrer in formation for creating new fragments

func (*FragmentReferrerContext) Descriptor deprecated

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

Deprecated: Use FragmentReferrerContext.ProtoReflect.Descriptor instead.

func (*FragmentReferrerContext) GetLabel

func (x *FragmentReferrerContext) GetLabel() string

func (*FragmentReferrerContext) GetLevel

func (x *FragmentReferrerContext) GetLevel() int32

func (*FragmentReferrerContext) GetObjectID

func (x *FragmentReferrerContext) GetObjectID() string

func (*FragmentReferrerContext) GetPredicate

func (x *FragmentReferrerContext) GetPredicate() string

func (*FragmentReferrerContext) GetSearchLabel

func (x *FragmentReferrerContext) GetSearchLabel() string

func (*FragmentReferrerContext) GetSortKey

func (x *FragmentReferrerContext) GetSortKey() int32

func (*FragmentReferrerContext) GetSubject

func (x *FragmentReferrerContext) GetSubject() string

func (*FragmentReferrerContext) GetSubjectClass

func (x *FragmentReferrerContext) GetSubjectClass() []string

func (*FragmentReferrerContext) ProtoMessage

func (*FragmentReferrerContext) ProtoMessage()

func (*FragmentReferrerContext) ProtoReflect added in v0.1.8

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

func (*FragmentReferrerContext) Reset

func (x *FragmentReferrerContext) Reset()

func (*FragmentReferrerContext) String

func (x *FragmentReferrerContext) String() string

type FragmentRequest

type FragmentRequest struct {
	Subject      []string `protobuf:"bytes,1,rep,name=subject,proto3" json:"subject,omitempty"`
	Predicate    string   `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	Object       string   `protobuf:"bytes,3,opt,name=object,proto3" json:"object,omitempty"`
	Page         int32    `protobuf:"varint,4,opt,name=page,proto3" json:"page,omitempty"`
	Language     string   `protobuf:"bytes,5,opt,name=language,proto3" json:"language,omitempty"`
	OrgID        string   `protobuf:"bytes,6,opt,name=orgID,proto3" json:"orgID,omitempty"`
	Graph        string   `protobuf:"bytes,7,opt,name=graph,proto3" json:"graph,omitempty"`
	Spec         string   `protobuf:"bytes,8,opt,name=spec,proto3" json:"spec,omitempty"`
	Echo         string   `protobuf:"bytes,9,opt,name=echo,proto3" json:"echo,omitempty"`
	LodKey       string   `protobuf:"bytes,10,opt,name=lodKey,proto3" json:"lodKey,omitempty"`
	ExcludeHubID string   `protobuf:"bytes,11,opt,name=excludeHubID,proto3" json:"excludeHubID,omitempty"`
	HubID        string   `protobuf:"bytes,12,opt,name=hubID,proto3" json:"hubID,omitempty"`
	OrgIDKey     string   `protobuf:"bytes,13,opt,name=orgIDKey,proto3" json:"orgIDKey,omitempty"`
	// contains filtered or unexported fields
}

func NewFragmentRequest

func NewFragmentRequest(orgID string) *FragmentRequest

NewFragmentRequest creates a finder for Fragments Use the funcs to setup filters and search properties then call Find to execute.

func (*FragmentRequest) AssignObject

func (fr *FragmentRequest) AssignObject()

AssignObject cleans the object string and sets the language when applicable

func (*FragmentRequest) BuildQuery

func (fr *FragmentRequest) BuildQuery() *elastic.BoolQuery

func (*FragmentRequest) Descriptor deprecated

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

Deprecated: Use FragmentRequest.ProtoReflect.Descriptor instead.

func (*FragmentRequest) Do

Do executes the fragments request on elasticsearch

func (*FragmentRequest) Find

func (fr *FragmentRequest) Find(ctx context.Context, client *elastic.Client) ([]*Fragment, int64, error)

Find returns a list of matching LodFragments

func (FragmentRequest) GetESPage

func (fr FragmentRequest) GetESPage() int

GetESPage returns the 0 based page for Elastic Search todo refactor for protobuf

func (*FragmentRequest) GetEcho

func (x *FragmentRequest) GetEcho() string

func (*FragmentRequest) GetExcludeHubID

func (x *FragmentRequest) GetExcludeHubID() string

func (*FragmentRequest) GetGraph

func (x *FragmentRequest) GetGraph() string

func (*FragmentRequest) GetHubID

func (x *FragmentRequest) GetHubID() string

func (*FragmentRequest) GetLanguage

func (x *FragmentRequest) GetLanguage() string

func (*FragmentRequest) GetLodKey

func (x *FragmentRequest) GetLodKey() string

func (*FragmentRequest) GetObject

func (x *FragmentRequest) GetObject() string

func (*FragmentRequest) GetOrgID

func (x *FragmentRequest) GetOrgID() string

func (*FragmentRequest) GetOrgIDKey added in v0.2.0

func (x *FragmentRequest) GetOrgIDKey() string

func (*FragmentRequest) GetPage

func (x *FragmentRequest) GetPage() int32

func (*FragmentRequest) GetPredicate

func (x *FragmentRequest) GetPredicate() string

func (*FragmentRequest) GetSpec

func (x *FragmentRequest) GetSpec() string

func (*FragmentRequest) GetSubject

func (x *FragmentRequest) GetSubject() []string

func (*FragmentRequest) ParseQueryString

func (fr *FragmentRequest) ParseQueryString(v url.Values) error

ParseQueryString sets the FragmentRequest values from url.Values

func (*FragmentRequest) ProtoMessage

func (*FragmentRequest) ProtoMessage()

func (*FragmentRequest) ProtoReflect added in v0.1.8

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

func (*FragmentRequest) Reset

func (x *FragmentRequest) Reset()

func (*FragmentRequest) String

func (x *FragmentRequest) String() string

type FragmentResource

type FragmentResource struct {
	ID                   string                     `json:"id"`
	Types                []string                   `json:"types"`
	GraphExternalContext []*FragmentReferrerContext `json:"graphExternalContext"`
	Context              []*FragmentReferrerContext `json:"context"`
	Entries              []*ResourceEntry           `json:"entries"`
	Tags                 []string                   `json:"tags,omitempty"`
	// contains filtered or unexported fields
}

FragmentResource holds all the conttext information for a resource It works together with the FragmentBuilder to create the linked fragments

func (*FragmentResource) AddTo added in v0.3.0

func (fr *FragmentResource) AddTo(g *rdf.Graph) error

func (*FragmentResource) AppendContext

func (fr *FragmentResource) AppendContext(ctxs ...*FragmentReferrerContext)

AppendContext adds the referrerContext to the FragmentResource This action increments nilthe level count

func (*FragmentResource) ContextPath

func (fr *FragmentResource) ContextPath() string

ContextPath returns a string that can be used to reconstruct the path hierarchy for statistics. The values are separated by a forward slash.

func (*FragmentResource) CreateFragments

func (fr *FragmentResource) CreateFragments(fg *FragmentGraph) ([]*Fragment, error)

CreateFragments creates ElasticSearch documents for each RDF triple in the FragmentResource

func (*FragmentResource) CreateLodKey

func (fr *FragmentResource) CreateLodKey() (string, error)

CreateLodKey returns the path including the # fragments from the subject URL This is used for the Linked Open Data resolving

func (*FragmentResource) GenerateJSONLD

func (fr *FragmentResource) GenerateJSONLD() map[string]interface{}

GenerateJSONLD converts a FragmenResource into a JSON-LD entry

func (*FragmentResource) GenerateTriples deprecated added in v0.2.1

func (fr *FragmentResource) GenerateTriples() []*r.Triple

Deprecated: use FragmentResource.AddTo to add them to a graph

func (*FragmentResource) GetLabel

func (fr *FragmentResource) GetLabel() (label, language string)

GetLabel returns the label and language for a resource This is used to present a label for a link in the interface

func (*FragmentResource) GetLevel

func (fr *FragmentResource) GetLevel() int32

GetLevel returns the relative level that this resource has from the root or parent resource

func (*FragmentResource) NewContext

func (fr *FragmentResource) NewContext(predicate, objectID string) *FragmentReferrerContext

NewContext returns the context for the current fragmentresource

func (*FragmentResource) ObjectIDs

func (fr *FragmentResource) ObjectIDs() []*FragmentReferrerContext

ObjectIDs returns an array of FragmentReferrerContext

func (*FragmentResource) Predicates

func (fr *FragmentResource) Predicates() map[string][]*FragmentEntry

Predicates returns a map of FragmentEntry

func (*FragmentResource) SetEntries

func (fr *FragmentResource) SetEntries(rm *ResourceMap) error

SetEntries sets the ResourceEntries for indexing

type FragmentResourceDoc

type FragmentResourceDoc struct {
	ID                   string                     `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Types                []string                   `protobuf:"bytes,2,rep,name=Types,proto3" json:"Types,omitempty"`
	GraphExternalContext []*FragmentReferrerContext `protobuf:"bytes,3,rep,name=GraphExternalContext,proto3" json:"GraphExternalContext,omitempty"`
	Context              []*FragmentReferrerContext `protobuf:"bytes,4,rep,name=Context,proto3" json:"Context,omitempty"`
	Predicates           []*FragmentEntryDoc        `protobuf:"bytes,6,rep,name=Predicates,proto3" json:"Predicates,omitempty"`
	ObjectIDs            []*FragmentReferrerContext `protobuf:"bytes,7,rep,name=ObjectIDs,proto3" json:"ObjectIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*FragmentResourceDoc) Descriptor deprecated

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

Deprecated: Use FragmentResourceDoc.ProtoReflect.Descriptor instead.

func (*FragmentResourceDoc) GetContext

func (x *FragmentResourceDoc) GetContext() []*FragmentReferrerContext

func (*FragmentResourceDoc) GetGraphExternalContext

func (x *FragmentResourceDoc) GetGraphExternalContext() []*FragmentReferrerContext

func (*FragmentResourceDoc) GetID

func (x *FragmentResourceDoc) GetID() string

func (*FragmentResourceDoc) GetObjectIDs

func (x *FragmentResourceDoc) GetObjectIDs() []*FragmentReferrerContext

func (*FragmentResourceDoc) GetPredicates

func (x *FragmentResourceDoc) GetPredicates() []*FragmentEntryDoc

func (*FragmentResourceDoc) GetTypes

func (x *FragmentResourceDoc) GetTypes() []string

func (*FragmentResourceDoc) ProtoMessage

func (*FragmentResourceDoc) ProtoMessage()

func (*FragmentResourceDoc) ProtoReflect added in v0.1.8

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

func (*FragmentResourceDoc) Reset

func (x *FragmentResourceDoc) Reset()

func (*FragmentResourceDoc) String

func (x *FragmentResourceDoc) String() string

type FragmentSearchResponse

type FragmentSearchResponse struct {
	Request   *FragmentRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	NrTriples int32            `protobuf:"varint,2,opt,name=nrTriples,proto3" json:"nrTriples,omitempty"`
	Page      int32            `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	Fragments []*Fragment      `protobuf:"bytes,4,rep,name=fragments,proto3" json:"fragments,omitempty"`
	// contains filtered or unexported fields
}

func (*FragmentSearchResponse) Descriptor deprecated

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

Deprecated: Use FragmentSearchResponse.ProtoReflect.Descriptor instead.

func (*FragmentSearchResponse) GetFragments

func (x *FragmentSearchResponse) GetFragments() []*Fragment

func (*FragmentSearchResponse) GetNrTriples

func (x *FragmentSearchResponse) GetNrTriples() int32

func (*FragmentSearchResponse) GetPage

func (x *FragmentSearchResponse) GetPage() int32

func (*FragmentSearchResponse) GetRequest

func (x *FragmentSearchResponse) GetRequest() *FragmentRequest

func (*FragmentSearchResponse) ProtoMessage

func (*FragmentSearchResponse) ProtoMessage()

func (*FragmentSearchResponse) ProtoReflect added in v0.1.8

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

func (*FragmentSearchResponse) Reset

func (x *FragmentSearchResponse) Reset()

func (*FragmentSearchResponse) String

func (x *FragmentSearchResponse) String() string

type FragmentUpdateResponse

type FragmentUpdateResponse struct {
	GraphsStored int32            `protobuf:"varint,1,opt,name=graphsStored,proto3" json:"graphsStored,omitempty"`
	Spec         string           `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	HasErrors    bool             `protobuf:"varint,3,opt,name=hasErrors,proto3" json:"hasErrors,omitempty"`
	Errors       []*FragmentError `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*FragmentUpdateResponse) Descriptor deprecated

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

Deprecated: Use FragmentUpdateResponse.ProtoReflect.Descriptor instead.

func (*FragmentUpdateResponse) GetErrors

func (x *FragmentUpdateResponse) GetErrors() []*FragmentError

func (*FragmentUpdateResponse) GetGraphsStored

func (x *FragmentUpdateResponse) GetGraphsStored() int32

func (*FragmentUpdateResponse) GetHasErrors

func (x *FragmentUpdateResponse) GetHasErrors() bool

func (*FragmentUpdateResponse) GetSpec

func (x *FragmentUpdateResponse) GetSpec() string

func (*FragmentUpdateResponse) ProtoMessage

func (*FragmentUpdateResponse) ProtoMessage()

func (*FragmentUpdateResponse) ProtoReflect added in v0.1.8

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

func (*FragmentUpdateResponse) Reset

func (x *FragmentUpdateResponse) Reset()

func (*FragmentUpdateResponse) String

func (x *FragmentUpdateResponse) String() string

type FuzzEntry

type FuzzEntry struct {
	Predicate   string   `json:"predicate"`
	Tags        []string `json:"tags"`
	Order       int      `json:"order"`
	SearchLabel string   `json:"searchLabel"`
}

FuzzEntry holds all the information to generate a Fuzzed Triple

type FuzzRecord

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

func (*FuzzRecord) AddTriples

func (fr *FuzzRecord) AddTriples() error

type FuzzResource

type FuzzResource struct {
	Subject     string       `json:"subject"`
	Type        string       `json:"type"`
	SearchLabel string       `json:"searchLabel"`
	Predicates  []*FuzzEntry `json:"predicates"`
	Order       int          `json:"order"`
}

FuzzResource holds all the information to generate a Fuzzed RDF-resource

type Fuzzer

type Fuzzer struct {
	BaseURL string
	// contains filtered or unexported fields
}

Fuzzer is the builder for building fuzzed records based on a record definition

func NewFuzzer

func NewFuzzer(recDef *Crecord_dash_definition) (*Fuzzer, error)

NewFuzzer creates a Fuzzer for creating Records based on the Record Definition

func (*Fuzzer) CreateRecords

func (fz *Fuzzer) CreateRecords(orgID string, n int) ([]string, error)

CreateRecords for n number of fuzzed records

func (*Fuzzer) CreateTriples

func (fz *Fuzzer) CreateTriples(subject string, fe *FuzzEntry) []*r.Triple

CreateTriples creates fuzzed Triples for a FuzzEntry

func (*Fuzzer) ExpandNameSpace

func (fz *Fuzzer) ExpandNameSpace(xmlLabel string) (string, error)

ExpandNameSpace converts prefix xml label to fully qualified URLs

func (*Fuzzer) NewFuzzEntry

func (fz *Fuzzer) NewFuzzEntry(order int, elem *Celem) (*FuzzEntry, error)

NewFuzzEntry creates a FuzzEntry from a child elem in the Record Definition

func (*Fuzzer) NewFuzzResource

func (fz *Fuzzer) NewFuzzResource(order int, elem *Celem) (*FuzzResource, error)

NewFuzzResource creates a FuzzResource

func (*Fuzzer) NewString

func (fz *Fuzzer) NewString(label string) string

NewString creates a new fuzzed string

func (*Fuzzer) NewURI

func (fz *Fuzzer) NewURI(label string, key int) string

NewURI created new Fuzzed URI. When the label is given that is used for the URI

type GeoType

type GeoType int32
const (
	GeoType_BBOX    GeoType = 0
	GeoType_GEOFILT GeoType = 1
	GeoType_CLUSTER GeoType = 2
)

func (GeoType) Descriptor added in v0.1.8

func (GeoType) Descriptor() protoreflect.EnumDescriptor

func (GeoType) Enum added in v0.1.8

func (x GeoType) Enum() *GeoType

func (GeoType) EnumDescriptor deprecated

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

Deprecated: Use GeoType.Descriptor instead.

func (GeoType) Number added in v0.1.8

func (x GeoType) Number() protoreflect.EnumNumber

func (GeoType) String

func (x GeoType) String() string

func (GeoType) Type added in v0.1.8

func (GeoType) Type() protoreflect.EnumType
type Header struct {

	// The tenant identifier for this RecordType.
	OrgID string `protobuf:"bytes,1,opt,name=orgID,proto3" json:"orgID,omitempty"`
	// The spec is the unique dataset string to identify which dataset  this
	// Fragment belongs to
	Spec string `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// The revision is used to determine which version is an orphan and should be removed
	Revision int32 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// The hubId is the unique identifier for any document record in hub3
	HubID string `protobuf:"bytes,4,opt,name=hubID,proto3" json:"hubID,omitempty"`
	// Each fragment can be tagged with additional metadata. This can be queried for.
	// Some examples are 'resource', 'literal', 'bnode', 'rdfType', etc.
	Tags []string `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
	// The document type for ElasticSearch. This is a constant value
	DocType string `protobuf:"bytes,6,opt,name=docType,proto3" json:"docType,omitempty"`
	// The subject of the graph stored
	EntryURI string `protobuf:"bytes,7,opt,name=entryURI,proto3" json:"entryURI,omitempty"`
	// the graph name of the graph stored
	NamedGraphURI string `protobuf:"bytes,8,opt,name=namedGraphURI,proto3" json:"namedGraphURI,omitempty"`
	// miliseconds since epoch
	Modified int64 `protobuf:"varint,9,opt,name=modified,proto3" json:"modified,omitempty"`
	// sourceID the record being publlished. this can be a commit sha or generated per
	// indexing run
	SourceID string `protobuf:"bytes,10,opt,name=sourceID,proto3" json:"sourceID,omitempty"`
	// commit path to source
	SourcePath string `protobuf:"bytes,11,opt,name=sourcePath,proto3" json:"sourcePath,omitempty"`
	// id to group sub-set of records for spec that can be used for orphancontrol
	GroupID string `protobuf:"bytes,12,opt,name=groupID,proto3" json:"groupID,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) AddTags

func (m *Header) AddTags(tags ...string)

AddTags adds a tag string to the tags array of the Header

func (*Header) Descriptor deprecated

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetDocType

func (x *Header) GetDocType() string

func (*Header) GetEntryURI

func (x *Header) GetEntryURI() string

func (*Header) GetGroupID added in v0.2.0

func (x *Header) GetGroupID() string

func (*Header) GetHubID

func (x *Header) GetHubID() string

func (*Header) GetModified

func (x *Header) GetModified() int64

func (*Header) GetNamedGraphURI

func (x *Header) GetNamedGraphURI() string

func (*Header) GetOrgID

func (x *Header) GetOrgID() string

func (*Header) GetRevision

func (x *Header) GetRevision() int32

func (*Header) GetSourceID added in v0.2.0

func (x *Header) GetSourceID() string

func (*Header) GetSourcePath added in v0.2.0

func (x *Header) GetSourcePath() string

func (*Header) GetSpec

func (x *Header) GetSpec() string

func (*Header) GetTags

func (x *Header) GetTags() []string

func (*Header) LastModified added in v0.3.0

func (h *Header) LastModified() time.Time

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) ProtoReflect added in v0.1.8

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

func (*Header) Reset

func (x *Header) Reset()

func (*Header) String

func (x *Header) String() string

type HyperMediaDataSet

type HyperMediaDataSet struct {
	DataSetURI   string
	PagerURI     string
	TotalItems   int64
	ItemsPerPage int64
	FirstPage    string
	PreviousPage string
	NextPage     string
	CurrentPage  int32
}

HyperMediaDataSet holds all the configuration information to generate the HyperMediaControls RDF

func NewHyperMediaDataSet

func NewHyperMediaDataSet(r *http.Request, totalHits int64, fr *FragmentRequest) *HyperMediaDataSet

NewHyperMediaDataSet creates the basis to generate triple-pattern-fragment controls

func (HyperMediaDataSet) CreateControls

func (hmd HyperMediaDataSet) CreateControls() ([]byte, error)

CreateControls creates an byte array of the RDF media controls

func (HyperMediaDataSet) HasNext

func (hmd HyperMediaDataSet) HasNext() bool

HasNext returns if the dataset has a next page

func (HyperMediaDataSet) HasPrevious

func (hmd HyperMediaDataSet) HasPrevious() bool

HasPrevious returns if the dataset has a previous page

type I18NLabel

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

func (*I18NLabel) Descriptor deprecated

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

Deprecated: Use I18NLabel.ProtoReflect.Descriptor instead.

func (*I18NLabel) GetLang

func (x *I18NLabel) GetLang() string

func (*I18NLabel) GetName

func (x *I18NLabel) GetName() string

func (*I18NLabel) ProtoMessage

func (*I18NLabel) ProtoMessage()

func (*I18NLabel) ProtoReflect added in v0.1.8

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

func (*I18NLabel) Reset

func (x *I18NLabel) Reset()

func (*I18NLabel) String

func (x *I18NLabel) String() string

type IdType

type IdType int32
const (
	// same as ES doc_id
	IdType_HUDID IdType = 0
	// case insensitive id search
	IdType_IDCI IdType = 1
	// named graph
	IdType_NAMEDGRAPH IdType = 2
)

func (IdType) Descriptor added in v0.1.8

func (IdType) Descriptor() protoreflect.EnumDescriptor

func (IdType) Enum added in v0.1.8

func (x IdType) Enum() *IdType

func (IdType) EnumDescriptor deprecated

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

Deprecated: Use IdType.Descriptor instead.

func (IdType) Number added in v0.1.8

func (x IdType) Number() protoreflect.EnumNumber

func (IdType) String

func (x IdType) String() string

func (IdType) Type added in v0.1.8

func (IdType) Type() protoreflect.EnumType

type IndexEntry

type IndexEntry struct {
	ID       string `json:"id,omitempty"`
	Value    string `json:"value,omitempty"`
	Language string `json:"language,omitempty"`
	Type     string `json:"@type,omitempty"`
	Raw      string `json:"raw,omitempty"`
}

IndexEntry holds info for earch triple in the V1 API

func (*IndexEntry) Hash added in v0.2.1

func (ie *IndexEntry) Hash(searchLabel string) (string, error)

type IndexRange

type IndexRange struct {
	Greater string `json:"gte"`
	Less    string `json:"lte"`
}

IndexRange is used for indexing ranges.

func CreateDateRange

func CreateDateRange(period string) (IndexRange, error)

CreateDateRange creates a date indexRange

func (IndexRange) Valid

func (ir IndexRange) Valid() error

Valid checks if Less is smaller than Greater.

type InlineType

type InlineType int32
const (
	InlineType_NONE                InlineType = 0
	InlineType_URI_ONLY            InlineType = 4 // show row object resource URI
	InlineType_LABEL               InlineType = 1
	InlineType_MODAL               InlineType = 2
	InlineType_INLINE_DETAIL_BLOCK InlineType = 3
)

func (InlineType) Descriptor added in v0.1.8

func (InlineType) Descriptor() protoreflect.EnumDescriptor

func (InlineType) Enum added in v0.1.8

func (x InlineType) Enum() *InlineType

func (InlineType) EnumDescriptor deprecated

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

Deprecated: Use InlineType.Descriptor instead.

func (InlineType) Number added in v0.1.8

func (x InlineType) Number() protoreflect.EnumNumber

func (InlineType) String

func (x InlineType) String() string

func (InlineType) Type added in v0.1.8

type ItemFormatType

type ItemFormatType int32
const (
	ItemFormatType_SUMMARY       ItemFormatType = 0
	ItemFormatType_FRAGMENTGRAPH ItemFormatType = 1
	ItemFormatType_GROUPED       ItemFormatType = 2
	ItemFormatType_JSONLD        ItemFormatType = 3
	ItemFormatType_FLAT          ItemFormatType = 4
	ItemFormatType_TREE          ItemFormatType = 5
)

func (ItemFormatType) Descriptor added in v0.1.8

func (ItemFormatType) Enum added in v0.1.8

func (x ItemFormatType) Enum() *ItemFormatType

func (ItemFormatType) EnumDescriptor deprecated

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

Deprecated: Use ItemFormatType.Descriptor instead.

func (ItemFormatType) Number added in v0.1.8

func (ItemFormatType) String

func (x ItemFormatType) String() string

func (ItemFormatType) Type added in v0.1.8

type Legacy

type Legacy struct {
	HubID            string `json:"delving_hubId,omitempty"`
	RecordType       string `json:"delving_recordType,omitempty"`
	Spec             string `json:"delving_spec,omitempty"`
	Owner            string `json:"delving_owner,omitempty"`
	OrgID            string `json:"delving_orgId,omitempty"`
	Collection       string `json:"delving_collection,omitempty"`
	Title            string `json:"delving_title,omitempty"`
	Creator          string `json:"delving_creator,omitempty"`
	Provider         string `json:"delving_provider,omitempty"`
	HasGeoHash       string `json:"delving_hasGeoHash"`
	HasDigitalObject string `json:"delving_hasDigitalObject"`
	HasLandingPage   string `json:"delving_hasLandingPage"`
	HasDeepZoom      string `json:"delving_hasDeepZoom"`
}

Legacy holds the legacy values

func NewLegacy

func NewLegacy(indexDoc map[string]interface{}, fb *FragmentBuilder, recordTypes ...string) *Legacy

NewLegacy returns a legacy struct with default values

type MetadataFieldV1

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

func (*MetadataFieldV1) Descriptor deprecated

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

Deprecated: Use MetadataFieldV1.ProtoReflect.Descriptor instead.

func (*MetadataFieldV1) GetField

func (x *MetadataFieldV1) GetField() []string

func (*MetadataFieldV1) ProtoMessage

func (*MetadataFieldV1) ProtoMessage()

func (*MetadataFieldV1) ProtoReflect added in v0.1.8

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

func (*MetadataFieldV1) Reset

func (x *MetadataFieldV1) Reset()

func (*MetadataFieldV1) String

func (x *MetadataFieldV1) String() string

type MetadataItemV1

type MetadataItemV1 struct {
	DocId   string                      `protobuf:"bytes,1,opt,name=doc_id,json=docId,proto3" json:"doc_id,omitempty"`
	DocType string                      `protobuf:"bytes,2,opt,name=doc_type,json=docType,proto3" json:"doc_type,omitempty"`
	Fields  map[string]*MetadataFieldV1 `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MetadataItemV1) Descriptor deprecated

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

Deprecated: Use MetadataItemV1.ProtoReflect.Descriptor instead.

func (*MetadataItemV1) GetDocId

func (x *MetadataItemV1) GetDocId() string

func (*MetadataItemV1) GetDocType

func (x *MetadataItemV1) GetDocType() string

func (*MetadataItemV1) GetFields

func (x *MetadataItemV1) GetFields() map[string]*MetadataFieldV1

func (*MetadataItemV1) ProtoMessage

func (*MetadataItemV1) ProtoMessage()

func (*MetadataItemV1) ProtoReflect added in v0.1.8

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

func (*MetadataItemV1) Reset

func (x *MetadataItemV1) Reset()

func (*MetadataItemV1) String

func (x *MetadataItemV1) String() string

type Pagination

type Pagination struct {
	Start        int32             `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	Rows         int32             `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	NumFound     int32             `protobuf:"varint,3,opt,name=numFound,proto3" json:"numFound,omitempty"`
	HasNext      bool              `protobuf:"varint,4,opt,name=hasNext,proto3" json:"hasNext,omitempty"`
	NextPage     int32             `protobuf:"varint,5,opt,name=nextPage,proto3" json:"nextPage,omitempty"`
	HasPrevious  bool              `protobuf:"varint,6,opt,name=hasPrevious,proto3" json:"hasPrevious,omitempty"`
	PreviousPage int32             `protobuf:"varint,7,opt,name=previousPage,proto3" json:"previousPage,omitempty"`
	CurrentPage  int32             `protobuf:"varint,8,opt,name=currentPage,proto3" json:"currentPage,omitempty"`
	Links        []*PaginationLink `protobuf:"bytes,9,rep,name=links,proto3" json:"links,omitempty"`
	// contains filtered or unexported fields
}

func (*Pagination) Descriptor deprecated

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

Deprecated: Use Pagination.ProtoReflect.Descriptor instead.

func (*Pagination) GetCurrentPage

func (x *Pagination) GetCurrentPage() int32

func (*Pagination) GetHasNext

func (x *Pagination) GetHasNext() bool

func (*Pagination) GetHasPrevious

func (x *Pagination) GetHasPrevious() bool
func (x *Pagination) GetLinks() []*PaginationLink

func (*Pagination) GetNextPage

func (x *Pagination) GetNextPage() int32

func (*Pagination) GetNumFound

func (x *Pagination) GetNumFound() int32

func (*Pagination) GetPreviousPage

func (x *Pagination) GetPreviousPage() int32

func (*Pagination) GetRows

func (x *Pagination) GetRows() int32

func (*Pagination) GetStart

func (x *Pagination) GetStart() int32

func (*Pagination) ProtoMessage

func (*Pagination) ProtoMessage()

func (*Pagination) ProtoReflect added in v0.1.8

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

func (*Pagination) Reset

func (x *Pagination) Reset()

func (*Pagination) String

func (x *Pagination) String() string
type PaginationLink struct {
	Start      int32 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	IsLinked   bool  `protobuf:"varint,2,opt,name=isLinked,proto3" json:"isLinked,omitempty"`
	PageNumber int32 `protobuf:"varint,3,opt,name=pageNumber,proto3" json:"pageNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*PaginationLink) Descriptor deprecated

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

Deprecated: Use PaginationLink.ProtoReflect.Descriptor instead.

func (*PaginationLink) GetIsLinked

func (x *PaginationLink) GetIsLinked() bool

func (*PaginationLink) GetPageNumber

func (x *PaginationLink) GetPageNumber() int32

func (*PaginationLink) GetStart

func (x *PaginationLink) GetStart() int32

func (*PaginationLink) ProtoMessage

func (*PaginationLink) ProtoMessage()

func (*PaginationLink) ProtoReflect added in v0.1.8

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

func (*PaginationLink) Reset

func (x *PaginationLink) Reset()

func (*PaginationLink) String

func (x *PaginationLink) String() string

type PresentationField

type PresentationField struct {
	I18NLabel  *I18NLabel `protobuf:"bytes,1,opt,name=i18nLabel,proto3" json:"i18nLabel,omitempty"`
	Clickable  bool       `protobuf:"varint,2,opt,name=clickable,proto3" json:"clickable,omitempty"`
	Searchable bool       `protobuf:"varint,7,opt,name=searchable,proto3" json:"searchable,omitempty"`
	Predicate  string     `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
	Single     bool       `protobuf:"varint,4,opt,name=single,proto3" json:"single,omitempty"`
	Order      int32      `protobuf:"varint,5,opt,name=order,proto3" json:"order,omitempty"`
	FieldType  FieldType  `protobuf:"varint,6,opt,name=fieldType,proto3,enum=fragments.FieldType" json:"fieldType,omitempty"`
	InlineType InlineType `protobuf:"varint,8,opt,name=inlineType,proto3,enum=fragments.InlineType" json:"inlineType,omitempty"`
	InlineCSS  string     `protobuf:"bytes,9,opt,name=inlineCSS,proto3" json:"inlineCSS,omitempty"`
	// contains filtered or unexported fields
}

func (*PresentationField) Descriptor deprecated

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

Deprecated: Use PresentationField.ProtoReflect.Descriptor instead.

func (*PresentationField) GetClickable

func (x *PresentationField) GetClickable() bool

func (*PresentationField) GetFieldType

func (x *PresentationField) GetFieldType() FieldType

func (*PresentationField) GetI18NLabel

func (x *PresentationField) GetI18NLabel() *I18NLabel

func (*PresentationField) GetInlineCSS

func (x *PresentationField) GetInlineCSS() string

func (*PresentationField) GetInlineType

func (x *PresentationField) GetInlineType() InlineType

func (*PresentationField) GetOrder

func (x *PresentationField) GetOrder() int32

func (*PresentationField) GetPredicate

func (x *PresentationField) GetPredicate() string

func (*PresentationField) GetSearchable

func (x *PresentationField) GetSearchable() bool

func (*PresentationField) GetSingle

func (x *PresentationField) GetSingle() bool

func (*PresentationField) ProtoMessage

func (*PresentationField) ProtoMessage()

func (*PresentationField) ProtoReflect added in v0.1.8

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

func (*PresentationField) Reset

func (x *PresentationField) Reset()

func (*PresentationField) String

func (x *PresentationField) String() string

type ProtoBuf

type ProtoBuf struct {
	MessageType string `json:"messageType,omitempty"`
	Data        string `json:"data,omitempty"`
}

ProtoBuf holds a protobuf encode version of the messageType.

type Query

type Query struct {
	Numfound    int32         `protobuf:"varint,1,opt,name=numfound,proto3" json:"numfound,omitempty"`
	Terms       string        `protobuf:"bytes,2,opt,name=terms,proto3" json:"terms,omitempty"`
	BreadCrumbs []*BreadCrumb `protobuf:"bytes,3,rep,name=breadCrumbs,proto3" json:"breadCrumbs,omitempty"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetBreadCrumbs

func (x *Query) GetBreadCrumbs() []*BreadCrumb

func (*Query) GetNumfound

func (x *Query) GetNumfound() int32

func (*Query) GetTerms

func (x *Query) GetTerms() string

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) ProtoReflect added in v0.1.8

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

func (*Query) Reset

func (x *Query) Reset()

func (*Query) String

func (x *Query) String() string

type QueryFacet

type QueryFacet struct {
	Name        string       `json:"name"`
	Field       string       `json:"field"`
	IsSelected  bool         `json:"isSelected"`
	I18n        string       `json:"i18N,omitempty"`
	Total       int64        `json:"total"`
	MissingDocs int64        `json:"missingDocs"`
	OtherDocs   int64        `json:"otherDocs"`
	Min         string       `json:"min,omitempty"`
	Max         string       `json:"max,omitempty"`
	Type        string       `json:"type,omitempty"`
	Links       []*FacetLink `json:"links"`
}

QueryFacet contains all the information for an ElasticSearch Aggregation

func DecodeFacets

func DecodeFacets(res *elastic.SearchResult, fb *FacetURIBuilder) ([]*QueryFacet, error)

DecodeFacets decodes the elastic aggregations in the SearchResult to fragments.QueryFacets

type QueryFilter

type QueryFilter struct {
	Level1      *ContextQueryFilter `protobuf:"bytes,1,opt,name=Level1,proto3" json:"Level1,omitempty"`
	Level2      *ContextQueryFilter `protobuf:"bytes,2,opt,name=Level2,proto3" json:"Level2,omitempty"`
	SearchLabel string              `protobuf:"bytes,3,opt,name=SearchLabel,proto3" json:"SearchLabel,omitempty"`
	TypeClass   string              `protobuf:"bytes,6,opt,name=TypeClass,proto3" json:"TypeClass,omitempty"`
	Value       string              `protobuf:"bytes,4,opt,name=Value,proto3" json:"Value,omitempty"`
	Exclude     bool                `protobuf:"varint,5,opt,name=Exclude,proto3" json:"Exclude,omitempty"`
	ID          bool                `protobuf:"varint,7,opt,name=ID,proto3" json:"ID,omitempty"`
	Exists      bool                `protobuf:"varint,8,opt,name=Exists,proto3" json:"Exists,omitempty"`
	Type        QueryFilterType     `protobuf:"varint,9,opt,name=type,proto3,enum=fragments.QueryFilterType" json:"type,omitempty"`
	Lte         string              `protobuf:"bytes,10,opt,name=lte,proto3" json:"lte,omitempty"`
	Gte         string              `protobuf:"bytes,11,opt,name=gte,proto3" json:"gte,omitempty"` // Path is the full query path
	// contains filtered or unexported fields
}

func NewDateRangeFilter

func NewDateRangeFilter(filter string) (*QueryFilter, error)

NewDateRangeFilter creates a new QueryFilter from the input string.

func NewQueryFilter

func NewQueryFilter(filter string) (*QueryFilter, error)

NewQueryFilter parses the filter string and creates a QueryFilter object

func NewTreeFilter

func NewTreeFilter(filter string) (*QueryFilter, error)

NewTreeFilter creates QueryFilter for Tree

func (*QueryFilter) AsString

func (qf *QueryFilter) AsString() string

AsString returns the QueryFilter formatted as a string

func (*QueryFilter) Descriptor deprecated

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

Deprecated: Use QueryFilter.ProtoReflect.Descriptor instead.

func (*QueryFilter) ElasticFilter

func (qf *QueryFilter) ElasticFilter() (elastic.Query, error)

ElasticFilter creates an elasticsearch filter from the QueryFilter

func (*QueryFilter) Equal

func (qf *QueryFilter) Equal(oqf *QueryFilter) bool

Equal determines equality between Query Filters

func (*QueryFilter) GetExclude

func (x *QueryFilter) GetExclude() bool

func (*QueryFilter) GetExists

func (x *QueryFilter) GetExists() bool

func (*QueryFilter) GetGte

func (x *QueryFilter) GetGte() string

func (*QueryFilter) GetID

func (x *QueryFilter) GetID() bool

func (*QueryFilter) GetLevel1

func (x *QueryFilter) GetLevel1() *ContextQueryFilter

func (*QueryFilter) GetLevel2

func (x *QueryFilter) GetLevel2() *ContextQueryFilter

func (*QueryFilter) GetLte

func (x *QueryFilter) GetLte() string

func (*QueryFilter) GetSearchLabel

func (x *QueryFilter) GetSearchLabel() string

func (*QueryFilter) GetType

func (x *QueryFilter) GetType() QueryFilterType

func (*QueryFilter) GetTypeClass

func (x *QueryFilter) GetTypeClass() string

func (*QueryFilter) GetValue

func (x *QueryFilter) GetValue() string

func (*QueryFilter) ProtoMessage

func (*QueryFilter) ProtoMessage()

func (*QueryFilter) ProtoReflect added in v0.1.8

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

func (*QueryFilter) Reset

func (x *QueryFilter) Reset()

func (*QueryFilter) SetExclude

func (qf *QueryFilter) SetExclude(q *elastic.BoolQuery, qs ...elastic.Query) *elastic.BoolQuery

func (*QueryFilter) String

func (x *QueryFilter) String() string

type QueryFilterType

type QueryFilterType int32
const (
	QueryFilterType_TEXT        QueryFilterType = 0
	QueryFilterType_ID          QueryFilterType = 1
	QueryFilterType_EXCLUDE     QueryFilterType = 2
	QueryFilterType_EXISTS      QueryFilterType = 3
	QueryFilterType_RANGE       QueryFilterType = 4
	QueryFilterType_DATERANGE   QueryFilterType = 5
	QueryFilterType_ISODATE     QueryFilterType = 6
	QueryFilterType_TREEITEM    QueryFilterType = 7
	QueryFilterType_ENTRYTAG    QueryFilterType = 8
	QueryFilterType_SEARCHLABEL QueryFilterType = 9
)

func (QueryFilterType) Descriptor added in v0.1.8

func (QueryFilterType) Enum added in v0.1.8

func (x QueryFilterType) Enum() *QueryFilterType

func (QueryFilterType) EnumDescriptor deprecated

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

Deprecated: Use QueryFilterType.Descriptor instead.

func (QueryFilterType) Number added in v0.1.8

func (QueryFilterType) String

func (x QueryFilterType) String() string

func (QueryFilterType) Type added in v0.1.8

type RDFUploader

type RDFUploader struct {
	OrgID        string
	Spec         string
	SubjectClass string
	TypeClassURI string
	IDSplitter   string
	Revision     int32
	// contains filtered or unexported fields
}

func NewRDFUploader

func NewRDFUploader(orgID, spec, subjectClass, typePredicate, idSplitter string, revision int) *RDFUploader

func (*RDFUploader) IndexFragments

func (upl *RDFUploader) IndexFragments(bi BulkIndex) (int, error)

func (*RDFUploader) Parse

func (upl *RDFUploader) Parse(r io.Reader) (*ResourceMap, error)

func (*RDFUploader) SaveFragmentGraphs

func (upl *RDFUploader) SaveFragmentGraphs(bi BulkIndex) (int, error)

type RecordType

type RecordType int32
const (
	RecordType_NARTHEX    RecordType = 0
	RecordType_SCHEMA     RecordType = 1
	RecordType_VOCABULARY RecordType = 2
	RecordType_SOURCE     RecordType = 3
	RecordType_CACHE      RecordType = 4
)

func (RecordType) Descriptor added in v0.1.8

func (RecordType) Descriptor() protoreflect.EnumDescriptor

func (RecordType) Enum added in v0.1.8

func (x RecordType) Enum() *RecordType

func (RecordType) EnumDescriptor deprecated

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

Deprecated: Use RecordType.Descriptor instead.

func (RecordType) Number added in v0.1.8

func (x RecordType) Number() protoreflect.EnumNumber

func (RecordType) String

func (x RecordType) String() string

func (RecordType) Type added in v0.1.8

type ResourceEntry

type ResourceEntry struct {
	ID          string            `json:"@id,omitempty"`
	Value       string            `json:"@value,omitempty"`
	Language    string            `json:"@language,omitempty"`
	DataType    string            `json:"@type,omitempty"`
	EntryType   string            `json:"entrytype,omitempty"`
	Predicate   string            `json:"predicate,omitempty"`
	SearchLabel string            `json:"searchLabel,omitempty"`
	Level       int32             `json:"level"`
	Tags        []string          `json:"tags,omitempty"`
	Date        []string          `json:"isoDate,omitempty"`
	DateRange   *IndexRange       `json:"dateRange,omitempty"`
	Integer     int               `json:"integer,omitempty"`
	Float       float64           `json:"float,omitempty"`
	IntRange    *IndexRange       `json:"intRange,omitempty"`
	LatLong     string            `json:"latLong,omitempty"`
	Inline      *FragmentResource `json:"inline,omitempty"`
	Order       int               `json:"order"`
}

ResourceEntry contains all the indexed entries for FragmentResources

func (*ResourceEntry) AddTags

func (re *ResourceEntry) AddTags(tags ...string)

AddTags adds a tag string to the tags array of the Header

func (*ResourceEntry) AsLdObject

func (re *ResourceEntry) AsLdObject() *r.LdObject

AsLdObject generates an rdf2go.LdObject for JSON-LD generation

func (*ResourceEntry) AsTriple added in v0.3.0

func (re *ResourceEntry) AsTriple(subject rdf.Subject) (*rdf.Triple, error)

func (*ResourceEntry) GetTriple added in v0.2.1

func (re *ResourceEntry) GetTriple(subject r.Term) *r.Triple

type ResourceEntryHighlight

type ResourceEntryHighlight struct {
	SearchLabel string   `json:"searchLabel"`
	MarkDown    []string `json:"markdown"`
}

ResourceEntryHighlight holds the values of the ElasticSearch highlight fiel

type ResourceMap

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

ResourceMap is a convenience structure to hold the resourceMap data and functions

func NewEmptyResourceMap

func NewEmptyResourceMap(orgID string) *ResourceMap

NewEmptyResourceMap returns an initialised ResourceMap

func NewResourceMap

func NewResourceMap(orgID string, g *r.Graph) (*ResourceMap, error)

NewResourceMap creates a map for all the resources in the rdf2go.Graph

func NewResourceMapFromXML

func NewResourceMapFromXML(orgID string, triples []rdf.Triple) (*ResourceMap, error)

NewResourceMapFromXML creates a resource map from the triples

func (*ResourceMap) AppendOrderedTriple

func (rm *ResourceMap) AppendOrderedTriple(t *r.Triple, resolved bool, order int) error

AppendOrderedTriple appends a triple to a subject map

func (*ResourceMap) AppendTriple

func (rm *ResourceMap) AppendTriple(t *r.Triple, resolved bool) error

AppendTriple appends a triple to a subject map

func (*ResourceMap) GetResource

func (rm *ResourceMap) GetResource(subject string) (*FragmentResource, bool)

GetResource returns a Fragment resource from the ResourceMap

func (*ResourceMap) ResolveObjectIDs

func (rm *ResourceMap) ResolveObjectIDs(excludeHubID string) error

ResolveObjectIDs queries the fragmentstore for additional context

func (*ResourceMap) Resources

func (rm *ResourceMap) Resources() map[string]*FragmentResource

Resources returns the map

func (*ResourceMap) ResourcesList

func (rm *ResourceMap) ResourcesList(resources map[string]*FragmentResource) []*FragmentResource

ResourcesList returns a list of FragmentResource

func (*ResourceMap) SetContextLevels

func (rm *ResourceMap) SetContextLevels(subjectURI string) (map[string]*FragmentResource, error)

SetContextLevels sets FragmentReferrerContext to each level from the root

type ResourceSortOrder

type ResourceSortOrder struct {
	Key   string
	Value int
}

ResourceSortOrder holds the sort keys

func (ResourceSortOrder) CleanKey

func (rso ResourceSortOrder) CleanKey() string

CleanKey strips leading and trailing "<>" from the key.

type ResponseBlockType

type ResponseBlockType int32
const (
	ResponseBlockType_QUERY      ResponseBlockType = 0
	ResponseBlockType_ITEMS      ResponseBlockType = 1
	ResponseBlockType_FACETS     ResponseBlockType = 2
	ResponseBlockType_LAYOUT     ResponseBlockType = 3
	ResponseBlockType_PAGINATION ResponseBlockType = 4
)

func (ResponseBlockType) Descriptor added in v0.1.8

func (ResponseBlockType) Enum added in v0.1.8

func (ResponseBlockType) EnumDescriptor deprecated

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

Deprecated: Use ResponseBlockType.Descriptor instead.

func (ResponseBlockType) Number added in v0.1.8

func (ResponseBlockType) String

func (x ResponseBlockType) String() string

func (ResponseBlockType) Type added in v0.1.8

type ResponseFormatType

type ResponseFormatType int32
const (
	ResponseFormatType_JSON     ResponseFormatType = 0
	ResponseFormatType_PROTOBUF ResponseFormatType = 1
	// not supported
	ResponseFormatType_XML ResponseFormatType = 2
	// not supported
	ResponseFormatType_JSONP ResponseFormatType = 3
	// not supported
	ResponseFormatType_KML ResponseFormatType = 4
	// not supported
	ResponseFormatType_GEOCLUSTER ResponseFormatType = 5
	// not supported
	ResponseFormatType_GEOJSON ResponseFormatType = 6
	// not supported
	ResponseFormatType_GEOBUF ResponseFormatType = 7
	// supported
	ResponseFormatType_LDJSON ResponseFormatType = 8
	// supported
	ResponseFormatType_BULKACTION ResponseFormatType = 9
)

func (ResponseFormatType) Descriptor added in v0.1.8

func (ResponseFormatType) Enum added in v0.1.8

func (ResponseFormatType) EnumDescriptor deprecated

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

Deprecated: Use ResponseFormatType.Descriptor instead.

func (ResponseFormatType) Number added in v0.1.8

func (ResponseFormatType) String

func (x ResponseFormatType) String() string

func (ResponseFormatType) Type added in v0.1.8

type ResultSummary

type ResultSummary struct {
	Title         string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Owner         string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	DatasetTitle  string `protobuf:"bytes,3,opt,name=datasetTitle,proto3" json:"datasetTitle,omitempty"`
	Thumbnail     string `protobuf:"bytes,4,opt,name=thumbnail,proto3" json:"thumbnail,omitempty"`
	LandingPage   string `protobuf:"bytes,5,opt,name=landingPage,proto3" json:"landingPage,omitempty"`
	LatLong       string `protobuf:"bytes,6,opt,name=latLong,proto3" json:"latLong,omitempty"`
	Date          string `protobuf:"bytes,7,opt,name=date,proto3" json:"date,omitempty"`
	Description   string `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"`
	Subject       string `protobuf:"bytes,9,opt,name=subject,proto3" json:"subject,omitempty"`
	Collection    string `protobuf:"bytes,10,opt,name=collection,proto3" json:"collection,omitempty"`
	SubCollection string `protobuf:"bytes,11,opt,name=subCollection,proto3" json:"subCollection,omitempty"`
	ObjectID      string `protobuf:"bytes,12,opt,name=objectID,proto3" json:"objectID,omitempty"`
	ObjectType    string `protobuf:"bytes,13,opt,name=objectType,proto3" json:"objectType,omitempty"`
	Creator       string `protobuf:"bytes,14,opt,name=creator,proto3" json:"creator,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultSummary) AddEntry

func (sum *ResultSummary) AddEntry(entry *ResourceEntry)

AddEntry adds Summary fields based on the ResourceEntry tags

func (*ResultSummary) Descriptor deprecated

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

Deprecated: Use ResultSummary.ProtoReflect.Descriptor instead.

func (*ResultSummary) GetCollection

func (x *ResultSummary) GetCollection() string

func (*ResultSummary) GetCreator

func (x *ResultSummary) GetCreator() string

func (*ResultSummary) GetDatasetTitle

func (x *ResultSummary) GetDatasetTitle() string

func (*ResultSummary) GetDate

func (x *ResultSummary) GetDate() string

func (*ResultSummary) GetDescription

func (x *ResultSummary) GetDescription() string

func (*ResultSummary) GetLandingPage

func (x *ResultSummary) GetLandingPage() string

func (*ResultSummary) GetLatLong

func (x *ResultSummary) GetLatLong() string

func (*ResultSummary) GetObjectID

func (x *ResultSummary) GetObjectID() string

func (*ResultSummary) GetObjectType

func (x *ResultSummary) GetObjectType() string

func (*ResultSummary) GetOwner

func (x *ResultSummary) GetOwner() string

func (*ResultSummary) GetSubCollection

func (x *ResultSummary) GetSubCollection() string

func (*ResultSummary) GetSubject

func (x *ResultSummary) GetSubject() string

func (*ResultSummary) GetThumbnail

func (x *ResultSummary) GetThumbnail() string

func (*ResultSummary) GetTitle

func (x *ResultSummary) GetTitle() string

func (*ResultSummary) ProtoMessage

func (*ResultSummary) ProtoMessage()

func (*ResultSummary) ProtoReflect added in v0.1.8

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

func (*ResultSummary) Reset

func (x *ResultSummary) Reset()

func (*ResultSummary) String

func (x *ResultSummary) String() string

type ResultType

type ResultType int32
const (
	ResultType_GRID    ResultType = 0
	ResultType_TABLE   ResultType = 1
	ResultType_MAP     ResultType = 2
	ResultType_ARCHIVE ResultType = 3
)

func (ResultType) Descriptor added in v0.1.8

func (ResultType) Descriptor() protoreflect.EnumDescriptor

func (ResultType) Enum added in v0.1.8

func (x ResultType) Enum() *ResultType

func (ResultType) EnumDescriptor deprecated

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

Deprecated: Use ResultType.Descriptor instead.

func (ResultType) Number added in v0.1.8

func (x ResultType) Number() protoreflect.EnumNumber

func (ResultType) String

func (x ResultType) String() string

func (ResultType) Type added in v0.1.8

type ResultViewConfig

type ResultViewConfig struct {
	ResultType ResultType         `protobuf:"varint,1,opt,name=resultType,proto3,enum=fragments.ResultType" json:"resultType,omitempty"`
	Fields     *PresentationField `protobuf:"bytes,2,opt,name=fields,proto3" json:"fields,omitempty"`
	Inline     bool               `protobuf:"varint,3,opt,name=inline,proto3" json:"inline,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultViewConfig) Descriptor deprecated

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

Deprecated: Use ResultViewConfig.ProtoReflect.Descriptor instead.

func (*ResultViewConfig) GetFields

func (x *ResultViewConfig) GetFields() *PresentationField

func (*ResultViewConfig) GetInline

func (x *ResultViewConfig) GetInline() bool

func (*ResultViewConfig) GetResultType

func (x *ResultViewConfig) GetResultType() ResultType

func (*ResultViewConfig) ProtoMessage

func (*ResultViewConfig) ProtoMessage()

func (*ResultViewConfig) ProtoReflect added in v0.1.8

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

func (*ResultViewConfig) Reset

func (x *ResultViewConfig) Reset()

func (*ResultViewConfig) String

func (x *ResultViewConfig) String() string

type ScrollPager

type ScrollPager struct {
	// scrollID is serialized version SearchRequest
	PreviousScrollID string `json:"previousScrollID"`
	NextScrollID     string `json:"nextScrollID"`
	Cursor           int32  `json:"cursor"`
	Total            int64  `json:"total"`
	Rows             int32  `json:"rows"`
}

ScrollPager holds all paging information for a search result.

func NewScrollPager

func NewScrollPager() *ScrollPager

NewScrollPager returns a ScrollPager with defaults set

type ScrollResultV4

type ScrollResultV4 struct {
	Pager      *ScrollPager       `json:"pager"`
	Pagination *search.Paginator  `json:"pagination,omitempty"`
	Query      *Query             `json:"query"`
	Items      []*FragmentGraph   `json:"items,omitempty"`
	Collapsed  []*Collapsed       `json:"collapse,omitempty"`
	Peek       map[string]int64   `json:"peek,omitempty"`
	Facets     []*QueryFacet      `json:"facets,omitempty"`
	TreeHeader *TreeHeader        `json:"treeHeader,omitempty"`
	Tree       []*Tree            `json:"tree,omitempty"`
	TreePage   map[string][]*Tree `json:"treePage,omitempty"`
	ProtoBuf   *ProtoBuf          `json:"-"`
}

ScrollResultV4 intermediate non-protobuf search results

type ScrollType added in v0.1.7

type ScrollType int
const (
	ScrollNext ScrollType = iota
	ScrollPrev
)

type SearchRequest

type SearchRequest struct {

	// Will output a summary result set. Any valid Lucene or Solr Query syntax will work.
	Query              string              `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	ResponseFormatType ResponseFormatType  `protobuf:"varint,2,opt,name=responseFormatType,proto3,enum=fragments.ResponseFormatType" json:"responseFormatType,omitempty"`
	ResponseSize       int32               `protobuf:"varint,3,opt,name=responseSize,proto3" json:"responseSize,omitempty"`
	Start              int32               `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	Page               int32               `protobuf:"varint,5,opt,name=page,proto3" json:"page,omitempty"`
	QueryFilter        []*QueryFilter      `protobuf:"bytes,6,rep,name=QueryFilter,proto3" json:"QueryFilter,omitempty"`
	HiddenQueryFilter  []*QueryFilter      `protobuf:"bytes,7,rep,name=HiddenQueryFilter,proto3" json:"HiddenQueryFilter,omitempty"`
	Disable            []ResponseBlockType `protobuf:"varint,8,rep,packed,name=disable,proto3,enum=fragments.ResponseBlockType" json:"disable,omitempty"`
	Enable             []ResponseBlockType `protobuf:"varint,9,rep,packed,name=enable,proto3,enum=fragments.ResponseBlockType" json:"enable,omitempty"`
	FacetField         []*FacetField       `protobuf:"bytes,10,rep,name=facetField,proto3" json:"facetField,omitempty"`
	FacetLimit         int32               `protobuf:"varint,11,opt,name=FacetLimit,proto3" json:"FacetLimit,omitempty"`
	FacetAndBoolType   bool                `protobuf:"varint,12,opt,name=FacetAndBoolType,proto3" json:"FacetAndBoolType,omitempty"`
	SortBy             string              `protobuf:"bytes,13,opt,name=sortBy,proto3" json:"sortBy,omitempty"`
	// geo options
	LatLong  string `protobuf:"bytes,14,opt,name=LatLong,proto3" json:"LatLong,omitempty"`   // pt
	Distance string `protobuf:"bytes,15,opt,name=Distance,proto3" json:"Distance,omitempty"` // d
	// min_* and max_* are the bounding box parameters
	MinX float32 `protobuf:"fixed32,16,opt,name=min_x,json=minX,proto3" json:"min_x,omitempty"`
	MinY float32 `protobuf:"fixed32,17,opt,name=min_y,json=minY,proto3" json:"min_y,omitempty"`
	MaxX float32 `protobuf:"fixed32,18,opt,name=max_x,json=maxX,proto3" json:"max_x,omitempty"`
	MaxY float32 `protobuf:"fixed32,19,opt,name=max_y,json=maxY,proto3" json:"max_y,omitempty"`
	// add support for polygon
	Field   []string `protobuf:"bytes,20,rep,name=field,proto3" json:"field,omitempty"`
	GeoType GeoType  `protobuf:"varint,21,opt,name=geoType,proto3,enum=fragments.GeoType" json:"geoType,omitempty"`
	// qr
	QueryRefinement string         `protobuf:"bytes,22,opt,name=QueryRefinement,proto3" json:"QueryRefinement,omitempty"`
	SearchAfter     []byte         `protobuf:"bytes,23,opt,name=searchAfter,proto3" json:"searchAfter,omitempty"`
	ItemFormat      ItemFormatType `protobuf:"varint,24,opt,name=itemFormat,proto3,enum=fragments.ItemFormatType" json:"itemFormat,omitempty"`
	Paging          bool           `protobuf:"varint,25,opt,name=Paging,proto3" json:"Paging,omitempty"`
	CollapseOn      string         `protobuf:"bytes,26,opt,name=collapseOn,proto3" json:"collapseOn,omitempty"`
	CollapseSize    int32          `protobuf:"varint,27,opt,name=collapseSize,proto3" json:"collapseSize,omitempty"`
	CollapseSort    string         `protobuf:"bytes,28,opt,name=collapseSort,proto3" json:"collapseSort,omitempty"`
	Peek            string         `protobuf:"bytes,29,opt,name=peek,proto3" json:"peek,omitempty"`
	SortAsc         bool           `protobuf:"varint,30,opt,name=sortAsc,proto3" json:"sortAsc,omitempty"`
	Tree            *TreeQuery     `protobuf:"bytes,31,opt,name=tree,proto3" json:"tree,omitempty"`
	CalculatedTotal int64          `protobuf:"varint,32,opt,name=calculatedTotal,proto3" json:"calculatedTotal,omitempty"`
	SessionID       string         `protobuf:"bytes,33,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	OrgID           string         `protobuf:"bytes,34,opt,name=OrgID,proto3" json:"OrgID,omitempty"`
	OrgIDKey        string         `protobuf:"bytes,35,opt,name=orgIDKey,proto3" json:"orgIDKey,omitempty"`
	CollapseFormat  string         `protobuf:"bytes,36,opt,name=collapseFormat,proto3" json:"collapseFormat,omitempty"`
	V1Mode          bool           `protobuf:"varint,37,opt,name=v1Mode,proto3" json:"v1Mode,omitempty"`
	// contains filtered or unexported fields
}

func DefaultSearchRequest

func DefaultSearchRequest(cfg *c.RawConfig) *SearchRequest

DefaultSearchRequest takes an Config Objects and sets the defaults

func NewSearchRequest

func NewSearchRequest(orgID string, params url.Values) (*SearchRequest, error)

NewSearchRequest builds a search request object from URL Parameters

func SearchRequestFromHex

func SearchRequestFromHex(s string) (*SearchRequest, error)

SearchRequestFromHex creates a SearchRequest object from a string

func (*SearchRequest) AddDateFilter

func (sr *SearchRequest) AddDateFilter(filter string) error

AddDateFilter adds a filter for Date Querying.

func (*SearchRequest) AddDateRangeFilter

func (sr *SearchRequest) AddDateRangeFilter(filter string) error

AddDateRangeFilter extracts a start and end date from the QueryFilter.Value add appends it to the QueryFilter Array.

func (*SearchRequest) AddFieldExistFilter

func (sr *SearchRequest) AddFieldExistFilter(filter string) error

AddFieldExistFilter adds a query to filter on records where this fields exists. This query for now works on any field level. It is not possible to specify context path.

func (*SearchRequest) AddQueryFilter

func (sr *SearchRequest) AddQueryFilter(filter string, id bool) error

AddQueryFilter adds a QueryFilter to the SearchRequest The raw query from the QueryString are added here. This function converts this string to a QueryFilter.

func (*SearchRequest) AddTreeFilter

func (sr *SearchRequest) AddTreeFilter(filter string) error

AddTreeFilter extracts a start and end date from the QueryFilter.Value add appends it to the QueryFilter Array.

func (*SearchRequest) Aggregations

func (sr *SearchRequest) Aggregations(fub *FacetURIBuilder) (map[string]elastic.Aggregation, error)

Aggregations returns the aggregations for the SearchRequest

func (*SearchRequest) CreateAggregationBySearchLabel

func (sr *SearchRequest) CreateAggregationBySearchLabel(path string, facet *FacetField, fub *FacetURIBuilder) (elastic.Aggregation, error)

CreateAggregationBySearchLabel creates Elastic aggregations for the nested fragment resources

func (*SearchRequest) CreateBinKey

func (sr *SearchRequest) CreateBinKey(key interface{}) ([]byte, error)

func (*SearchRequest) DecodeFacets

func (sr *SearchRequest) DecodeFacets(res *elastic.SearchResult, fb *FacetURIBuilder) ([]*QueryFacet, error)

DecodeFacets decodes the elastic aggregations in the SearchResult to fragments.QueryFacets The QueryFacets are returned in the order of the SearchRequest.FacetField

func (*SearchRequest) DecodeSearchAfter

func (sr *SearchRequest) DecodeSearchAfter() ([]interface{}, error)

DecodeSearchAfter returns an interface array decoded from []byte

func (*SearchRequest) DeepCopy

func (sr *SearchRequest) DeepCopy() (*SearchRequest, error)

DeepCopy create a deepCopy of the SearchRequest. This is used to calculate next NextScrollID values without change the current values of the request.

func (*SearchRequest) Descriptor deprecated

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) ElasticQuery

func (sr *SearchRequest) ElasticQuery() (elastic.Query, error)

ElasticQuery creates an ElasticSearch query from the Search Request This query can be passed into an elastic Search Object.

func (*SearchRequest) ElasticSearchService

func (sr *SearchRequest) ElasticSearchService(ec *elastic.Client) (*elastic.SearchService, *FacetURIBuilder, error)

ElasticSearchService creates the elastic SearchService for execution

func (*SearchRequest) GetCalculatedTotal

func (x *SearchRequest) GetCalculatedTotal() int64

func (*SearchRequest) GetCollapseFormat added in v0.2.1

func (x *SearchRequest) GetCollapseFormat() string

func (*SearchRequest) GetCollapseOn

func (x *SearchRequest) GetCollapseOn() string

func (*SearchRequest) GetCollapseSize

func (x *SearchRequest) GetCollapseSize() int32

func (*SearchRequest) GetCollapseSort

func (x *SearchRequest) GetCollapseSort() string

func (*SearchRequest) GetDisable

func (x *SearchRequest) GetDisable() []ResponseBlockType

func (*SearchRequest) GetDistance

func (x *SearchRequest) GetDistance() string

func (*SearchRequest) GetEnable

func (x *SearchRequest) GetEnable() []ResponseBlockType

func (*SearchRequest) GetFacetAndBoolType

func (x *SearchRequest) GetFacetAndBoolType() bool

func (*SearchRequest) GetFacetField

func (x *SearchRequest) GetFacetField() []*FacetField

func (*SearchRequest) GetFacetLimit

func (x *SearchRequest) GetFacetLimit() int32

func (*SearchRequest) GetField

func (x *SearchRequest) GetField() []string

func (*SearchRequest) GetGeoType

func (x *SearchRequest) GetGeoType() GeoType

func (*SearchRequest) GetHiddenQueryFilter

func (x *SearchRequest) GetHiddenQueryFilter() []*QueryFilter

func (*SearchRequest) GetItemFormat

func (x *SearchRequest) GetItemFormat() ItemFormatType

func (*SearchRequest) GetLatLong

func (x *SearchRequest) GetLatLong() string

func (*SearchRequest) GetMaxX

func (x *SearchRequest) GetMaxX() float32

func (*SearchRequest) GetMaxY

func (x *SearchRequest) GetMaxY() float32

func (*SearchRequest) GetMinX

func (x *SearchRequest) GetMinX() float32

func (*SearchRequest) GetMinY

func (x *SearchRequest) GetMinY() float32

func (*SearchRequest) GetOrgID added in v0.2.0

func (x *SearchRequest) GetOrgID() string

func (*SearchRequest) GetOrgIDKey added in v0.2.0

func (x *SearchRequest) GetOrgIDKey() string

func (*SearchRequest) GetPage

func (x *SearchRequest) GetPage() int32

func (*SearchRequest) GetPaging

func (x *SearchRequest) GetPaging() bool

func (*SearchRequest) GetPeek

func (x *SearchRequest) GetPeek() string

func (*SearchRequest) GetQuery

func (x *SearchRequest) GetQuery() string

func (*SearchRequest) GetQueryFilter

func (x *SearchRequest) GetQueryFilter() []*QueryFilter

func (*SearchRequest) GetQueryRefinement

func (x *SearchRequest) GetQueryRefinement() string

func (*SearchRequest) GetResponseFormatType

func (x *SearchRequest) GetResponseFormatType() ResponseFormatType

func (*SearchRequest) GetResponseSize

func (x *SearchRequest) GetResponseSize() int32

func (*SearchRequest) GetSearchAfter

func (x *SearchRequest) GetSearchAfter() []byte

func (*SearchRequest) GetSessionID

func (x *SearchRequest) GetSessionID() string

func (*SearchRequest) GetSortAsc

func (x *SearchRequest) GetSortAsc() bool

func (*SearchRequest) GetSortBy

func (x *SearchRequest) GetSortBy() string

func (*SearchRequest) GetStart

func (x *SearchRequest) GetStart() int32

func (*SearchRequest) GetTree

func (x *SearchRequest) GetTree() *TreeQuery

func (*SearchRequest) GetV1Mode added in v0.2.1

func (x *SearchRequest) GetV1Mode() bool

func (*SearchRequest) NewUserQuery

func (sr *SearchRequest) NewUserQuery() (*Query, *BreadCrumbBuilder, error)

NewUserQuery creates an object with the user Query and the breadcrumbs

func (*SearchRequest) ProtoMessage

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect added in v0.1.8

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

func (*SearchRequest) RemoveQueryFilter

func (sr *SearchRequest) RemoveQueryFilter(filter string) error

RemoveQueryFilter removes a QueryFilter from the SearchRequest The raw query from the QueryString are added here.

func (*SearchRequest) Reset

func (x *SearchRequest) Reset()

func (*SearchRequest) ScrollPagers added in v0.1.7

func (sr *SearchRequest) ScrollPagers(total int64) (*ScrollPager, error)

func (*SearchRequest) SearchRequestToHex

func (sr *SearchRequest) SearchRequestToHex() (string, error)

SearchRequestToHex converts the SearchRequest to a hex string

func (*SearchRequest) String

func (x *SearchRequest) String() string

type SearchResultV1

type SearchResultV1 struct {
	Query      *Query            `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Pagination *Pagination       `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	Items      []*MetadataItemV1 `protobuf:"bytes,3,rep,name=items,proto3" json:"items,omitempty"`
	Facets     []*Facet          `protobuf:"bytes,4,rep,name=facets,proto3" json:"facets,omitempty"`
	// contains filtered or unexported fields
}

Full SearchResult

func (*SearchResultV1) Descriptor deprecated

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

Deprecated: Use SearchResultV1.ProtoReflect.Descriptor instead.

func (*SearchResultV1) GetFacets

func (x *SearchResultV1) GetFacets() []*Facet

func (*SearchResultV1) GetItems

func (x *SearchResultV1) GetItems() []*MetadataItemV1

func (*SearchResultV1) GetPagination

func (x *SearchResultV1) GetPagination() *Pagination

func (*SearchResultV1) GetQuery

func (x *SearchResultV1) GetQuery() *Query

func (*SearchResultV1) ProtoMessage

func (*SearchResultV1) ProtoMessage()

func (*SearchResultV1) ProtoReflect added in v0.1.8

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

func (*SearchResultV1) Reset

func (x *SearchResultV1) Reset()

func (*SearchResultV1) String

func (x *SearchResultV1) String() string

type SearchResultWrapperV1

type SearchResultWrapperV1 struct {
	Result *SearchResultV1 `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResultWrapperV1) Descriptor deprecated

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

Deprecated: Use SearchResultWrapperV1.ProtoReflect.Descriptor instead.

func (*SearchResultWrapperV1) GetResult

func (x *SearchResultWrapperV1) GetResult() *SearchResultV1

func (*SearchResultWrapperV1) ProtoMessage

func (*SearchResultWrapperV1) ProtoMessage()

func (*SearchResultWrapperV1) ProtoReflect added in v0.1.8

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

func (*SearchResultWrapperV1) Reset

func (x *SearchResultWrapperV1) Reset()

func (*SearchResultWrapperV1) String

func (x *SearchResultWrapperV1) String() string

type SparqlUpdate

type SparqlUpdate struct {
	Triples       string `json:"triples"`
	NamedGraphURI string `json:"graphUri"`
	Spec          string `json:"datasetSpec"`
	SpecRevision  int    `json:"specRevision"`
}

SparqlUpdate contains the elements to perform a SPARQL update query

func (SparqlUpdate) String

func (su SparqlUpdate) String() string

func (SparqlUpdate) TripleCount

func (su SparqlUpdate) TripleCount() (int, error)

TripleCount counts the number of Ntriples in a string

type StatCounter

type StatCounter struct {
	Value    string `json:"value"`
	DocCount int    `json:"docCount"`
}

StatCounter holds value counters for statistics overviews

type System

type System struct {
	Slug               string `json:"slug,omitempty"`
	Spec               string `json:"spec,omitempty"`
	Thumbnail          string `json:"thumbnail,omitempty"`
	Preview            string `json:"preview,omitempty"`
	Caption            string `json:"caption,omitempty"`
	AboutURI           string `json:"about_uri,omitempty"`
	SourceURI          string `json:"source_uri,omitempty"`
	GraphName          string `json:"graph_name,omitempty"`
	CreatedAt          string `json:"created_at,omitempty"`
	ModifiedAt         string `json:"modified_at,omitempty"`
	SourceGraph        string `json:"source_graph,omitempty"`
	ProxyResourceGraph string `json:"proxy_resource_graph,omitempty"`
	WebResourceGraph   string `json:"web_resource_graph,omitempty"`
	ContentHash        string `json:"content_hash,omitempty"`
	HasGeoHash         string `json:"hasGeoHash"`
	HasDigitalObject   string `json:"hasDigitalObject"`
	HasLandingPage     string `json:"hasLandingPage"`
	HasDeepZoom        string `json:"hasDeepZoom"`
}

System holds system information for each IndexDoc

func NewSystem

func NewSystem(indexDoc map[string]interface{}, fb *FragmentBuilder) *System

NewSystem generates system info for the V1 doc

type Tree

type Tree struct {
	Leaf             string              `json:"leaf,omitempty"`
	Parent           string              `json:"parent,omitempty"`
	Label            string              `json:"label"`
	CLevel           string              `json:"cLevel"`
	UnitID           string              `json:"unitID"`
	Type             string              `json:"type"`
	HubID            string              `json:"hubID"`
	ChildCount       int                 `json:"childCount"`
	Depth            int                 `json:"depth"`
	HasChildren      bool                `json:"hasChildren"`
	HasDigitalObject bool                `json:"hasDigitalObject"`
	HasRestriction   bool                `json:"hasRestriction"`
	DaoLink          string              `json:"daoLink,omitempty"`
	ManifestLink     string              `json:"manifestLink,omitempty"`
	MimeTypes        []string            `json:"mimeType,omitempty"`
	DOCount          int                 `json:"doCount"`
	Inline           []*Tree             `json:"inline,omitempty"`
	SortKey          uint64              `json:"sortKey"`
	Periods          []string            `json:"periods"`
	Content          []string            `json:"content,omitempty"`
	RawContent       []string            `json:"rawContent,omitempty"`
	Access           string              `json:"access,omitempty"`
	Title            string              `json:"title,omitempty"`
	Description      []string            `json:"description,omitempty"`
	InventoryID      string              `json:"inventoryID,omitempty"`
	AgencyCode       string              `json:"agencyCode,omitempty"`
	PeriodDesc       []string            `json:"periodDesc,omitempty"`
	Material         string              `json:"material,omitempty"`
	PhysDesc         string              `json:"physDesc,omitempty"`
	Fields           map[string][]string `json:"fields,omitempty"`
}

Tree holds all the core information for building Navigational Trees from RDF graphs

func InlineTree

func InlineTree(nodes []*Tree, tq *TreeQuery, total int64) ([]*Tree, map[string]*Tree, error)

InlineTree creates a nested tree from an Array of *Tree

func TreeNode

func TreeNode(ctx context.Context, hubID string) (*Tree, error)

func (*Tree) DeepCopy

func (t *Tree) DeepCopy() *Tree

DeepCopy creates a deep-copy of a Tree.

func (*Tree) PageEntry

func (t *Tree) PageEntry() *TreePageEntry

PageEntry creates a paging entry for a tree element.

type TreeDescription

type TreeDescription struct {
	Name        string   `json:"name"`
	InventoryID string   `json:"inventoryID"`
	Abstract    []string `json:"abstract"`
	Owner       string   `json:"owner"`
	Period      []string `json:"period"`
}

TreeDescription describes the meta-information for an Archival Finding Aid tree

type TreeHeader

type TreeHeader struct {
	ActiveID          string          `json:"activeID"`
	ExpandedIDs       map[string]bool `json:"expandedIDs,omitempty"`
	PreviousScrollIDs []string        `json:"previousScrollIDs,omitempty"`
	Paging            *TreePaging     `json:"paging,omitempty"`
	Searching         *TreeSearching  `json:"searching,omitempty"`
}

TreeHeader contains rendering hints for the consumer of the TreeView API.

type TreeNavigator

type TreeNavigator struct {
	Cursor  int               `json:"cursor"`
	Total   int               `json:"total"`
	CLevel  string            `json:"cLevel"`
	Entries map[string]string `json:"entries"` // key is the CLevel
}

TreeNavigator possible remove

type TreePageEntry

type TreePageEntry struct {
	CLevel      string          `json:"cLevel"`
	SortKey     int32           `json:"sortKey"`
	ExpandedIDs map[string]bool `json:"expandedIDs,omitempty"`
	Depth       int32           `json:"depth"`
}

TreePageEntry contains information how to merge pages from different responses.

func (*TreePageEntry) CreateTreePage

func (tpe *TreePageEntry) CreateTreePage(
	nodeMap map[string]*Tree,
	rootNodes []*Tree,
	appending bool,
	sortFrom int32,
) map[string][]*Tree

CreateTreePage creates a paging entry that can be used to merge the EAD tree between different paging request.

func (*TreePageEntry) SameLeaf

func (tpe *TreePageEntry) SameLeaf(other *TreePageEntry) bool

SameLeaf determines if two TreePageEntry are in the same tree leaf.

type TreePaging

type TreePaging struct {
	PageSize        int32                    `json:"pageSize,omitempty"`
	NrPages         int32                    `json:"nrPages,omitempty"`
	HasNext         bool                     `json:"hasNext"`
	HasPrevious     bool                     `json:"hasPrevious"`
	PageNext        int32                    `json:"pageNext,omitempty"`
	PagePrevious    int32                    `json:"pagePrevious,omitempty"`
	PageCurrent     []int32                  `json:"pageCurrent,omitempty"`
	PageFirst       int32                    `json:"pageFirst"`
	PageLast        int32                    `json:"pageLast"`
	ResultFirst     *TreePageEntry           `json:"resultFirst,omitempty"`
	ResultLast      *TreePageEntry           `json:"resultLast,omitempty"`
	ResultActive    *TreePageEntry           `json:"resultActive,omitempty"`
	HitsOnPage      map[int32]*TreePageEntry `json:"hitsOnPage,omitempty"`
	HitsOnPageCount int32                    `json:"hitsOnPageCount,omitempty"`
	HitsTotalCount  int32                    `json:"hitsTotalCount,omitempty"`
	ActiveHit       int32                    `json:"activeHit,omitempty"`
	SameLeaf        bool                     `json:"sameLeaf"`
	IsSearch        bool                     `json:"isSearch"`
}

TreePaging contains rendering hints for Paging through a Tree and Tree search-results

func (*TreePaging) CalculatePaging

func (tp *TreePaging) CalculatePaging()

CalculatePaging calculates all the paging information. This applies to searching and normal paging.

type TreeQuery

type TreeQuery struct {
	CLevel           string   `protobuf:"bytes,1,opt,name=cLevel,proto3" json:"cLevel,omitempty"`
	Leaf             string   `protobuf:"bytes,2,opt,name=leaf,proto3" json:"leaf,omitempty"`
	Parent           string   `protobuf:"bytes,3,opt,name=parent,proto3" json:"parent,omitempty"`
	Type             []string `protobuf:"bytes,4,rep,name=type,proto3" json:"type,omitempty"`
	Depth            []string `protobuf:"bytes,5,rep,name=depth,proto3" json:"depth,omitempty"`
	FillTree         bool     `protobuf:"varint,6,opt,name=fillTree,proto3" json:"fillTree,omitempty"`
	ChildCount       string   `protobuf:"bytes,7,opt,name=childCount,proto3" json:"childCount,omitempty"`
	Label            string   `protobuf:"bytes,8,opt,name=label,proto3" json:"label,omitempty"`
	Spec             string   `protobuf:"bytes,9,opt,name=spec,proto3" json:"spec,omitempty"`
	UnitID           string   `protobuf:"bytes,10,opt,name=unitID,proto3" json:"unitID,omitempty"`
	CursorHint       int32    `protobuf:"varint,11,opt,name=cursorHint,proto3" json:"cursorHint,omitempty"`
	MimeType         []string `protobuf:"bytes,12,rep,name=mimeType,proto3" json:"mimeType,omitempty"`
	HasRestriction   bool     `protobuf:"varint,13,opt,name=hasRestriction,proto3" json:"hasRestriction,omitempty"`
	HasDigitalObject bool     `protobuf:"varint,14,opt,name=hasDigitalObject,proto3" json:"hasDigitalObject,omitempty"`
	Page             []int32  `protobuf:"varint,15,rep,packed,name=page,proto3" json:"page,omitempty"`
	PageSize         int32    `protobuf:"varint,16,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	AllParents       bool     `protobuf:"varint,17,opt,name=allParents,proto3" json:"allParents,omitempty"`
	IsPaging         bool     `protobuf:"varint,18,opt,name=isPaging,proto3" json:"isPaging,omitempty"`
	IsSearch         bool     `protobuf:"varint,19,opt,name=isSearch,proto3" json:"isSearch,omitempty"`
	PageMode         string   `protobuf:"bytes,20,opt,name=pageMode,proto3" json:"pageMode,omitempty"`
	Query            string   `protobuf:"bytes,21,opt,name=query,proto3" json:"query,omitempty"`
	WithFields       bool     `protobuf:"varint,22,opt,name=withFields,proto3" json:"withFields,omitempty"`
	OrgID            string   `protobuf:"bytes,23,opt,name=orgID,proto3" json:"orgID,omitempty"`
	// contains filtered or unexported fields
}

func (*TreeQuery) Descriptor deprecated

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

Deprecated: Use TreeQuery.ProtoReflect.Descriptor instead.

func (*TreeQuery) GetAllParents

func (x *TreeQuery) GetAllParents() bool

func (*TreeQuery) GetCLevel

func (x *TreeQuery) GetCLevel() string

func (*TreeQuery) GetChildCount

func (x *TreeQuery) GetChildCount() string

func (*TreeQuery) GetCursorHint

func (x *TreeQuery) GetCursorHint() int32

func (*TreeQuery) GetDepth

func (x *TreeQuery) GetDepth() []string

func (*TreeQuery) GetFillTree

func (x *TreeQuery) GetFillTree() bool

func (*TreeQuery) GetHasDigitalObject

func (x *TreeQuery) GetHasDigitalObject() bool

func (*TreeQuery) GetHasRestriction

func (x *TreeQuery) GetHasRestriction() bool

func (*TreeQuery) GetIsPaging

func (x *TreeQuery) GetIsPaging() bool

func (*TreeQuery) GetIsSearch

func (x *TreeQuery) GetIsSearch() bool

func (*TreeQuery) GetLabel

func (x *TreeQuery) GetLabel() string

func (*TreeQuery) GetLeaf

func (x *TreeQuery) GetLeaf() string

func (*TreeQuery) GetMimeType

func (x *TreeQuery) GetMimeType() []string

func (*TreeQuery) GetOrgID added in v0.3.0

func (x *TreeQuery) GetOrgID() string

func (*TreeQuery) GetPage

func (x *TreeQuery) GetPage() []int32

func (*TreeQuery) GetPageMode

func (x *TreeQuery) GetPageMode() string

func (*TreeQuery) GetPageSize

func (x *TreeQuery) GetPageSize() int32

func (*TreeQuery) GetParent

func (x *TreeQuery) GetParent() string

func (*TreeQuery) GetPreviousScrollIDs

func (tq *TreeQuery) GetPreviousScrollIDs(cLevel string, sr *SearchRequest, pager *ScrollPager) ([]string, error)

GetPreviousScrollIDs returns scrollIDs up to the cLevel This information can be used to construct the previous search results when both the UnitID and the Label are being queried

func (*TreeQuery) GetQuery

func (x *TreeQuery) GetQuery() string

func (*TreeQuery) GetSpec

func (x *TreeQuery) GetSpec() string

func (*TreeQuery) GetType

func (x *TreeQuery) GetType() []string

func (*TreeQuery) GetUnitID

func (x *TreeQuery) GetUnitID() string

func (*TreeQuery) GetWithFields added in v0.1.1

func (x *TreeQuery) GetWithFields() bool

func (*TreeQuery) IsExpanded

func (tq *TreeQuery) IsExpanded() bool

IsExpanded returns if the tree query contains a query that puts the active ID expanded in the tree

func (*TreeQuery) IsNavigatedQuery

func (tq *TreeQuery) IsNavigatedQuery() bool

IsNavigatedQuery returns if there is both a query and active ID

func (*TreeQuery) PreviousCurrentNextPage

func (tq *TreeQuery) PreviousCurrentNextPage() (int32, int32, int32)

PreviousCurrentNextPage returns the previous and next page based on the TreeQuery.

This does not take max boundaries based on number of records returned into account.

func (*TreeQuery) ProtoMessage

func (*TreeQuery) ProtoMessage()

func (*TreeQuery) ProtoReflect added in v0.1.8

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

func (*TreeQuery) Reset

func (x *TreeQuery) Reset()

func (*TreeQuery) SearchPages

func (tq *TreeQuery) SearchPages(sortKey int32) ([]int32, error)

SearchPages returns the active search pages for a given sortKey

func (*TreeQuery) String

func (x *TreeQuery) String() string

func (*TreeQuery) TreePagingSize

func (tq *TreeQuery) TreePagingSize() int32

TreePagingSize returns the relative size of the paging window based on the number of pages. This is used to set the ElasticSearch responseSize.

type TreeSearching

type TreeSearching struct {
	IsSearch    bool   `json:"isSearch"`
	HitsTotal   int32  `json:"hitsTotal"`
	CurrentHit  int32  `json:"currentHit"`
	HasNext     bool   `json:"hasNext"`
	HasPrevious bool   `json:"hasPrevious"`
	ByLabel     string `json:"byLabel,omitempty"`
	ByUnitID    string `json:"byUnitID,omitempty"`
	ByQuery     string `json:"byQuery,omitempty"`
}

TreeSearching contains rendering hints for the search results in the TreeView API.

func (*TreeSearching) SetPreviousNext

func (ts *TreeSearching) SetPreviousNext(start int32)

SetPreviousNext calculate previous and next search paging

type TreeStats

type TreeStats struct {
	Spec     string
	Leafs    int64
	Depth    []StatCounter
	Children []StatCounter
	Type     []StatCounter
	PhysDesc []StatCounter
	MimeType []StatCounter
}

TreeStats holds all the information for a navigation tree for a Dataset

func CreateTreeStats

func CreateTreeStats(ctx context.Context, orgID, spec string) (*TreeStats, error)

CreateTreeStats creates a statistics overview

type WebTriples

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

func NewWebTriples

func NewWebTriples() *WebTriples

func (*WebTriples) Append

func (wt *WebTriples) Append(s string, t *r.Triple)

Jump to

Keyboard shortcuts

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