flow

Documentation

Index

• type Client
• type CosmosFlow
  • func NewCosmosFlow(client Client, storeClient store.StoreCaller, logger *zap.Logger) *CosmosFlow
  • func (f *CosmosFlow) BlockAndTx(ctx context.Context, height uint64) (block structs.BlockWithMeta, err error)
  • func (f *CosmosFlow) GetData(ctx context.Context, hr structs.ExpandedHeightRange) (kind string, payload []byte, err error)
  • func (f *CosmosFlow) GetRewardBalances(ctx context.Context, ha []structs.HeightAccount) (rewardSummary map[uint64]structs.GetRewardResponse, err error)
  • func (ic *CosmosFlow) GetTransactions(ctx context.Context, hr structs.ExpandedHeightRange) (structs.Heights, error)
  • func (f *CosmosFlow) LatestMark(ctx context.Context, ldReq structs.LatestDataRequest) (ldResp structs.LatestDataResponse, err error)

Types

type Client

type Client interface {
	GetBlock(ctx context.Context, params structs.HeightHash) (block structs.Block, er error)
	SearchTx(ctx context.Context, r structs.HeightHash, block structs.Block, perPage uint64) (txs []structs.Transaction, err error)

	GetRewardBalances(ctx context.Context, params []structs.HeightAccount) (resp map[uint64]structs.GetRewardResponse, err error)
}

type CosmosFlow

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

func NewCosmosFlow

func NewCosmosFlow(client Client, storeClient store.StoreCaller, logger *zap.Logger) *CosmosFlow

func (*CosmosFlow) BlockAndTx

func (f *CosmosFlow) BlockAndTx(ctx context.Context, height uint64) (block structs.BlockWithMeta, err error)

func (*CosmosFlow) GetData

func (f *CosmosFlow) GetData(ctx context.Context, hr structs.ExpandedHeightRange) (kind string, payload []byte, err error)

func (*CosmosFlow) GetRewardBalances

func (f *CosmosFlow) GetRewardBalances(ctx context.Context, ha []structs.HeightAccount) (rewardSummary map[uint64]structs.GetRewardResponse, err error)

GetReward gets reward

func (*CosmosFlow) GetTransactions

func (ic *CosmosFlow) GetTransactions(ctx context.Context, hr structs.ExpandedHeightRange) (structs.Heights, error)

GetTransactions gets new transactions and blocks from cosmos for given range

func (*CosmosFlow) LatestMark

func (f *CosmosFlow) LatestMark(ctx context.Context, ldReq structs.LatestDataRequest) (ldResp structs.LatestDataResponse, err error)