solr

type Adds map[string]int

type ClusterProps struct {
	UrlScheme string `json:"urlScheme"`
}

type ClusterState struct {
	LiveNodes   []string
	Version     int
	Collections map[string]Collection
}

type Collection struct {
	Shards            map[string]Shard `json:"shards"`
	ReplicationFactor string           `json:"replicationFactor"`
}

type CompositeKey struct {
	ShardKey string
	DocID    string
	Bits     uint
}

type Debug struct {
	Timing Timing `json:"timing"`
}

type DeleteRequest struct {
	Delete []string `json:"delete"`
}

type HTTPer interface {
	Do(*http.Request) (*http.Response, error)
}

type HashRange struct {
	Low  int32
	High int32
}

type HttpError struct {
	Message string
	Status  int
}

type Logger interface {
	Error(err error)
	Info(v ...interface{})
	Debug(v ...interface{})
	Printf(format string, v ...interface{})
}

type Replica struct {
	Core     string `json:"core"`
	Leader   string `json:"leader"`
	BaseURL  string `json:"base_url"`
	NodeName string `json:"node_name"`
	State    string `json:"state"`
}

type Response struct {
	NumFound uint32                   `json:"numFound"`
	Start    int                      `json:"start"`
	Docs     []map[string]interface{} `json:"docs"`
}

type Router interface {
	GetUriFromList(urisIn []string) string
}

type Shard struct {
	Name     string             `json:"-"`
	Range    string             `json:"range"`
	State    string             `json:"state"`
	Replicas map[string]Replica `json:"replicas"`
}

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

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

type SolrHTTP interface {
	Select(nodeUris []string, opts ...func(url.Values)) (SolrResponse, error)
	Update(nodeUris []string, singleDoc bool, doc interface{}, opts ...func(url.Values)) (UpdateResponse, error)
	Logger() Logger
}

type SolrHealthcheckResponse struct {
	LiveNodes              []string `json:"live_nodes"`
	DownReplicas           []string `json:"down_replicas"`
	RecoveryFailedReplicas []string `json:"recovery_failed_replicas"`
}

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

type SolrInternalError struct {
	SolrError
}

type SolrLeaderError struct {
	SolrError
}

type SolrLocator interface {
	GetLeaders(docID string) ([]string, error)
	GetReplicaUris() ([]string, error)
	GetReplicasFromRoute(route string) ([]string, error)
	GetShardFromRoute(route string) (string, error)
	GetLeadersAndReplicas(docID string) ([]string, error)
}

type SolrLogger struct {
	*log.Logger
}

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

type SolrMinRFError struct {
	SolrError
	MinRF int
}

type SolrParseError struct {
	SolrError
}

type SolrResponse struct {
	Status int `json:"status"`
	QTime  int `json:"qtime"`
	Params struct {
		Query  string `json:"q"`
		Indent string `json:"indent"`
		Wt     string `json:"wt"`
	} `json:"params"`
	Response       Response `json:"response"`
	Debug          *Debug   `json:"debug"`
	NextCursorMark string   `json:"nextCursorMark"`
	Adds           Adds     `json:"adds"`
}

type SolrZK interface {
	GetZookeepers() string
	GetClusterState() (ClusterState, error)
	GetClusterProps() (ClusterProps, error)
	Listen() error
	Listening() bool
	GetSolrLocator() SolrLocator
	UseHTTPS() (bool, error)
}

type StageTiming struct {
	Time float64 `json:"time"`
}

type Timing struct {
	Time    float64     `json:"time"`
	Prepare StageTiming `json:"prepare"`
	Process StageTiming `json:"process"`
}

type UpdateResponse struct {
	Response struct {
		Status int `json:"status"`
		QTime  int `json:"QTime"`
		RF     int `json:"rf"`
		MinRF  int `json:"min_rf"`
	} `json:"responseHeader"`

	// <adds> is a weird return value. It mixes ids with versions in a single slice, e.g.
	// ["id1",1233144,"id2",4122243], to get only the ids call AddedIDs afterwards
	Adds []interface{} `json:"adds"`

	Error struct {
		Metadata []string `json:"metadata"`
		Msg      string   `json:"msg"`
		Code     int      `json:"code"`
	}
}

type Zookeeper interface {
	IsConnected() bool
	Connect() error
	GetConnectionString() string
	Get(path string) ([]byte, int, error)
	Poll(path string, cb stateChanged)
	GetClusterState() (map[string]Collection, int, error)
	GetClusterStateW() (map[string]Collection, int, <-chan zk.Event, error)
	GetLiveNodes() ([]string, error)
	GetLiveNodesW() ([]string, <-chan zk.Event, error)
	GetLeaderElectW() (<-chan zk.Event, error)
	GetClusterProps() (ClusterProps, error)
	ZKLogger(l Logger)
}