zmq

Documentation

Index

• Variables
• func Fields(topic string) []string
• type Block
• type BlockHash
• type Message
  • func NewMessage(topic, body []byte) *Message
  • func (m *Message) DecodeBlock() (*Block, error)
  • func (m *Message) DecodeBlockHash() (BlockHash, error)
  • func (m *Message) DecodeOp() (*Op, error)
  • func (m *Message) DecodeOpHash() (OpHash, error)
  • func (m *Message) DecodeStatus() (*Status, error)
• type Op
• type OpHash
• type Status
• type ZmqAPI
  • func NewZmqAPI(c *client.Client) ZmqAPI

Variables

var (
	ParseOpHash    = tezos.ParseOpHash
	ParseBlockHash = tezos.ParseBlockHash
)

var ZmqRawBlockColumns = []string{
	"row_id",
	"hash",
	"predecessor",
	"height",
	"cycle",
	"time",
	"solvetime",
	"version",
	"round",
	"nonce",
	"voting_period_kind",
	"baker",
	"proposer",
	"n_ops_applied",
	"n_ops_failed",
	"n_calls",
	"n_rollup_calls",
	"n_events",
	"volume",
	"fee",
	"reward",
	"deposit",
	"activated_supply",
	"burned_supply",
	"minted_supply",
	"n_accounts",
	"n_new_accounts",
	"n_new_contracts",
	"n_cleared_accounts",
	"n_funded_accounts",
	"gas_limit",
	"gas_used",
	"storage_paid",
	"lb_esc_vote",
	"lb_esc_ema",
	"protocol",
}

var ZmqRawOpColumns = []string{
	"id",
	"type",
	"hash",
	"block",
	"height",
	"cycle",
	"time",
	"op_n",
	"op_p",
	"op_c",
	"op_i",
	"status",
	"is_success",
	"is_contract",
	"is_internal",
	"is_event",
	"is_rollup",
	"counter",
	"gas_limit",
	"gas_used",
	"storage_limit",
	"storage_paid",
	"volume",
	"fee",
	"reward",
	"deposit",
	"burned",
	"sender_id",
	"sender",
	"receiver_id",
	"receiver",
	"creator_id",
	"creator",
	"baker_id",
	"baker",
	"data",
	"parameters",
	"storage",
	"big_map_diff",
	"errors",
	"entrypoint",
	"code_hash",
	"events",
	"ticket_updates",
}

var ZmqStatusColumns = []string{
	"status",
	"blocks",
	"finalized",
	"indexed",
	"progress",
}

Functions

func Fields

func Fields(topic string) []string

Types

type Block

type Block = index.Block

type BlockHash

type BlockHash = tezos.BlockHash

type Message

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

func NewMessage

func NewMessage(topic, body []byte) *Message

func (*Message) DecodeBlock

func (m *Message) DecodeBlock() (*Block, error)

func (*Message) DecodeBlockHash

func (m *Message) DecodeBlockHash() (BlockHash, error)

func (*Message) DecodeOp

func (m *Message) DecodeOp() (*Op, error)

func (*Message) DecodeOpHash

func (m *Message) DecodeOpHash() (OpHash, error)

func (*Message) DecodeStatus

func (m *Message) DecodeStatus() (*Status, error)

type Op

type Op = index.Op

type OpHash

type OpHash = tezos.OpHash

type Status

type Status = index.Status

type ZmqAPI

type ZmqAPI interface {
}

func NewZmqAPI

func NewZmqAPI(c *client.Client) ZmqAPI