nearprovider

Documentation

Index

• Variables
• type Config
• type Message
• type Nearer
  • func NewNearer(getter kv.Getter, log *logan.Entry) Nearer
• type Provider
  • func New(client, historyClient *nearclient.Client, s3 s3.Connector, log *logan.Entry) Provider
• type RPCs

Variables

var ErrNoShardsAvailable = errors.New("No shards available")

var ErrUnknownTx = errors.New("unknown tx")

var NearHooks = figure.Hooks{
	"*nearclient.Client": func(raw interface{}) (reflect.Value, error) {
		v, err := cast.ToStringE(raw)
		if err != nil {
			return reflect.Value{}, errors.Wrap(err, "expected string")
		}

		client, err := nearclient.New(v)
		if err != nil {
			return reflect.Value{}, errors.Wrap(err, "failed to create near rpc client")
		}

		return reflect.ValueOf(client), nil
	},
}

Types

type Config

type Config struct {
	S3  s3.Config `fig:"s3,required"`
	RPC RPCs      `fig:"rpc,required"`
}

type Message

type Message struct {
	Block  *common.BlockView   `json:"block"`
	Shards []*common.ShardView `json:"shards"`
}

type Nearer

type Nearer interface {
	Near() Provider
}

func NewNearer

func NewNearer(getter kv.Getter, log *logan.Entry) Nearer

type Provider

type Provider interface {
	ListBlocks(ctx context.Context, limit uint64, fromBlock common.BlockHeight) ([]common.BlockHeight, error)
	GetMessage(ctx context.Context, height common.BlockHeight) (*Message, error)
	GetTransaction(ctx context.Context, hash common.Hash, sender common.AccountID) (*common.FinalExecutionOutcomeWithReceiptView, error)
	GetLastKnownBlockHeight(ctx context.Context) (*common.BlockHeight, error)
	GetNFTMetadata(ctx context.Context, token common.AccountID, tokenID string) (*common.NftMetadataView, error)
}

func New

func New(client, historyClient *nearclient.Client, s3 s3.Connector, log *logan.Entry) Provider

type RPCs

type RPCs struct {
	Main    *nearclient.Client `fig:"main,required"`
	History *nearclient.Client `fig:"history,required"`
}