tx_heap_by_start_time.go

// Copyright (C) 2019-2021, Ava Labs, Inc. All rights reserved.
// See the file LICENSE for licensing terms.

package platformvm

import "time"

var _ TimedTxHeap = &txHeapByStartTime{}

type TimedTxHeap interface {
	TxHeap

	Timestamp() time.Time
}

type txHeapByStartTime struct {
	txHeap
}

func NewTxHeapByStartTime() TimedTxHeap {
	h := &txHeapByStartTime{}
	h.initialize(h)
	return h
}

func (h *txHeapByStartTime) Less(i, j int) bool {
	iTime := h.txs[i].tx.UnsignedTx.(TimedTx).StartTime()
	jTime := h.txs[j].tx.UnsignedTx.(TimedTx).StartTime()
	return iTime.Before(jTime)
}

func (h *txHeapByStartTime) Timestamp() time.Time {
	return h.Peek().UnsignedTx.(TimedTx).StartTime()
}