util

package

v1.0.0 Latest Latest Go to latest Published: Feb 26, 2024 License: AGPL-3.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bnb-chain/token-recover-approver

Links

Open Source Insights

Documentation ¶

Index ¶

func EncodeBytesArrayToHex(data [][]byte) []string
func EncodeBytesToHex(data []byte) string
func Launch(start func() error, shutdown func() error, timeout time.Duration)
func MustDecodeHexArrayToBytes(hexArray []string) [][]byte
func MustDecodeHexToBytes(hex string) []byte
func VerifyMerkleProof(rootHash []byte, proof [][]byte, leaf []byte) bool
type Entry
type Stream
- func NewJSONStream(builder func() any) Stream
- func (s Stream) Start(path string)
- func (s Stream) Watch() <-chan Entry

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func EncodeBytesArrayToHex ¶

func EncodeBytesArrayToHex(data [][]byte) []string

func EncodeBytesToHex ¶

func EncodeBytesToHex(data []byte) string

func Launch ¶

func Launch(start func() error, shutdown func() error, timeout time.Duration)

Launch service gracefully, or force exit after two consecutive signals

func MustDecodeHexArrayToBytes ¶

func MustDecodeHexArrayToBytes(hexArray []string) [][]byte

func MustDecodeHexToBytes ¶

func MustDecodeHexToBytes(hex string) []byte

func VerifyMerkleProof ¶

func VerifyMerkleProof(rootHash []byte, proof [][]byte, leaf []byte) bool

Types ¶

type Entry ¶

type Entry struct {
	Error error
	Data  any
}

Entry represents each stream. If the stream fails, an error will be present.

type Stream ¶

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

Stream helps transmit each streams withing a channel.

func NewJSONStream ¶

func NewJSONStream(builder func() any) Stream

NewJSONStream returns a new `Stream` type.

func (Stream) Start ¶

func (s Stream) Start(path string)

Start starts streaming JSON file line by line. If an error occurs, the channel will be closed.

func (Stream) Watch ¶

func (s Stream) Watch() <-chan Entry

Watch watches JSON streams. Each stream entry will either have an error or a User object. Client code does not need to explicitly exit after catching an error as the `Start` method will close the channel automatically.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL