rest

package

v0.1.0-beta Latest Latest Go to latest Published: Apr 17, 2020 License: Apache-2.0 Imports: 41 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dfuse-io/dfuse-eosio

Links

Open Source Insights

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 SetLogger(logger *zap.Logger)
func SimpleSearchHandler(db eosws.DB, blockmetaClient *pbblockmeta.Client) http.Handler
type EOSDB
type Flux
type Healthz
type Hub
type Merger
type PushResponse
type Search
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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 SetLogger ¶

func SetLogger(logger *zap.Logger)

func SimpleSearchHandler ¶

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

Types ¶

type EOSDB ¶

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

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"`
	EOSDB   *EOSDB   `json:"eosdb,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"`
		EOSDB  *bool `json:"eosdb,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 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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL