client

Documentation

Index

• type Api
• type ClientApi
  • func (nm *ClientApi) GetBlockRpc(ctx context.Context, height int64) *types.Block
  • func (nm *ClientApi) GetTx(ctx context.Context, hash string) *sdk.GetTxResponse
  • func (nm *ClientApi) GetTxsRpc(ctx context.Context, height int64) []*ctypes.ResultTx
  • func (nm *ClientApi) Init(cfg *config.Config) error
  • func (nm *ClientApi) Stop()
  • func (nm *ClientApi) SubscribeBlock(ctx context.Context) <-chan ctypes.ResultEvent
  • func (nm *ClientApi) SubscribeTxs(ctx context.Context) <-chan ctypes.ResultEvent
• type StatusEnum

Types

type Api

type Api interface {
	Init(cfg *config.Config) error
	Connect() error
	SubscribeBlock(ctx context.Context) <-chan ctypes.ResultEvent
	SubscribeTxs(ctx context.Context) <-chan ctypes.ResultEvent
	GetBlockRpc(ctx context.Context, height int64) *types.Block
	GetTx(ctx context.Context, txHash string) *sdk.GetTxResponse
	GetTxsRpc(height int64) []*ctypes.ResultTx
	Stop()
	ResendBlock(blockHeight uint64)
	ResendTx(txHash string, index uint32)
}

type ClientApi

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

NodeConnector info

func (*ClientApi) GetBlockRpc

func (nm *ClientApi) GetBlockRpc(ctx context.Context, height int64) *types.Block

func (*ClientApi) GetTx

func (nm *ClientApi) GetTx(ctx context.Context, hash string) *sdk.GetTxResponse

func (*ClientApi) GetTxsRpc

func (nm *ClientApi) GetTxsRpc(ctx context.Context, height int64) []*ctypes.ResultTx

func (*ClientApi) Init

func (nm *ClientApi) Init(cfg *config.Config) error

func (*ClientApi) Stop

func (nm *ClientApi) Stop()

func (*ClientApi) SubscribeBlock

func (nm *ClientApi) SubscribeBlock(ctx context.Context) <-chan ctypes.ResultEvent

func (*ClientApi) SubscribeTxs

func (nm *ClientApi) SubscribeTxs(ctx context.Context) <-chan ctypes.ResultEvent

type StatusEnum

type StatusEnum string

const (
	PendingStatus   StatusEnum = "pending"
	ConfirmedStatus StatusEnum = "confirmed"
	RejectedStatus  StatusEnum = "rejected"
	OnForkStatus    StatusEnum = "onfork"
)