# Functions
NewConfig returns an instance of Config with defaults.
No description provided by the author
NewPointsWriter returns a new instance of PointsWriter for a node.
NewRemoteMapper returns a new remote mapper using the given connection.
NewService returns a new instance of Service.
NewShardMapper returns a mapper of local and remote shards.
NewShardMapping creates an empty ShardMapping.
NewShardWriter returns a new instance of ShardWriter.
No description provided by the author
ReadTLV reads a type-length-value record from r.
WriteTLV writes a type-length-value record to w.
# Constants
ConsistencyLevelAll requires all data nodes to acknowledge a write.
ConsistencyLevelAny allows for hinted hand off, potentially no write happened yet.
ConsistencyLevelOne requires at least one data node acknowledged a write.
ConsistencyLevelOne requires a quorum of data nodes to acknowledge a write.
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.
# Variables
ErrInvalidConsistencyLevel is returned when parsing the string version of a consistency level.
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.
# Structs
Config represents the configuration for the clustering service.
MapShardRequest represents the request to map a remote shard for a query.
MapShardResponse represents the response returned from a remote MapShardRequest call.
PointsWriter handles writes across multiple local and remote data nodes.
RemoteMapper implements the tsdb.Mapper interface.
Service processes data received over raw TCP connections.
ShardMapper is responsible for providing mappers for requested shards.
ShardMapping contains a mapping of a shards to a points.
ShardWriter writes a set of points to a shard.
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.
# Type aliases
ConsistencyLevel represent a required replication criteria before a write can be returned as successful.