dmesh

type BlockRangeData struct {
	TailBlock     uint64     `json:"tailBlockNum,omitempty"`
	TailBlockID   string     `json:"tailBlockID,omitempty"`
	TailBlockTime *time.Time `json:"tailBlockTime,omitempty"`
	HeadBlockData
}

type ConnectablePeer interface {
	Addr() string
	Conn() *grpc.ClientConn
	SetConn(conn *grpc.ClientConn)
	Close() error
	ResetConn() error
}

type GenericPeer struct {
	sync.RWMutex

	Ready bool       `json:"ready,omitempty"` // should be ready when service is live
	Host  string     `json:"host,omitempty"`  // search-liverouter-v2-1-59f98966b8-vzzsb
	Boot  *time.Time `json:"boot,omitempty"`
	// contains filtered or unexported fields
}

type HeadBlockData struct {
	IrrBlock      uint64     `json:"irrBlockNum,omitempty"`
	IrrBlockID    string     `json:"irrBlockID,omitempty"`
	IrrBlockTime  *time.Time `json:"irrBlockTime,omitempty"`
	HeadBlock     uint64     `json:"headBlockNum,omitempty"`
	HeadBlockID   string     `json:"headBlockID,omitempty"`
	HeadBlockTime *time.Time `json:"headBlockTime,omitempty"`
}

type MergeablePeer interface {
	// Merge copies from `in` any fields that could have moved, when
	// watching from etcd.
	Merge(in Peer)
}

type Peer interface {
	SetKey(string) error
	Key() string
}

type PeerEvent struct {
	EventName string
	Peer      Peer
	PeerKey   string
}

type RelayerPeer struct {
	GenericPeer
	HeadBlockData

	HighBlockNum uint64 `json:"high_blk"`
}

type SearchPeer struct {
	GenericPeer
	BlockRangeData

	ServesResolveForks bool `json:"resolveForks,omitempty"` // peer can resolve forks
	ServesReversible   bool `json:"reversible,omitempty"`   // peer serves the reversible segment of the chain, and is capable of navigating it
	HasMovingHead      bool `json:"headMoves,omitempty"`    // false for frozen ranges
	HasMovingTail      bool `json:"tailMoves,omitempty"`    // whether the process truncates its lower blocks

	ShardSize uint64 `json:"shardSize"`
	TierLevel uint32 `json:"tier"` // Frozen archives, first segments, are lower tiers (0, 1), and those at the tip are higher, more chances we roll out new ones at the tip of the chain.
	// contains filtered or unexported fields
}