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.

TODO:取个达意的名字.

NewPointsWriter returns a new instance of PointsWriter for a node.

NewService returns a new instance of Service.

NewShardMapping creates an empty ShardMapping.

NewShardWriter returns a new instance of ShardWriter.

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.

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

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

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.

ClusterShardMapper implements a ShardMapper for local shards.

ShardMapper maps data sources to a list of shard information.

Config represents the configuration for the coordinator 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.

FieldDimensionsRequest represents a request to retrieve unique fields & dimensions.

FieldDimensionsResponse represents a response from remote iterator creation.

LocalTSDBStore embeds a tsdb.Store and implements IteratorCreator to satisfy the TSDBStore interface.

NodeDialer dials connections to a given node.

PointsWriter handles writes across multiple local and remote data nodes.

Service processes data received over raw TCP connections.

ShardMapping contains a mapping of shards to points.

ShardWriter writes a set of points to a shard.

Source contains the database and retention policy source for data.

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.

WriteStatistics keeps statistics related to the PointsWriter.

MetaClient is an interface for accessing meta data.

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

Factory is a function to create new connections.