# Functions
NewConfig returns an instance of Config with defaults.
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.
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.
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.
Service processes data received over raw TCP connections.
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.