api

Documentation

Index

• func InitMetrics()
• type BlocksMap
• type Client
  • func NewClient(chainID string, logger *zap.Logger, cli *grpc.ClientConn, cfg *ClientConfig) *Client
  • func (c *Client) GetBlock(ctx context.Context, params structs.HeightHash) (block structs.Block, er error)
  • func (c *Client) SearchTx(ctx context.Context, r structs.HeightHash, block structs.Block, perPage uint64) (txs []structs.Transaction, err error)
• type ClientConfig
• type SimpleBlockCache
  • func NewSimpleBlockCache(cap int) *SimpleBlockCache
  • func (sbc *SimpleBlockCache) Add(bl structs.Block)
  • func (sbc *SimpleBlockCache) Get(height uint64) (bl structs.Block, ok bool)
• type TxLogError

Functions

func InitMetrics

func InitMetrics()

InitMetrics initialise metrics

Types

type BlocksMap

type BlocksMap struct {
	sync.Mutex
	Blocks      map[uint64]structs.Block
	NumTxs      uint64
	StartHeight uint64
	EndHeight   uint64
}

BlocksMap map of blocks to control block map with extra summary of number of transactions

type Client

type Client struct {
	Sbc *SimpleBlockCache
	// contains filtered or unexported fields
}

Client is a Tendermint RPC client for cosmos using figmentnetworks datahub

func NewClient

func NewClient(chainID string, logger *zap.Logger, cli *grpc.ClientConn, cfg *ClientConfig) *Client

NewClient returns a new client for a given endpoint

func (*Client) GetBlock

func (c *Client) GetBlock(ctx context.Context, params structs.HeightHash) (block structs.Block, er error)

GetBlock fetches most recent block from chain

func (*Client) SearchTx

func (c *Client) SearchTx(ctx context.Context, r structs.HeightHash, block structs.Block, perPage uint64) (txs []structs.Transaction, err error)

SearchTx is making search api call

type ClientConfig

type ClientConfig struct {
	ReqPerSecond        int
	TimeoutBlockCall    time.Duration
	TimeoutSearchTxCall time.Duration
}

type SimpleBlockCache

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

SimpleBlockCache simple in memory block cache to store latest blocks

func NewSimpleBlockCache

func NewSimpleBlockCache(cap int) *SimpleBlockCache

NewSimpleBlockCache a SimpleBlockCache constructor

func (*SimpleBlockCache) Add

func (sbc *SimpleBlockCache) Add(bl structs.Block)

Add blocks to the cache (thread safe)

func (*SimpleBlockCache) Get

func (sbc *SimpleBlockCache) Get(height uint64) (bl structs.Block, ok bool)

Get and check block of given height (thread safe)

type TxLogError

type TxLogError struct {
	Codespace string  `json:"codespace"`
	Code      float64 `json:"code"`
	Message   string  `json:"message"`
}

TxLogError Error message