client

package

v0.0.0-...-8df4799 Latest Latest Go to latest Published: Apr 2, 2024 License: Apache-2.0 Imports: 51 Imported by: 4

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/DefiantLabs/probe

Links

Open Source Insights

Documentation ¶

Overview ¶

APACHE NOTICE Sourced with modifications from https://github.com/strangelove-ventures/lens

Index ¶

Variables
func GetHeightFromMetadata(md metadata.MD) (int64, error)
func GetProveFromMetadata(md metadata.MD) (bool, error)
func NewRPCClient(addr string, timeout time.Duration) (*rpchttp.HTTP, error)
func RegisterOsmosisInterfaces(registry types.InterfaceRegistry)
func RegisterTendermintLiquidityInterfaces(aminoCodec *codec.LegacyAmino, registry types.InterfaceRegistry)
func SetHeightOnContext(ctx context.Context, height int64) context.Context
func SetProveOnContext(ctx context.Context, prove bool) context.Context
type ChainClient
- func NewChainClient(ccc *ChainClientConfig, homepath string, input io.Reader, output io.Writer, ...) (*ChainClient, error)
type ChainClientConfig
type Codec
- func MakeCodec(moduleBasics []module.AppModuleBasic) Codec
- func MakeCodecConfig() Codec

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// Provides a default set of AppModuleBasics that are included in the ChainClientConfig
	// This is used to provide a default set of modules that will be used for protobuf registration and in-app decoding of RPC responses
	DefaultModuleBasics = []module.AppModuleBasic{
		auth.AppModuleBasic{},
		authz.AppModuleBasic{},
		bank.AppModuleBasic{},
		capability.AppModuleBasic{},
		gov.AppModuleBasic{},
		crisis.AppModuleBasic{},
		distribution.AppModuleBasic{},
		feegrant.AppModuleBasic{},
		mint.AppModuleBasic{},
		params.AppModuleBasic{},
		slashing.AppModuleBasic{},
		staking.AppModuleBasic{},
		vesting.AppModuleBasic{},
		wasm.AppModuleBasic{},
		ibc.AppModuleBasic{},
		ibcTransfer.AppModuleBasic{},
		ibcTm.AppModuleBasic{},
	}
)

Functions ¶

func GetHeightFromMetadata ¶

func GetHeightFromMetadata(md metadata.MD) (int64, error)

func GetProveFromMetadata ¶

func GetProveFromMetadata(md metadata.MD) (bool, error)

func NewRPCClient ¶

func NewRPCClient(addr string, timeout time.Duration) (*rpchttp.HTTP, error)

func RegisterOsmosisInterfaces ¶

func RegisterOsmosisInterfaces(registry types.InterfaceRegistry)

Split out from base codec to not include explicitly. Should be included only when needed.

func RegisterTendermintLiquidityInterfaces ¶

func RegisterTendermintLiquidityInterfaces(aminoCodec *codec.LegacyAmino, registry types.InterfaceRegistry)

Split out from base codec to not include explicitly. Should be included only when needed.

func SetHeightOnContext ¶

func SetHeightOnContext(ctx context.Context, height int64) context.Context

func SetProveOnContext ¶

func SetProveOnContext(ctx context.Context, prove bool) context.Context

Types ¶

type ChainClient ¶

type ChainClient struct {
	Config         *ChainClientConfig
	Keybase        keyring.Keyring
	KeyringOptions []keyring.Option
	RPCClient      rpcclient.Client
	Input          io.Reader
	Output         io.Writer
	Codec          Codec
	Logger         log.Logger
}

func NewChainClient ¶

func NewChainClient(ccc *ChainClientConfig, homepath string, input io.Reader, output io.Writer, kro ...keyring.Option) (*ChainClient, error)

func (*ChainClient) Init ¶

func (cc *ChainClient) Init() error

func (*ChainClient) Invoke ¶

func (cc *ChainClient) Invoke(ctx context.Context, method string, req, reply interface{}, opts ...grpc.CallOption) (err error)

Invoke implements the grpc ClientConn.Invoke method, but only for querying state

func (*ChainClient) NewStream ¶

func (cc *ChainClient) NewStream(context.Context, *grpc.StreamDesc, string, ...grpc.CallOption) (grpc.ClientStream, error)

NewStream implements the grpc ClientConn.NewStream method

func (*ChainClient) QueryABCI ¶

func (cc *ChainClient) QueryABCI(req abci.RequestQuery) (abci.ResponseQuery, error)

func (*ChainClient) RunGRPCQuery ¶

func (cc *ChainClient) RunGRPCQuery(ctx context.Context, method string, req interface{}, md metadata.MD) (abci.ResponseQuery, metadata.MD, error)

RunGRPCQuery runs a gRPC query from the clientCtx, given all necessary arguments for the gRPC method, and returns the ABCI response. It is used to factorize code between client (Invoke) and server (RegisterGRPCServer) gRPC handlers.

type ChainClientConfig ¶

type ChainClientConfig struct {
	Key            string                  `json:"key" yaml:"key"`
	ChainID        string                  `json:"chain-id" yaml:"chain-id"`
	RPCAddr        string                  `json:"rpc-addr" yaml:"rpc-addr"`
	AccountPrefix  string                  `json:"account-prefix" yaml:"account-prefix"`
	KeyringBackend string                  `json:"keyring-backend" yaml:"keyring-backend"`
	KeyDirectory   string                  `json:"key-directory" yaml:"key-directory"`
	Debug          bool                    `json:"debug" yaml:"debug"`
	Timeout        string                  `json:"timeout" yaml:"timeout"`
	OutputFormat   string                  `json:"output-format" yaml:"output-format"`
	Modules        []module.AppModuleBasic `json:"-" yaml:"-"`
}

type Codec ¶

type Codec struct {
	InterfaceRegistry types.InterfaceRegistry
	Marshaler         codec.Codec
	TxConfig          client.TxConfig
	Amino             *codec.LegacyAmino
}

func MakeCodec ¶

func MakeCodec(moduleBasics []module.AppModuleBasic) Codec

func MakeCodecConfig ¶

func MakeCodecConfig() Codec

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
codec
osmosis/v15/x/epochs/types
osmosis/v15/x/gamm/types
osmosis/v15/x/lockup/types
osmosis/v15/x/poolmanager/types
osmosis/v15/x/protorev/types
tendermint/liquidity/x/liquidity/types

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