Documentation
¶
Index ¶
- func EncodeKeyForForwardAggregation(originatorTableID uint64, sendingShardID uint64, sequence uint64, ...) []byte
- func EncodeKeyForForwardIngest(sourceID uint64, partitionID uint64, offset uint64, remoteConsumerID uint64) []byte
- func EncodePrevAndCurrentRow(prevValueBuff []byte, currValueBuff []byte) []byte
- func SendForwardBatches(forwardBatches map[uint64]*cluster.WriteBatch, clust cluster.Cluster) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EncodePrevAndCurrentRow ¶
func SendForwardBatches ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.