core

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2016 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const Version = "3" // rpc routes for profiling, setting config

Variables

View Source 
var Routes = map[string]*rpc.RPCFunc{

	"subscribe":   rpc.NewWSRPCFunc(SubscribeResult, "event"),
	"unsubscribe": rpc.NewWSRPCFunc(UnsubscribeResult, "event"),

	"status":               rpc.NewRPCFunc(StatusResult, ""),
	"net_info":             rpc.NewRPCFunc(NetInfoResult, ""),
	"dial_seeds":           rpc.NewRPCFunc(DialSeedsResult, "seeds"),
	"blockchain":           rpc.NewRPCFunc(BlockchainInfoResult, "minHeight,maxHeight"),
	"genesis":              rpc.NewRPCFunc(GenesisResult, ""),
	"block":                rpc.NewRPCFunc(BlockResult, "height"),
	"validators":           rpc.NewRPCFunc(ValidatorsResult, ""),
	"dump_consensus_state": rpc.NewRPCFunc(DumpConsensusStateResult, ""),
	"broadcast_tx_commit":  rpc.NewRPCFunc(BroadcastTxCommitResult, "tx"),
	"broadcast_tx_sync":    rpc.NewRPCFunc(BroadcastTxSyncResult, "tx"),
	"broadcast_tx_async":   rpc.NewRPCFunc(BroadcastTxAsyncResult, "tx"),
	"unconfirmed_txs":      rpc.NewRPCFunc(UnconfirmedTxsResult, ""),
	"num_unconfirmed_txs":  rpc.NewRPCFunc(NumUnconfirmedTxsResult, ""),

	"unsafe_flush_mempool":      rpc.NewRPCFunc(UnsafeFlushMempool, ""),
	"unsafe_set_config":         rpc.NewRPCFunc(UnsafeSetConfigResult, "type,key,value"),
	"unsafe_start_cpu_profiler": rpc.NewRPCFunc(UnsafeStartCPUProfilerResult, "filename"),
	"unsafe_stop_cpu_profiler":  rpc.NewRPCFunc(UnsafeStopCPUProfilerResult, ""),
	"unsafe_write_heap_profile": rpc.NewRPCFunc(UnsafeWriteHeapProfileResult, "filename"),
}

Functions

func Block 

func Block(height int) (*ctypes.ResultBlock, error)

func BlockResult added in v0.7.0 

func BlockResult(height int) (ctypes.TMResult, error)

func BlockchainInfo 

func BlockchainInfo(minHeight, maxHeight int) (*ctypes.ResultBlockchainInfo, error)

func BlockchainInfoResult added in v0.7.0 

func BlockchainInfoResult(min, max int) (ctypes.TMResult, error)

func BroadcastTxAsync 

func BroadcastTxAsync(tx types.Tx) (*ctypes.ResultBroadcastTx, error)

Returns right away, with no response

func BroadcastTxAsyncResult added in v0.7.0 

func BroadcastTxAsyncResult(tx []byte) (ctypes.TMResult, error)

func BroadcastTxCommit 

func BroadcastTxCommit(tx types.Tx) (*ctypes.ResultBroadcastTx, error)

CONTRACT: returns error==nil iff the tx is included in a block.

If CheckTx fails, return with the response from CheckTx AND an error. Else, block until the tx is included in a block, 

and return the result of AppendTx (with no error).

Even if AppendTx fails, so long as the tx is included in a block this function 

will not return an error - it is the caller's responsibility to check res.Code.

The function times out after five minutes and returns the result of CheckTx and an error. TODO: smarter timeout logic or someway to cancel (tx not getting committed is a sign of a larger problem!)

func BroadcastTxCommitResult added in v0.7.0 

func BroadcastTxCommitResult(tx []byte) (ctypes.TMResult, error)

func BroadcastTxSync 

func BroadcastTxSync(tx types.Tx) (*ctypes.ResultBroadcastTx, error)

Returns with the response from CheckTx

func BroadcastTxSyncResult added in v0.7.0 

func BroadcastTxSyncResult(tx []byte) (ctypes.TMResult, error)

func DialSeeds added in v0.7.0 

func DialSeeds(seeds []string) (*ctypes.ResultDialSeeds, error)

Dial given list of seeds if we have no outbound peers

func DialSeedsResult added in v0.7.0 

func DialSeedsResult(seeds []string) (ctypes.TMResult, error)

func DumpConsensusState 

