burrow

Documentation

Index

• type Block
  • func NewBurrowBlock(block *exec.BlockExecution) *Block
  • func (b *Block) GetHeight() uint64
  • func (b *Block) GetMetadata(columns types.SQLColumnNames) (map[string]interface{}, error)
  • func (b *Block) GetTxs() []chain.Transaction
• type Chain
  • func New(conn *grpc.ClientConn, filter *chain.Filter) (*Chain, error)
  • func (b *Chain) Close() error
  • func (b *Chain) Connectivity() connectivity.State
  • func (b *Chain) ConsumeBlocks(ctx context.Context, in *rpcevents.BlockRange, ...) error
  • func (b *Chain) GetABI(ctx context.Context, address crypto.Address) (string, error)
  • func (b *Chain) GetChainID() string
  • func (b *Chain) GetVersion() string
  • func (b *Chain) StatusMessage(ctx context.Context, lastProcessedHeight uint64) []interface{}
• type Event
  • func (ev *Event) Get(key string) (value interface{}, ok bool)
  • func (ev *Event) GetAddress() crypto.Address
  • func (ev *Event) GetData() []byte
  • func (ev *Event) GetIndex() uint64
  • func (ev *Event) GetTopics() []binary.Word256
  • func (ev *Event) GetTransactionHash() binary.HexBytes
• type Transaction
  • func (tx *Transaction) GetEvents() []chain.Event
  • func (tx *Transaction) GetException() *errors.Exception
  • func (tx *Transaction) GetHash() binary.HexBytes
  • func (tx *Transaction) GetMetadata(columns types.SQLColumnNames) (map[string]interface{}, error)
  • func (tx *Transaction) GetOrigin() *chain.Origin

Types

type Block

type Block exec.BlockExecution

func NewBurrowBlock

func NewBurrowBlock(block *exec.BlockExecution) *Block

func (*Block) GetHeight

func (b *Block) GetHeight() uint64

func (*Block) GetMetadata

func (b *Block) GetMetadata(columns types.SQLColumnNames) (map[string]interface{}, error)

func (*Block) GetTxs

func (b *Block) GetTxs() []chain.Transaction

type Chain

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

func New

func New(conn *grpc.ClientConn, filter *chain.Filter) (*Chain, error)

func (*Chain) Close

func (b *Chain) Close() error

func (*Chain) Connectivity

func (b *Chain) Connectivity() connectivity.State

func (*Chain) ConsumeBlocks

func (b *Chain) ConsumeBlocks(ctx context.Context, in *rpcevents.BlockRange, consumer func(chain.Block) error) error

func (*Chain) GetABI

func (b *Chain) GetABI(ctx context.Context, address crypto.Address) (string, error)

func (*Chain) GetChainID

func (b *Chain) GetChainID() string

func (*Chain) GetVersion

func (b *Chain) GetVersion() string

func (*Chain) StatusMessage

func (b *Chain) StatusMessage(ctx context.Context, lastProcessedHeight uint64) []interface{}

type Event

type Event exec.Event

func (*Event) Get

func (ev *Event) Get(key string) (value interface{}, ok bool)

Tags

func (*Event) GetAddress

func (ev *Event) GetAddress() crypto.Address

func (*Event) GetData

func (ev *Event) GetData() []byte

func (*Event) GetIndex

func (ev *Event) GetIndex() uint64

func (*Event) GetTopics

func (ev *Event) GetTopics() []binary.Word256

func (*Event) GetTransactionHash

func (ev *Event) GetTransactionHash() binary.HexBytes

type Transaction

type Transaction exec.TxExecution

func (*Transaction) GetEvents

func (tx *Transaction) GetEvents() []chain.Event

func (*Transaction) GetException

func (tx *Transaction) GetException() *errors.Exception

func (*Transaction) GetHash

func (tx *Transaction) GetHash() binary.HexBytes

func (*Transaction) GetMetadata

func (tx *Transaction) GetMetadata(columns types.SQLColumnNames) (map[string]interface{}, error)

func (*Transaction) GetOrigin

func (tx *Transaction) GetOrigin() *chain.Origin