# Functions
NewConfig returns an instance of Config with defaults.
NewPointsWriter returns a new instance of PointsWriter for a node.
NewRemoteMaper returns a new remote mapper.
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.
DefaultShardWriterTimeout is the default timeout set on shard writers.
DefaultWriteTimeout is the default timeout for a complete write to succeed.
No description provided by the author
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 the clustering service.
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.