solr

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2018 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddBasicAuthHeader 

func AddBasicAuthHeader(request *http.Request, solrConfig *SolrConfig)

AddBasicAuthHeader add Auth header with basic auth credentials

func AddNegotiateHeader 

func AddNegotiateHeader(request *http.Request, solrConfig *SolrConfig)

AddNegotiateHeader add WWW-Authenticate header (SPNEGO) in case of kerberos is enabled

func GenerateIniFile 

func GenerateIniFile(iniFileLocation string)

GenerateIniFile create an ini file to a specific location

func GenerateSolrConfig 

func GenerateSolrConfig(iniFileLocation string) (SolrConfig, SSHConfig)

GenerateSolrConfig create sample ini file for Solr data generation

func GenerateSolrData 

func GenerateSolrData(solrConfig *SolrConfig, sshConfig *SSHConfig, iniFileLocation string)

GenerateSolrData Use to generate Solr data, also scp keytab file to local if kerberos and ssl config is enabled

func GetSolrCollectionUri 

func GetSolrCollectionUri(solrConfig *SolrConfig, uriSuffix string) string

GetSolrCollectionUri gather Solr collection url with url context (if exists) and url suffix e.g.: url - https://myurl:8886, context: /solr, suffix: /update/json/docs = https://myurl:8886/solr/update/json/docs

Types

type BasicAuthConfig 

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

BasicAuthConfig hold authentication credentials

type KerberosConfig 

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

KerberosConfig holds kerberos related configurations

type SSHConfig 

type SSHConfig struct {
	Enabled          bool
	Username         string
	PrivateKeyPath   string
	DownloadLocation string
	RemoteKrb5Conf   string
	RemoteKeytab     string
	Hostname         string
}

SSHConfig holds SSH related configs that is used by the data generator (to gather keytabs if kerberos is enabled)

type SecurityConfig 

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

SecurityConfig holds security related configurations

func InitSecurityConfig 

func InitSecurityConfig(krb5Path string, keytabPath string, principal string, realm string) SecurityConfig

InitSecurityConfig set initial security config on start

type SolrClient 

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

SolrClient represents a Solr connection that is used to communicate with Solr HTTP endpoints

func NewSolrClient 

func NewSolrClient(solrConfig *SolrConfig) (*SolrClient, error)

NewSolrClient initialize a new Solr client based on configuration type

func (*SolrClient) Query 

func (solrClient *SolrClient) Query(solrQuery *SolrQuery) (bool, *SolrResponseData, error)

Query get Solr data based on parameters

func (*SolrClient) Update 

func (solrClient *SolrClient) Update(docs interface{}, parameters *url.Values, commit bool) (bool, *SolrResponseData, error)

Update send documents to Solr

type SolrConfig 

type SolrConfig struct {
	Url                   string
	Collection            string
	SecurityConfig        *SecurityConfig
	SolrUrlContext        string
	TlsConfig             TLSConfig
	Insecure              bool
	ConnectTimeoutSeconds int
}

SolrConfig holds Solr related configurations

type SolrDataProcessor 

type SolrDataProcessor struct {
	BatchContext *processor.BatchContext
	Mutex        *sync.Mutex
	SolrClient   *SolrClient
}

SolrDataProcessor type for processing Solr data

func (SolrDataProcessor) GetBatchContext 

func (p SolrDataProcessor) GetBatchContext() *processor.BatchContext

GetBatchContext gather batch context that will be used by processor

func (SolrDataProcessor) HandleError 

func (p SolrDataProcessor) HandleError(err error)

HandleError handle errors during time based buffer processing (it is not used by this generator)

func (SolrDataProcessor) Process 

func (p SolrDataProcessor) Process() error

Process send gathered data to Solr

type SolrDocument 

type SolrDocument map[string]interface{}

SolrDocument represents a Solr document (document map)

type SolrDocuments 

type SolrDocuments []SolrDocument

SolrDocuments holds array of Solr documents

type SolrQuery 

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

SolrQuery represents a solr query object

func CreateSolrQuery 

func CreateSolrQuery() *SolrQuery

CreateSolrQuery will create a new Solr query with empty queries

func (*SolrQuery) AddFacet 

func (q *SolrQuery) AddFacet(field string)

AddFacet add facet field

func (*SolrQuery) AddFields 

func (q *SolrQuery) AddFields(fields []string)

AddFields adding fields to Solr query

func (*SolrQuery) AddParam 

func (q *SolrQuery) AddParam(key, value string)

AddParam add query parameter for Solr query

func (*SolrQuery) AddPivotFields 

func (q *SolrQuery) AddPivotFields(pivotFields []string)

AddFields adding fields to Solr query

func (*SolrQuery) Encode 

func (q *SolrQuery) Encode() string

Encode transform Solr query parameters to string

func (*SolrQuery) FacetQuery 

func (q *SolrQuery) FacetQuery(query string)

FacetQuery sets facet query string

func (*SolrQuery) FilterQuery 

func (q *SolrQuery) FilterQuery(filterQuery string)

FilterQuery add filter query string

func (*SolrQuery) Query 

func (q *SolrQuery) Query(query string)

Query sets query string

func (*SolrQuery) Rows 

func (q *SolrQuery) Rows(rows int)

Rows sets rows parameter for Solr query

func (*SolrQuery) SetParam 

func (q *SolrQuery) SetParam(key, value string)

SetParam set query parameter for Solr query

func (*SolrQuery) Sort 

func (q *SolrQuery) Sort(sort string)

Sort sets sort for Solr query

func (*SolrQuery) Start 

func (q *SolrQuery) Start(start int)

Start sets start parameter for Solr query

type SolrResponse 

type SolrResponse struct {
	NumFound int32          `json:"numFound,omitempty"`
	Start    int32          `json:"start,omitempty"`
	MaxScore float32        `json:"maxScore,omitempty"`
	Docs     []SolrDocument `json:"docs,omitempty"`
}

SolrResponse represents a Solr HTTP response

type SolrResponseData 

type SolrResponseData struct {
	ResponseHeader SolrResponseHeader `json:"responseHeader"`
	Response       SolrResponse       `json:"response"`
}

SolrResponseData represents Solr response data that contains the response itself and the response header as well

type SolrResponseHeader 

type SolrResponseHeader struct {
	Status int32             `json:"status,omitempty"`
	QTime  int32             `json:"QTime,omitempty"`
	Params map[string]string `json:"params,omitempty"`
}

SolrResponseHeader represents Solr request headers from Solr HTTP response

type TLSConfig 

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

TLSConfig holds TLS related configurations

Source Files

View all Source files

Jump to

Keyboard shortcuts

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