solr

Mar 2, 2022

Changes in this version

type SolrZK

+ Close func()

Mar 2, 2022

Changes in this version

type Zookeeper

+ Close func()

Jun 15, 2018

Changes in this version

+ func ConnectionTimeout(seconds int) func(*solrHttp)

Jun 14, 2018

Changes in this version

+ func QueryRouter(router Router) func(*solrHttp)

+ type Router interface

+ AddSearchResult func(t time.Duration, uri string, statusCode int, err error)

+ GetUriFromList func(urisIn []string) string

+ func NewAdaptiveRouter(recency int) Router

+ func NewRoundRobinRouter() Router

Oct 6, 2017

Changes in this version

+ func PreferLocalShards(preferLocalShards bool) func(url.Values)

type SolrHTTP

+ Select func(nodeUris []string, opts ...func(url.Values)) (SolrResponse, error)

type SolrHttpRetrier

+ func (s *SolrHttpRetrier) Select(nodeUris []string, opts ...func(url.Values)) (SolrResponse, error)

Jul 18, 2017

Changes in this version

type Logger

+ Debug func(v interface{})

+ Error func(err error)

+ Info func(v interface{})

+ type SolrLogger struct

+ func (l *SolrLogger) Debug(v interface{})

+ func (l *SolrLogger) Error(err error)

+ func (l *SolrLogger) Info(v interface{})

+ func (l *SolrLogger) Printf(format string, v ...interface{})

+ type SolrMinRFError struct

+ MinRF int

type Zookeeper

+ ZKLogger func(l Logger)

Jul 13, 2017

Changes in this version

+ func SolrZKLogger(logger Logger) func(s *solrZkInstance)

Jul 13, 2017

Changes in this version

+ func ReadTimeout(seconds int) func(*solrHttp)

+ func WriteTimeout(seconds int) func(*solrHttp)

Jul 7, 2017

Changes in this version

+ func InsecureSkipVerify(insecureSkipVerify bool) func(*solrHttp)

Jul 7, 2017

Changes in this version

+ func VerifyCert(verify bool) func(*solrHttp)

Jun 6, 2017

Changes in this version

type CompositeKey

+ Bits uint

May 23, 2017

Changes in this version

+ func SleepTimeMS(sleepTimeMS int) func(*solrZkInstance)

type Zookeeper

+ IsConnected func() bool

May 19, 2017

Changes in this version

type Shard

+ Name string

type SolrLocator

+ GetShardFromRoute func(route string) (string, error)

May 16, 2017

Changes in this version

type SolrZK

+ UseHTTPS func() (bool, error)

May 9, 2017

Changes in this version

type SolrZK

+ GetSolrLocator func() SolrLocator

May 7, 2017

Changes in this version

+ type SolrLocator interface

+ GetLeaders func(docID string) ([]string, error)

+ GetLeadersAndReplicas func(docID string) ([]string, error)

+ GetReplicaUris func(baseURL string) ([]string, error)

+ GetReplicasFromRoute func(route string) ([]string, error)

+ func GetSolrLocator(solrZk SolrZK) SolrLocator

May 5, 2017

Changes in this version

+ var ErrNotFound = NewNotFoundError("Not found")

+ func Cert(cert string) func(*solrHttp)

+ func ClusterStateVersion(version int, collection string) func(url.Values)

+ func Commit(commit bool) func(url.Values)

+ func Cursor(c string) func(url.Values)

+ func DefaultRows(rows uint32) func(*solrHttp)

+ func DeleteStreamBody(filter string) func(url.Values)

+ func FilterQuery(fq string) func(url.Values)

+ func GetDocIdFromDoc(m map[string]interface{}) string

+ func GetVersionFromDoc(m map[string]interface{}) int

+ func HTTPClient(cli HTTPer) func(*solrHttp)

+ func Hash(key CompositeKey) (int32, error)

+ func HttpLogger(logger Logger) func(*solrHttp)

+ func MinRF(minRf int) func(*solrHttp)

+ func NewNotFoundError(error string) error

+ func NewSolrBatchError(err error) error

+ func NewSolrError(status int, message string) error

+ func NewSolrInternalError(status int, message string) error

+ func NewSolrLeaderError(docID string) error

+ func NewSolrMapParseError(bucket string, userId int, m map[string]interface{}) error

+ func NewSolrParseError(status int, message string) error

+ func NewSolrRFError(rf, minRF int) error

+ func Password(password string) func(*solrHttp)

+ func Query(q string) func(url.Values)

