common

Documentation

Index

• Constants
• func Connect(protoAddr string) (net.Conn, error)
• func DialerFunc(ctx context.Context, addr string) (net.Conn, error)
• func ExecuteCall[Q any, R any](ctx context.Context, cookieAssistant CookieAssistant, call APICall[Q, R], ...) (*R, error)
• func ExecuteStreamCall[Q any, S grpc.ClientStream](ctx context.Context, cookieAssistant CookieAssistant, call APIStreamCall[Q, S], ...) (S, error)
• func HexToBytes(str string) ([]byte, error)
• func ProtocolAndAddress(listenAddr string) (protocol, address string)
• func RemoveExtraDecimals(value decimal.Decimal, decimalsToRemove int32) decimal.Decimal
• type APICall
• type APIStreamCall
• type BareMetalLoadBalancedCookieAssistant
  • func (assistant *BareMetalLoadBalancedCookieAssistant) Metadata(provider MetadataProvider) (string, error)
  • func (assistant *BareMetalLoadBalancedCookieAssistant) ProcessResponseMetadata(header metadata.MD)
  • func (assistant *BareMetalLoadBalancedCookieAssistant) RealMetadata() metadata.MD
• 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)
  • func (assistant *DisabledCookieAssistant) ProcessResponseMetadata(header metadata.MD)
  • func (assistant *DisabledCookieAssistant) RealMetadata() metadata.MD
• type ExpiringCookieAssistant
  • func MainnetKubernetesCookieAssistant() ExpiringCookieAssistant
  • func TestnetKubernetesCookieAssistant() ExpiringCookieAssistant
  • func (assistant *ExpiringCookieAssistant) Metadata(provider MetadataProvider) (string, error)
  • func (assistant *ExpiringCookieAssistant) ProcessResponseMetadata(header metadata.MD)
  • func (assistant *ExpiringCookieAssistant) RealMetadata() metadata.MD
• type MetadataProvider
  • func NewMetadataProvider(f func() metadata.MD) MetadataProvider
• type Network
  • func LoadNetwork(name, node string) Network
  • func NewNetwork() Network

Constants

const (
	MainnetTokensListURL = "https://github.com/InjectiveLabs/injective-lists/raw/master/tokens/mainnet.json" // nolint:gosec // not credentials, just the link to the public tokens list
	TestnetTokensListURL = "https://github.com/InjectiveLabs/injective-lists/raw/master/tokens/testnet.json" // nolint:gosec // not credentials, just the link to the public tokens list
	DevnetTokensListURL  = "https://github.com/InjectiveLabs/injective-lists/raw/master/tokens/devnet.json"  // nolint:gosec // not credentials, just the link to the public tokens list
)

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 ExecuteCall

func ExecuteCall[Q any, R any](ctx context.Context, cookieAssistant CookieAssistant, call APICall[Q, R], in *Q) (*R, error)

func ExecuteStreamCall

func ExecuteStreamCall[Q any, S grpc.ClientStream](ctx context.Context, cookieAssistant CookieAssistant, call APIStreamCall[Q, S], in *Q) (S, error)

func HexToBytes

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

func ProtocolAndAddress

func ProtocolAndAddress(listenAddr string) (protocol, address 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 APICall

type APICall[Q any, R any] func(ctx context.Context, in *Q, opts ...grpc.CallOption) (*R, error)

type APIStreamCall

type APIStreamCall[Q any, S grpc.ClientStream] func(ctx context.Context, in *Q, opts ...grpc.CallOption) (S, error)

type BareMetalLoadBalancedCookieAssistant

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

func (*BareMetalLoadBalancedCookieAssistant) Metadata

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

func (*BareMetalLoadBalancedCookieAssistant) ProcessResponseMetadata

func (assistant *BareMetalLoadBalancedCookieAssistant) ProcessResponseMetadata(header metadata.MD)

func (*BareMetalLoadBalancedCookieAssistant) RealMetadata

func (assistant *BareMetalLoadBalancedCookieAssistant) RealMetadata() metadata.MD

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
	ShouldFixSequenceMismatch bool
}

func DefaultClientOptions

func DefaultClientOptions() *ClientOptions

type CookieAssistant

type CookieAssistant interface {
	Metadata(provider MetadataProvider) (string, error)
	RealMetadata() metadata.MD
	ProcessResponseMetadata(header metadata.MD)
}

type DisabledCookieAssistant

type DisabledCookieAssistant struct{}

func (*DisabledCookieAssistant) Metadata

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

func (*DisabledCookieAssistant) ProcessResponseMetadata

func (assistant *DisabledCookieAssistant) ProcessResponseMetadata(header metadata.MD)

func (*DisabledCookieAssistant) RealMetadata

func (assistant *DisabledCookieAssistant) RealMetadata() metadata.MD

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)

func (*ExpiringCookieAssistant) ProcessResponseMetadata

func (assistant *ExpiringCookieAssistant) ProcessResponseMetadata(header metadata.MD)

func (*ExpiringCookieAssistant) RealMetadata

func (assistant *ExpiringCookieAssistant) RealMetadata() metadata.MD

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
	FeeDenom                string
	Name                    string
	ChainCookieAssistant    CookieAssistant
	ExchangeCookieAssistant CookieAssistant
	ExplorerCookieAssistant CookieAssistant
	OfficialTokensListURL   string
}

func LoadNetwork

func LoadNetwork(name, 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.