sender

type Chain interface {
	GetLatestBlockEventId() (uint64, error)
	GetEvent(eventId uint64) (byte, []types.Hash, error)
	GetConfirmSubLedgerBySnapshotBlocks(snapshotBlocks []*ledger.SnapshotBlock) (map[types.Address][]*ledger.AccountBlock, error)
	vm_context.Chain
}

type KafkaSender struct {
	// contains filtered or unexported fields
}

type MqAccountBlock struct {
	ledger.AccountBlock

	Balance     *big.Int      `json:"balance"`
	FromAddress types.Address `json:"fromAddress"`
	Timestamp   int64         `json:"timestamp"`

	ParsedData string `json:"parsedData"`
	SendData   []byte `json:"sendData"`
}

type MqSnapshotBlock struct {
	*ledger.SnapshotBlock
	MqSnapshotContent MqSnapshotContent `json:"snapshotContent"`
	Producer          types.Address     `json:"producer"`
	Timestamp         int64             `json:"timestamp"`
}

type MqSnapshotContent map[types.Address]*MqSnapshotContentItem

type MqSnapshotContentItem struct {
	Start *ledger.HashHeight `json:"start"`
	End   *ledger.HashHeight `json:"end"`
}

type Producer struct {
	// contains filtered or unexported fields
}