http

Documentation

Index

• Constants
• func Router(logRegistry *nlogger.Registry, storage relay.Storage, ...) *mux.Router
• func Run(ctx context.Context, logRegistry *nlogger.Registry, storage relay.Storage, ...) error
• type ICQClient
  • func NewICQClient(host string) (*ICQClient, error)
  • func (c ICQClient) GetUnsuccessfulTxs() ([]relay.UnsuccessfulTxInfo, error)
  • func (c ICQClient) ResubmitTxs(txs ResubmitRequest) error
• type PromWrapper
  • func NewPromWrapper(logRegistry *nlogger.Registry, storage relay.Storage) PromWrapper
  • func (p PromWrapper) ServeHTTP(res http.ResponseWriter, req *http.Request)
• type ResubmitRequest
• type ResubmitTx

Constants

const (
	ServerContext           = "http"
	UnsuccessfulTxsResource = "/unsuccessful-txs"
	ResubmitTxs             = "/resubmit-txs"
	PrometheusMetrics       = "/metrics"
)

const MonitoringLoggerContext = "monitoring"

Functions

func Router

func Router(logRegistry *nlogger.Registry, storage relay.Storage, txProcessor relay.TXProcessor, submittedTxsTasksQueue chan relay.PendingSubmittedTxInfo) *mux.Router

func Run

func Run(ctx context.Context, logRegistry *nlogger.Registry, storage relay.Storage, txProcessor relay.TXProcessor, submittedTxsTasksQueue chan relay.PendingSubmittedTxInfo, ListenAddr string) error

Types

type ICQClient

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

ICQClient provides high level methods to work with ICQ webserver api

func NewICQClient

func NewICQClient(host string) (*ICQClient, error)

NewICQClient takes a host as a single argument and returns an ICQClient in case of well formatted host arg host format is <scheme>://<host>[:<port>], e.g. http://myicq.host, https://myicq.host, http://myicq.host:8080

func (ICQClient) GetUnsuccessfulTxs

func (c ICQClient) GetUnsuccessfulTxs() ([]relay.UnsuccessfulTxInfo, error)

func (ICQClient) ResubmitTxs

func (c ICQClient) ResubmitTxs(txs ResubmitRequest) error

type PromWrapper

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

func NewPromWrapper

func NewPromWrapper(logRegistry *nlogger.Registry, storage relay.Storage) PromWrapper

func (PromWrapper) ServeHTTP

func (p PromWrapper) ServeHTTP(res http.ResponseWriter, req *http.Request)

type ResubmitRequest

type ResubmitRequest struct {
	Txs []ResubmitTx `json:"txs"`
}

type ResubmitTx

type ResubmitTx struct {
	QueryID uint64 `json:"query_id"`
	Hash    string `json:"hash"`
}