rpc

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 12, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewRpcClient 

func NewRpcClient(client abcicli.Client) rpcclient.Client

func StartRPC 

func StartRPC(
	app *terra.TerraApp,
	rpcclient rpcclient.Client,
	chainId string,
	codec params.EncodingConfig,
	invalidateTrigger chan int64,
	registerCustomRoutes func(router *mux.Router),
	getIsSynced func() bool,
) error

Types

type CacheBackend 

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

func NewCacheBackend 

func NewCacheBackend(cacheSize int, cacheType string) *CacheBackend

func (*CacheBackend) Get 

func (cb *CacheBackend) Get(cacheKey string) *ResponseCache

func (*CacheBackend) HandleCachedHTTP 

func (cb *CacheBackend) HandleCachedHTTP(writer http.ResponseWriter, request *http.Request, handler http.Handler)

func (*CacheBackend) Metric 

func (cb *CacheBackend) Metric()

func (*CacheBackend) Purge 

func (cb *CacheBackend) Purge()

func (*CacheBackend) Set 

func (cb *CacheBackend) Set(cacheKey string, status int, body []byte) *ResponseCache

type MantlemintRPCClient 

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

func (*MantlemintRPCClient) ABCIInfo 

func (m *MantlemintRPCClient) ABCIInfo(ctx context.Context) (*coretypes.ResultABCIInfo, error)

func (*MantlemintRPCClient) ABCIQuery 

func (m *MantlemintRPCClient) ABCIQuery(ctx context.Context, path string, data bytes.HexBytes) (*coretypes.ResultABCIQuery, error)

func (*MantlemintRPCClient) ABCIQueryWithOptions 

func (m *MantlemintRPCClient) ABCIQueryWithOptions(ctx context.Context, path string, data bytes.HexBytes, opts rpcclient.ABCIQueryOptions) (*coretypes.ResultABCIQuery, error)

func (*MantlemintRPCClient) Block 

func (m *MantlemintRPCClient) Block(ctx context.Context, height *int64) (*coretypes.ResultBlock, error)

func (*MantlemintRPCClient) BlockByHash 

func (m *MantlemintRPCClient) BlockByHash(ctx context.Context, hash []byte) (*coretypes.ResultBlock, error)

func (*MantlemintRPCClient) BlockResults 

func (m *MantlemintRPCClient) BlockResults(ctx context.Context, height *int64) (*coretypes.ResultBlockResults, error)

func (*MantlemintRPCClient) BlockSearch 

func (m *MantlemintRPCClient) BlockSearch(ctx context.Context, query string, page, perPage *int, orderBy string) (*coretypes.ResultBlockSearch, error)

func (*MantlemintRPCClient) BlockchainInfo 

func (m *MantlemintRPCClient) BlockchainInfo(ctx context.Context, minHeight, maxHeight int64) (*coretypes.ResultBlockchainInfo, error)

func (*MantlemintRPCClient) BroadcastEvidence 

func (m *MantlemintRPCClient) BroadcastEvidence(ctx context.Context, evidence tendermint.Evidence) (*coretypes.ResultBroadcastEvidence, error)

func (*MantlemintRPCClient) BroadcastTxAsync 

func (m *MantlemintRPCClient) BroadcastTxAsync(ctx context.Context, tx tendermint.Tx) (*coretypes.ResultBroadcastTx, error)

func (*MantlemintRPCClient) BroadcastTxCommit 

func (m *MantlemintRPCClient) BroadcastTxCommit(ctx context.Context, tx tendermint.Tx) (*coretypes.ResultBroadcastTxCommit, error)

func (*MantlemintRPCClient) BroadcastTxSync 

func (m *MantlemintRPCClient) BroadcastTxSync(ctx context.Context, tx tendermint.Tx) (*coretypes.ResultBroadcastTx, error)

func (*MantlemintRPCClient) CheckTx 

func (m *MantlemintRPCClient) CheckTx(ctx context.Context, tx tendermint.Tx) (*coretypes.ResultCheckTx, error)

func (*MantlemintRPCClient) Commit 

func (m *MantlemintRPCClient) Commit(ctx context.Context, height *int64) (*coretypes.ResultCommit, error)

