util

Documentation

Index

• Constants
• func BigIntToPaddedString(x *big.Int) string
• func DirectoryExists(p string) bool
• func ExtractMethod(fullMethod string) string
• func FileExists(p string) bool
• func ForwardMetadata(ctx context.Context) context.Context
• func GenerateCert(ethpriv *ecdsa.PrivateKey, validPeriod time.Duration) (cert []byte, key []byte, err error)
• func GetPlatformName() string
• func GetUserHomeDir() (homeDir string, err error)
• func HexToAddress(hex string) (common.Address, error)
• func LaconicError(err error) zapcore.Field
• func NewTLS(c *tls.Config) credentials.TransportCredentials
• func ParseBigInt(s string) (*big.Int, error)
• func StartPrometheus(ctx context.Context, listenAddr string)
• func StringToEtherPrice(s string) (*big.Int, error)
• type HitlessCertRotator
  • func NewHitlessCertRotator(ctx context.Context, ethPriv *ecdsa.PrivateKey) (HitlessCertRotator, *tls.Config, error)
• type ImmediateTicker
  • func NewImmediateTicker(d time.Duration) *ImmediateTicker
  • func (t *ImmediateTicker) Stop()

Constants

const (
	FormattedBigIntLength = 80
)

const (
	WorkerAddressHeader = "x-worker-eth-addr"
)

Functions

func BigIntToPaddedString

func BigIntToPaddedString(x *big.Int) string

func DirectoryExists

func DirectoryExists(p string) bool

DirectoryExists returns true if the given directory exists

func ExtractMethod

func ExtractMethod(fullMethod string) string

func FileExists

func FileExists(p string) bool

func ForwardMetadata

func ForwardMetadata(ctx context.Context) context.Context

ForwardMetadata is a helper function for gRPC proxy that chains incoming request with some outgoing request. It simply forwards incoming context metadata without changes by toggling internal outgoing key.

func GenerateCert

func GenerateCert(ethpriv *ecdsa.PrivateKey, validPeriod time.Duration) (cert []byte, key []byte, err error)

GenerateCert generates new PEM encoded x509cert and privatekey key. Generated certificate contains signature of a publick key by eth key

func GetPlatformName

func GetPlatformName() string

func GetUserHomeDir

func GetUserHomeDir() (homeDir string, err error)

func HexToAddress

func HexToAddress(hex string) (common.Address, error)

func LaconicError

func LaconicError(err error) zapcore.Field

func NewTLS

func NewTLS(c *tls.Config) credentials.TransportCredentials

NewTLS wraps TLS TransportCredentials from grpc to add custom logic

func ParseBigInt

func ParseBigInt(s string) (*big.Int, error)

ParseBigInt parses the given string and converts it to *big.Int

func StartPrometheus

func StartPrometheus(ctx context.Context, listenAddr string)

func StringToEtherPrice

func StringToEtherPrice(s string) (*big.Int, error)

StringToEtherPrice converts input string s to Ethereum's price present as big.Int This function expects to receive trimmed input.

Types

type HitlessCertRotator

type HitlessCertRotator interface {
	GetCertificate(*tls.ClientHelloInfo) (*tls.Certificate, error)
	GetClientCertificate(*tls.CertificateRequestInfo) (*tls.Certificate, error)
	Close()
}

HitlessCertRotator renews TLS cert periodically

func NewHitlessCertRotator

func NewHitlessCertRotator(ctx context.Context, ethPriv *ecdsa.PrivateKey) (HitlessCertRotator, *tls.Config, error)

type ImmediateTicker

type ImmediateTicker struct {
	C <-chan time.Time // The channel on which the ticks are delivered.
	// contains filtered or unexported fields
}

func NewImmediateTicker

func NewImmediateTicker(d time.Duration) *ImmediateTicker

func (*ImmediateTicker) Stop

func (t *ImmediateTicker) Stop()