common

Documentation

Index

• Constants
• func Connect(protoAddr string) (net.Conn, error)
• func DialerFunc(ctx context.Context, addr string) (net.Conn, error)
• func HexToBytes(str string) ([]byte, error)
• func LoadTlsCert(path string, serverName string) credentials.TransportCredentials
• func MsgResponse(data []byte) []*chaintypes.TxResponseGenericMessage
• func ProtocolAndAddress(listenAddr string) (string, string)
• func RemoveExtraDecimals(value decimal.Decimal, decimalsToRemove int32) decimal.Decimal
• type BareMetalLoadBalancedCookieAssistant
  • func (assistant *BareMetalLoadBalancedCookieAssistant) Metadata(provider MetadataProvider) (string, error)
• type ClientOption
  • func OptionGasPrices(gasPrices string) ClientOption
  • func OptionTLSCert(tlsCert credentials.TransportCredentials) ClientOption
  • func OptionTxFactory(txFactory *tx.Factory) ClientOption
• type ClientOptions
  • func DefaultClientOptions() *ClientOptions
• type CookieAssistant
• type DisabledCookieAssistant
  • func (assistant *DisabledCookieAssistant) Metadata(provider MetadataProvider) (string, error)
• type ExpiringCookieAssistant
  • func MainnetKubernetesCookieAssistant() ExpiringCookieAssistant
  • func TestnetKubernetesCookieAssistant() ExpiringCookieAssistant
  • func (assistant *ExpiringCookieAssistant) Metadata(provider MetadataProvider) (string, error)
• type MetadataProvider
  • func NewMetadataProvider(f func() metadata.MD) MetadataProvider
• type Network
  • func LoadNetwork(name string, node string) Network
  • func NewNetwork() Network
  • func (network *Network) ChainMetadata(provider MetadataProvider) (string, error)
  • func (network *Network) ExchangeMetadata(provider MetadataProvider) (string, error)
  • func (network *Network) ExplorerMetadata(provider MetadataProvider) (string, error)

Constants

const (
	SessionRenewalOffset = 2 * time.Minute
)

Functions

func Connect

func Connect(protoAddr string) (net.Conn, error)

Connect dials the given address and returns a net.Conn. The protoAddr argument should be prefixed with the protocol, eg. "tcp://127.0.0.1:8080" or "unix:///tmp/test.sock"

func DialerFunc

func DialerFunc(ctx context.Context, addr string) (net.Conn, error)

func HexToBytes

func HexToBytes(str string) ([]byte, error)

func LoadTlsCert

func LoadTlsCert(path string, serverName string) credentials.TransportCredentials

func MsgResponse

func MsgResponse(data []byte) []*chaintypes.TxResponseGenericMessage

func ProtocolAndAddress

func ProtocolAndAddress(listenAddr string) (string, string)

ProtocolAndAddress splits an address into the protocol and address components. For instance, "tcp://127.0.0.1:8080" will be split into "tcp" and "127.0.0.1:8080". If the address has no protocol prefix, the default is "tcp".

func RemoveExtraDecimals

func RemoveExtraDecimals(value decimal.Decimal, decimalsToRemove int32) decimal.Decimal

Types

type BareMetalLoadBalancedCookieAssistant

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

func (*BareMetalLoadBalancedCookieAssistant) Metadata

func (assistant *BareMetalLoadBalancedCookieAssistant) Metadata(provider MetadataProvider) (string, error)

type ClientOption

type ClientOption func(opts *ClientOptions) error

func OptionGasPrices

func OptionGasPrices(gasPrices string) ClientOption

func OptionTLSCert

func OptionTLSCert(tlsCert credentials.TransportCredentials) ClientOption

func OptionTxFactory

func OptionTxFactory(txFactory *tx.Factory) ClientOption

type ClientOptions

type ClientOptions struct {
	GasPrices string
	TLSCert   credentials.TransportCredentials
	TxFactory *tx.Factory
}

func DefaultClientOptions

func DefaultClientOptions() *ClientOptions

type CookieAssistant

type CookieAssistant interface {
	Metadata(provider MetadataProvider) (string, error)
}

type DisabledCookieAssistant

type DisabledCookieAssistant struct{}

func (*DisabledCookieAssistant) Metadata

func (assistant *DisabledCookieAssistant) Metadata(provider MetadataProvider) (string, error)

type ExpiringCookieAssistant

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

func MainnetKubernetesCookieAssistant

func MainnetKubernetesCookieAssistant() ExpiringCookieAssistant

func TestnetKubernetesCookieAssistant

func TestnetKubernetesCookieAssistant() ExpiringCookieAssistant

func (*ExpiringCookieAssistant) Metadata

func (assistant *ExpiringCookieAssistant) Metadata(provider MetadataProvider) (string, error)

type MetadataProvider

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

func NewMetadataProvider

func NewMetadataProvider(f func() metadata.MD) MetadataProvider

type Network

type Network struct {
	LcdEndpoint             string
	TmEndpoint              string
	ChainGrpcEndpoint       string
	ChainStreamGrpcEndpoint string
	ChainTlsCert            credentials.TransportCredentials
	ExchangeGrpcEndpoint    string
	ExplorerGrpcEndpoint    string
	ExchangeTlsCert         credentials.TransportCredentials
	ExplorerTlsCert         credentials.TransportCredentials
	ChainId                 string
	Fee_denom               string
	Name                    string
	// contains filtered or unexported fields
}

func LoadNetwork

func LoadNetwork(name string, node string) Network

func NewNetwork

func NewNetwork() Network

NewNetwork returns a new Network instance with all cookie assistants disabled. It can be used to setup a custom environment from scratch.

func (*Network) ChainMetadata

func (network *Network) ChainMetadata(provider MetadataProvider) (string, error)

func (*Network) ExchangeMetadata

func (network *Network) ExchangeMetadata(provider MetadataProvider) (string, error)

func (*Network) ExplorerMetadata

func (network *Network) ExplorerMetadata(provider MetadataProvider) (string, error)