func DumpConsensusState() (*ctypes.ResultDumpConsensusState, error)

func DumpConsensusStateResult added in v0.7.0 

func DumpConsensusStateResult() (ctypes.TMResult, error)

func Genesis 

func Genesis() (*ctypes.ResultGenesis, error)

func GenesisResult added in v0.7.0 

func GenesisResult() (ctypes.TMResult, error)

func NetInfo 

func NetInfo() (*ctypes.ResultNetInfo, error)

func NetInfoResult added in v0.7.0 

func NetInfoResult() (ctypes.TMResult, error)

func NumUnconfirmedTxs 

func NumUnconfirmedTxs() (*ctypes.ResultUnconfirmedTxs, error)

func NumUnconfirmedTxsResult added in v0.7.0 

func NumUnconfirmedTxsResult() (ctypes.TMResult, error)

func SetBlockStore 

func SetBlockStore(bs *bc.BlockStore)

func SetConfig 

func SetConfig(c cfg.Config)

func SetConsensusReactor 

func SetConsensusReactor(cr *consensus.ConsensusReactor)

func SetConsensusState 

func SetConsensusState(cs *consensus.ConsensusState)

func SetEventSwitch added in v0.7.0 

func SetEventSwitch(evsw *events.EventSwitch)

func SetGenesisDoc 

func SetGenesisDoc(doc *types.GenesisDoc)

func SetMempoolReactor added in v0.7.0 

func SetMempoolReactor(mr *mempl.MempoolReactor)

func SetPrivValidator added in v0.7.0 

func SetPrivValidator(pv *types.PrivValidator)

func SetSwitch added in v0.7.0 

func SetSwitch(sw *p2p.Switch)

func Status 

func Status() (*ctypes.ResultStatus, error)

func StatusResult added in v0.7.0 

func StatusResult() (ctypes.TMResult, error)

func Subscribe 

func Subscribe(wsCtx rpctypes.WSRPCContext, event string) (*ctypes.ResultSubscribe, error)

func SubscribeResult added in v0.7.0 

func SubscribeResult(wsCtx rpctypes.WSRPCContext, event string) (ctypes.TMResult, error)

func UnconfirmedTxs 

func UnconfirmedTxs() (*ctypes.ResultUnconfirmedTxs, error)

func UnconfirmedTxsResult added in v0.7.0 

func UnconfirmedTxsResult() (ctypes.TMResult, error)

func UnsafeFlushMempool 

func UnsafeFlushMempool() (*ctypes.ResultUnsafeFlushMempool, error)

func UnsafeFlushMempoolResult added in v0.7.0 

func UnsafeFlushMempoolResult() (ctypes.TMResult, error)

func UnsafeSetConfig added in v0.7.0 

func UnsafeSetConfig(typ, key, value string) (*ctypes.ResultUnsafeSetConfig, error)

func UnsafeSetConfigResult added in v0.7.0 

func UnsafeSetConfigResult(typ, key, value string) (ctypes.TMResult, error)

func UnsafeStartCPUProfiler 

func UnsafeStartCPUProfiler(filename string) (*ctypes.ResultUnsafeProfile, error)

func UnsafeStartCPUProfilerResult added in v0.7.0 

func UnsafeStartCPUProfilerResult(filename string) (ctypes.TMResult, error)

func UnsafeStopCPUProfiler 

func UnsafeStopCPUProfiler() (*ctypes.ResultUnsafeProfile, error)

func UnsafeStopCPUProfilerResult added in v0.7.0 

func UnsafeStopCPUProfilerResult() (ctypes.TMResult, error)

func UnsafeWriteHeapProfile 

func UnsafeWriteHeapProfile(filename string) (*ctypes.ResultUnsafeProfile, error)

func UnsafeWriteHeapProfileResult added in v0.7.0 

func UnsafeWriteHeapProfileResult(filename string) (ctypes.TMResult, error)

func Unsubscribe 

func Unsubscribe(wsCtx rpctypes.WSRPCContext, event string) (*ctypes.ResultUnsubscribe, error)

func UnsubscribeResult added in v0.7.0 

func UnsubscribeResult(wsCtx rpctypes.WSRPCContext, event string) (ctypes.TMResult, error)

func Validators 

func Validators() (*ctypes.ResultValidators, error)

func ValidatorsResult added in v0.7.0 

func ValidatorsResult() (ctypes.TMResult, error)

Types

This section is empty.

Source Files

View all Source files

Directories

Path Synopsis

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.