func (*MantlemintRPCClient) ConsensusParams 

func (m *MantlemintRPCClient) ConsensusParams(ctx context.Context, height *int64) (*coretypes.ResultConsensusParams, error)

func (*MantlemintRPCClient) ConsensusState 

func (m *MantlemintRPCClient) ConsensusState(ctx context.Context) (*coretypes.ResultConsensusState, error)

func (*MantlemintRPCClient) DumpConsensusState 

func (m *MantlemintRPCClient) DumpConsensusState(ctx context.Context) (*coretypes.ResultDumpConsensusState, error)

func (*MantlemintRPCClient) Genesis 

func (m *MantlemintRPCClient) Genesis(ctx context.Context) (*coretypes.ResultGenesis, error)

func (*MantlemintRPCClient) GenesisChunked 

func (m *MantlemintRPCClient) GenesisChunked(ctx context.Context, u uint) (*coretypes.ResultGenesisChunk, error)

func (*MantlemintRPCClient) Health 

func (m *MantlemintRPCClient) Health(ctx context.Context) (*coretypes.ResultHealth, error)

func (*MantlemintRPCClient) IsRunning 

func (m *MantlemintRPCClient) IsRunning() bool

func (*MantlemintRPCClient) NetInfo 

func (m *MantlemintRPCClient) NetInfo(ctx context.Context) (*coretypes.ResultNetInfo, error)

func (*MantlemintRPCClient) NumUnconfirmedTxs 

func (m *MantlemintRPCClient) NumUnconfirmedTxs(ctx context.Context) (*coretypes.ResultUnconfirmedTxs, error)

func (*MantlemintRPCClient) OnReset 

func (m *MantlemintRPCClient) OnReset() error

func (*MantlemintRPCClient) OnStart 

func (m *MantlemintRPCClient) OnStart() error

func (*MantlemintRPCClient) OnStop 

func (m *MantlemintRPCClient) OnStop()

func (*MantlemintRPCClient) Quit 

func (m *MantlemintRPCClient) Quit() <-chan struct{}

func (*MantlemintRPCClient) Reset 

func (m *MantlemintRPCClient) Reset() error

func (*MantlemintRPCClient) SetLogger 

func (m *MantlemintRPCClient) SetLogger(logger tmlog.Logger)

func (*MantlemintRPCClient) Start 

func (m *MantlemintRPCClient) Start() error

func (*MantlemintRPCClient) Status 

func (m *MantlemintRPCClient) Status(ctx context.Context) (*coretypes.ResultStatus, error)

func (*MantlemintRPCClient) Stop 

func (m *MantlemintRPCClient) Stop() error

func (*MantlemintRPCClient) String 

func (m *MantlemintRPCClient) String() string

func (*MantlemintRPCClient) Subscribe 

func (m *MantlemintRPCClient) Subscribe(ctx context.Context, subscriber, query string, outCapacity ...int) (out <-chan coretypes.ResultEvent, err error)

func (*MantlemintRPCClient) Tx 

func (m *MantlemintRPCClient) Tx(ctx context.Context, hash []byte, prove bool) (*coretypes.ResultTx, error)

func (*MantlemintRPCClient) TxSearch 

func (m *MantlemintRPCClient) TxSearch(ctx context.Context, query string, prove bool, page, perPage *int, orderBy string) (*coretypes.ResultTxSearch, error)

func (*MantlemintRPCClient) UnconfirmedTxs 

func (m *MantlemintRPCClient) UnconfirmedTxs(ctx context.Context, limit *int) (*coretypes.ResultUnconfirmedTxs, error)

func (*MantlemintRPCClient) Unsubscribe 

func (m *MantlemintRPCClient) Unsubscribe(ctx context.Context, subscriber, query string) error

func (*MantlemintRPCClient) UnsubscribeAll 

func (m *MantlemintRPCClient) UnsubscribeAll(ctx context.Context, subscriber string) error

func (*MantlemintRPCClient) Validators 

func (m *MantlemintRPCClient) Validators(ctx context.Context, height *int64, page, perPage *int) (*coretypes.ResultValidators, error)

type ResponseCache 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.