rest

Documentation

Index

• func BlockTimeHandler(blockmetaClient *pbblockmeta.Client) http.Handler
• func GetBlockHandler(db eosws.DB) http.Handler
• func GetBlockTransactionsHandler(db eosws.DB) http.Handler
• func GetBlocksHandler(db eosws.DB) http.Handler
• func GetCompletionHandler(completionInstance completion.Completion) http.Handler
• func GetKeyAccounts(fluxClient fluxcli.Client) http.Handler
• func GetTransactionHandler(db eosws.DB) http.Handler
• func HealthzHandler(hub *hub.SubscriptionHub, api *eos.API, blocksStore dstore.Store, db eosws.DB, ...) http.Handler
• func ListTransactionsHandler(db eosws.DB) http.Handler
• func NewReverseProxy(target *url.URL, stripQuerystring bool) *httputil.ReverseProxy
• func PingHandler(w http.ResponseWriter, r *http.Request)
• func SearchNotStuckHandler(searchEngine *eosws.SearchEngine) http.Handler
• func SimpleSearchHandler(db eosws.DB, blockmetaClient *pbblockmeta.Client) http.Handler
• type Flux
• type Healthz
• type Hub
• type Merger
• type PushResponse
• type Search
• type TRXDB
• type TxPushRouter
  • func NewTxPushRouter(dumbAPIProxy http.Handler, pushTransactionHandler http.Handler) *TxPushRouter
  • func (t *TxPushRouter) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type TxPusher
  • func NewTxPusher(API *eos.API, subscriptionHub *hub.SubscriptionHub) *TxPusher
  • func (t *TxPusher) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func BlockTimeHandler

func BlockTimeHandler(blockmetaClient *pbblockmeta.Client) http.Handler

func GetBlockHandler

func GetBlockHandler(db eosws.DB) http.Handler

func GetBlockTransactionsHandler

func GetBlockTransactionsHandler(db eosws.DB) http.Handler

func GetBlocksHandler

func GetBlocksHandler(db eosws.DB) http.Handler

func GetCompletionHandler

func GetCompletionHandler(completionInstance completion.Completion) http.Handler

func GetKeyAccounts

func GetKeyAccounts(fluxClient fluxcli.Client) http.Handler

func GetTransactionHandler

func GetTransactionHandler(db eosws.DB) http.Handler

func HealthzHandler

func HealthzHandler(hub *hub.SubscriptionHub, api *eos.API, blocksStore dstore.Store, db eosws.DB, fluxClient fluxdb.Client, searchEngine *eosws.SearchEngine, expectedSecret string) http.Handler

func ListTransactionsHandler

func ListTransactionsHandler(db eosws.DB) http.Handler

func NewReverseProxy

func NewReverseProxy(target *url.URL, stripQuerystring bool) *httputil.ReverseProxy

func PingHandler

func PingHandler(w http.ResponseWriter, r *http.Request)

func SearchNotStuckHandler

func SearchNotStuckHandler(searchEngine *eosws.SearchEngine) http.Handler

func SimpleSearchHandler

func SimpleSearchHandler(db eosws.DB, blockmetaClient *pbblockmeta.Client) http.Handler

Types

type Flux

type Flux struct {
	HeadBlock    uint32 `json:"head_block"`
	BlockLatency int    `json:"block_latency"`
}

type Healthz

type Healthz struct {
	Errors  []string `json:"errors"`
	Hub     *Hub     `json:"hub,omitempty"`
	TRXDB   *TRXDB   `json:"trxdb,omitempty"`
	Flux    *Flux    `json:"flux,omitempty"`
	Search  *Search  `json:"search,omitempty"`
	Merger  *Merger  `json:"merger,omitempty"`
	Healthy struct {
		Hub    *bool `json:"hub,omitempty"`
		Merger *bool `json:"merger,omitempty"`
		TRXDB  *bool `json:"trxdb,omitempty"`
		Flux   *bool `json:"flux,omitempty"`
		Search *bool `json:"search,omitempty"`
	} `json:"healthy"`
}

type Hub

type Hub struct {
	HeadBlockNum   uint32    `json:"head_block_num"`
	HeadBlockTime  time.Time `json:"head_block_time"`
	TimeLatencySec int64     `json:"time_latency_sec"`
}

type Merger

type Merger struct {
	LastMergedBlock uint32 `json:"last_merged_block"`
	BlockLatency    int    `json:"block_latency"`
}

type PushResponse

type PushResponse struct {
	TransactionID string                `json:"transaction_id"`
	BlockID       string                `json:"block_id"`
	BlockNum      uint32                `json:"block_num"`
	Processed     *eos.TransactionTrace `json:"processed"`
}

type Search

type Search struct {
	HeadBlock    uint32 `json:"head_block"`
	BlockLatency int    `json:"block_latency"`
}

type TRXDB

type TRXDB struct {
	HeadBlock    uint32 `json:"head_block"`
	BlockLatency int    `json:"block_latency"`
}

type TxPushRouter

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

func NewTxPushRouter

func NewTxPushRouter(dumbAPIProxy http.Handler, pushTransactionHandler http.Handler) *TxPushRouter

func (*TxPushRouter) ServeHTTP

func (t *TxPushRouter) ServeHTTP(w http.ResponseWriter, r *http.Request)

type TxPusher

type TxPusher struct {
	API *eos.API
	// contains filtered or unexported fields
}

func NewTxPusher

func NewTxPusher(API *eos.API, subscriptionHub *hub.SubscriptionHub) *TxPusher

func (*TxPusher) ServeHTTP

func (t *TxPusher) ServeHTTP(w http.ResponseWriter, r *http.Request)