DecodeLV reads the length-value record from r and unmarshals it into v.

DecodeTLV reads the type-length-value record from r and unmarshals it into v.

EncodeLV encodes v to a binary format and writes the length-value record to w.

EncodeTLV encodes v to a binary format and writes the record-length-value record to w.

NewBoundedPool returns a new pool based on buffered channels with an initial capacity, maximum capacity and timeout to wait for a connection from the pool.

NewConfig returns an instance of Config with defaults.

NewNodeBalancer create a shuffled, round-robin balancer so that multiple instances will return nodes in randomized order and each each returned node will be repeated in a cycle.

NewPointsWriter returns a new instance of PointsWriter for a node.

NewService returns a new instance of Service.

NewShardMapping creates an empty ShardMapping.

ReadLV reads the length-value from a TLV record.

ReadTLV reads a type-length-value record from r.

ReadType reads the type from a TLV record.

WriteLV writes the length-value in a TLV record to w.

WriteTLV writes a type-length-value record to w.

WriteType writes the type in a TLV record to w.

DefaultMaxConcurrentQueries is the maximum number of running queries.

DefaultMaxRemoteWriteConnections is the maximum number of open connections that will be available for remote writes to another host.

DefaultMaxSelectPointN is the maximum number of points a SELECT can process.

DefaultMaxSelectSeriesN is the maximum number of series a SELECT can run.

DefaultShardMapperTimeout is the default timeout set on shard mappers.

DefaultShardWriterTimeout is the default timeout set on shard writers.

DefaultWriteTimeout is the default timeout for a complete write to succeed.

1GB.

MuxHeader is the header byte used in the TCP mux.

ErrPartialWrite is returned when a write partially succeeds but does not meet the requested consistency level.

ErrTimeout is returned when a write times out.

ErrWriteFailed is returned when no writes succeeded.

Config represents the configuration for the clustering service.

CreateIteratorRequest represents a request to create a remote iterator.

CreateIteratorResponse represents a response from remote iterator creation.

ExecuteStatementRequest represents the a request to execute a statement on a node.

ExecuteStatementResponse represents the response returned from a remote ExecuteStatementRequest call.

ExpandSourcesRequest represents a request to expand regex sources.

ExpandSourcesResponse represents a response from source expansion.

FieldDimensionsRequest represents a request to retrieve unique fields & dimensions.

FieldDimensionsResponse represents a response from remote iterator creation.

IntoWriteRequest is a partial copy of cluster.WriteRequest.

PointsWriter handles writes across multiple local and remote data nodes.

SeriesKeysRequest represents a request to retrieve a list of series keys.

SeriesKeysResponse represents a response from retrieving series keys.

Service processes data received over raw TCP connections.

ShardMapping contains a mapping of a shards to a points.

StatementExecutor executes a statement in the query.

WritePointsRequest represents a request to write point data to the cluster.

WriteShardRequest represents the a request to write a slice of points to a shard.

WriteShardResponse represents the response returned from a remote WriteShardRequest call.

Balancer represents a load-balancing algorithm for a set of nodes.

MetaClient is an interface for accessing meta data.

ShardIteratorCreator is an interface for creating an IteratorCreator to access a specific shard.

TSDBStore is an interface for accessing the time series data store.

Factory is a function to create new connections.