+ func Route(r string) func(url.Values)

+ func Rows(rows uint32) func(url.Values)

+ func Sort(s string) func(url.Values)

+ func Start(start uint32) func(url.Values)

+ func UrlVals(urlVals url.Values) func(url.Values)

+ func User(user string) func(*solrHttp)

+ type Adds map[string]int

+ type ClusterProps struct

+ UrlScheme string

+ type ClusterState struct

+ Collections map[string]Collection

+ LiveNodes []string

+ Version int

+ type Collection struct

+ ReplicationFactor string

+ Shards map[string]Shard

+ type CompositeKey struct

+ DocID string

+ ShardKey string

+ func NewCompositeKey(id string) (CompositeKey, error)

+ type DeleteRequest struct

+ Delete []string

+ type HTTPer interface

+ Do func(*http.Request) (*http.Response, error)

+ type HashRange struct

+ High int32

+ Low int32

+ func ConvertToHashRange(hashRange string) (HashRange, error)

+ type Logger interface

+ Fatal func(v ...interface{})

+ Fatalf func(format string, v ...interface{})

+ Panic func(v ...interface{})

+ Panicf func(format string, v ...interface{})

+ Print func(v ...interface{})

+ Printf func(format string, v ...interface{})

+ Println func(v ...interface{})

+ type NotFoundError struct

+ func (err NotFoundError) Error() string

+ type Replica struct

+ BaseURL string

+ Core string

+ Leader string

+ NodeName string

+ State string

+ type Response struct

+ Docs []map[string]interface{}

+ NumFound uint32

+ Start int

+ type Shard struct

+ Range string

+ Replicas map[string]Replica

+ State string

+ type SolrBatchError struct

+ type SolrError struct

+ func (err SolrError) Error() string

+ type SolrHTTP interface

+ Logger func() Logger

+ Read func(nodeUris []string, opts ...func(url.Values)) (SolrResponse, error)

+ Update func(nodeUris []string, jsonDocs bool, doc interface{}, opts ...func(url.Values)) error

+ func NewSolrHTTP(solrZk SolrZK, collection string, options ...func(*solrHttp)) (SolrHTTP, error)

+ func NewSolrHttpRetrier(solrHttp SolrHTTP, retries int, exponentialBackoff time.Duration) SolrHTTP

+ type SolrHealthcheckResponse struct

+ DownReplicas []string

+ LiveNodes []string

+ RecoveryFailedReplicas []string

+ type SolrHttpRetrier struct

+ func (s *SolrHttpRetrier) Logger() Logger

+ func (s *SolrHttpRetrier) Read(nodeUris []string, opts ...func(url.Values)) (SolrResponse, error)

+ func (s *SolrHttpRetrier) Update(nodeUris []string, jsonDocs bool, doc interface{}, opts ...func(url.Values)) error

+ type SolrInternalError struct

+ type SolrLeaderError struct

+ type SolrMapParseError struct

+ func (err SolrMapParseError) Error() string

+ type SolrParseError struct

+ type SolrResponse struct

+ Adds Adds

+ NextCursorMark string

+ Params struct{ ... }

+ QTime int

+ Response Response

+ Status int

+ type SolrZK interface

+ GetClusterProps func() (ClusterProps, error)

+ GetClusterState func() (ClusterState, error)

+ GetLeaders func(docID string) ([]string, error)

+ GetLeadersAndReplicas func(docID string) ([]string, error)

+ GetReplicaUris func(baseURL string) ([]string, error)

+ GetReplicasFromRoute func(route string) ([]string, error)

+ GetZookeepers func() string

+ Listen func() error

+ Listening func() bool

+ func NewSolrZK(zookeepers string, zkRoot string, collectionName string, ...) SolrZK

+ type UpdateResponse struct

+ Error struct{ ... }

+ Response struct{ ... }

+ type Zookeeper interface

+ Connect func() error

+ Get func(path string) ([]byte, int, error)

+ GetClusterProps func() (ClusterProps, error)

+ GetClusterState func() (map[string]Collection, int, error)

+ GetClusterStateW func() (map[string]Collection, int, <-chan zk.Event, error)

+ GetConnectionString func() string

+ GetLeaderElectW func() (<-chan zk.Event, error)

+ GetLiveNodes func() ([]string, error)

+ GetLiveNodesW func() ([]string, <-chan zk.Event, error)

+ Poll func(path string, cb stateChanged)

+ func NewZookeeper(connectionString string, zkRoot string, collection string) Zookeeper