util

Documentation

Index

• Constants
• func BigIntToPaddedString(x *big.Int) string
• func DirectoryExists(p string) error
• func ExtractMethod(fullMethod string) string
• func FileExists(p string) error
• func ForwardMetadata(ctx context.Context) context.Context
• func GenerateCert(ethpriv *ecdsa.PrivateKey, validPeriod time.Duration) (cert []byte, key []byte, err error)
• func GetDefaultConfigDir() (string, error)
• func GetDefaultKeyStoreDir() (string, error)
• func GetPlatformName() string
• func GetUserHomeDir() (homeDir string, err error)
• func HexToAddress(hex string) (common.Address, error)
• 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
	HomeConfigDir         = ".sonm"
	DefaultKeystorePath   = "keystore"
)

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

Functions

func BigIntToPaddedString

func BigIntToPaddedString(x *big.Int) string

func DirectoryExists

func DirectoryExists(p string) error

DirectoryExists returns true if the given directory exists

func ExtractMethod

func ExtractMethod(fullMethod string) string

func FileExists

func FileExists(p string) error

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 GetDefaultConfigDir

func GetDefaultConfigDir() (string, error)

GetDefaultConfigDir returns default user's config dir. e.g: /home/user/.sonm

func GetDefaultKeyStoreDir

func GetDefaultKeyStoreDir() (string, error)

GetDefaultKeyStoreDir returns default keystore dir for current user. e.g: /home/user/.sonm/keystore

func GetPlatformName

func GetPlatformName() string

func GetUserHomeDir

func GetUserHomeDir() (homeDir string, err error)

GetUserHomeDir returns home for current user. e.g: /home/user

func HexToAddress

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

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()