Documentation
¶
Overview ¶
Package handler contains fns for encoding redis stream messages to block-replica AVRO segments
Index ¶
- func EncodeReplicaSegmentToAvro(replicaAvro *goavro.Codec, blockReplicaSegment interface{}) ([]byte, error)
- func ParseEventToBlockReplica(e event.Event, hash string, data *types.BlockReplica) (*event.BlockReplicaEvent, error)
- func ParseMessageToBlockReplica(msg redis.XMessage) (*event.BlockReplicaEvent, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EncodeReplicaSegmentToAvro ¶
func EncodeReplicaSegmentToAvro(replicaAvro *goavro.Codec, blockReplicaSegment interface{}) ([]byte, error)
EncodeReplicaSegmentToAvro encodes replica segment into AVRO binary encoding
func ParseEventToBlockReplica ¶ added in v1.1.6
func ParseEventToBlockReplica(e event.Event, hash string, data *types.BlockReplica) (*event.BlockReplicaEvent, error)
ParseEventToBlockReplica takes block-replica data and parses it to a block-replica event
func ParseMessageToBlockReplica ¶ added in v1.1.6
func ParseMessageToBlockReplica(msg redis.XMessage) (*event.BlockReplicaEvent, error)
ParseMessageToBlockReplica decodes the redis message to a BlockReplicaEvent
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.