utils

Documentation

Index

• Constants
• Variables
• func GetPort(addr string) (string, error)
• func Hash(result []byte) []byte
• func PrefixHex(in string) string
• type PriorityQueue
  • func (vq PriorityQueue) Len() int
  • func (vq PriorityQueue) Less(i, j int) bool
  • func (vq *PriorityQueue) Pop() interface{}
  • func (vq *PriorityQueue) Push(x interface{})
  • func (vq PriorityQueue) Swap(i, j int)
  • func (vq *PriorityQueue) Update(item *Queued, value []byte, priority int64)
• type Queued
  • func NewQueued(value []byte, priority int64, index int) *Queued
  • func (q Queued) Priority() int64
  • func (q Queued) Value() []byte

Constants

const HexPrefix = "0x"

Hex prefix

Variables

var ErrParsingAddress = errors.New("failed to parse network address")

Functions

func GetPort

func GetPort(addr string) (string, error)

Pick out the port from a full address

func Hash

func Hash(result []byte) []byte

Hash returns ripemd160 hash of the given input

func PrefixHex

func PrefixHex(in string) string

Types

type PriorityQueue

type PriorityQueue []*Queued

A PriorityQueue implements heap.Interface and holds Items.

func (PriorityQueue) Len

func (vq PriorityQueue) Len() int

func (PriorityQueue) Less

func (vq PriorityQueue) Less(i, j int) bool

func (*PriorityQueue) Pop

func (vq *PriorityQueue) Pop() interface{}

func (*PriorityQueue) Push

func (vq *PriorityQueue) Push(x interface{})

func (PriorityQueue) Swap

func (vq PriorityQueue) Swap(i, j int)

func (*PriorityQueue) Update

func (vq *PriorityQueue) Update(item *Queued, value []byte, priority int64)

update modifies the priority and value of an Queued in the queue.

type Queued

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

An Queued is a priority queue we hold for validators

func NewQueued

func NewQueued(value []byte, priority int64, index int) *Queued

func (Queued) Priority

func (q Queued) Priority() int64

func (Queued) Value

func (q Queued) Value() []byte