event

Documentation

Overview

Package event contains events/interfaces for raw and processsed block-replica objects

Index

• type BlockReplicaEvent
  • func (o *BlockReplicaEvent) GetBlockReplicaHash() string
  • func (o *BlockReplicaEvent) GetBlockReplicaString() string
  • func (o *BlockReplicaEvent) Type() string
• type Event
  • func NewBlockReplicaEvent() (Event, error)
• type ReplicaSegmentWrapped
• type ReplicationSegment

Types

type BlockReplicaEvent

type BlockReplicaEvent struct {
	Hash string           `json:"hash"`
	Data *ty.BlockReplica `json:"data"`
}

BlockReplicaEvent is a replication event coming from a redis stream

func (*BlockReplicaEvent) GetBlockReplicaHash

func (o *BlockReplicaEvent) GetBlockReplicaHash() string

GetBlockReplicaHash gets the block-replica hash

func (*BlockReplicaEvent) GetBlockReplicaString

func (o *BlockReplicaEvent) GetBlockReplicaString() string

GetBlockReplicaString gets the block-replica string

func (*BlockReplicaEvent) Type

func (o *BlockReplicaEvent) Type() string

Type gets the block-replica event types - block-specimen, block-result, or combined(block-replica)

type Event

type Event interface {
	GetBlockReplicaHash() string
	GetBlockReplicaString() string
}

Event allows for accessing the hash of block-replica event object

func NewBlockReplicaEvent

func NewBlockReplicaEvent() (Event, error)

NewBlockReplicaEvent creates a new block-replica event

type ReplicaSegmentWrapped

type ReplicaSegmentWrapped struct {
	ReplicationSegment
	IDBatch     []string
	SegmentName string
}

ReplicaSegmentWrapped wraps a ReplicationSegment with additional information

type ReplicationSegment

type ReplicationSegment struct {
	BlockReplicaEvent []*BlockReplicaEvent `json:"replicaEvent"`
	StartBlock        uint64               `json:"startBlock"`
	EndBlock          uint64               `json:"endBlock"`
	Elements          uint64               `json:"elements"`
}

ReplicationSegment is block replication segment that is converted to AVRO encoding