proxy

Documentation

Index

• Constants
• type Block
  • func (b Block) Difficulty() *big.Int
  • func (b Block) HashNoNonce() common.Hash
  • func (b Block) MixDigest() common.Hash
  • func (b Block) Nonce() uint64
  • func (b Block) NumberU64() uint64
• type BlockTemplate
• type Config
• type ErrorReply
• type JSONPushMessage
• type JSONRpcReq
• type JSONRpcReqNH
• type JSONRpcResp
• type Proxy
• type ProxyServer
  • func NewProxy(cfg *Config, backend *storage.RedisClient) *ProxyServer
  • func (s *ProxyServer) ListenNiceHashTCP()
  • func (s *ProxyServer) ListenSSLTCP()
  • func (s *ProxyServer) ListenTCP()
  • func (s *ProxyServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (s *ProxyServer) Start()
• type Session
• type Stratum
• type StratumNiceHash
• type StratumReq
• type StratumSSL
• type SubmitReply
• type Upstream

Constants

const (
	MaxReqSize = 1024
)

const (
	MaxSSLReqSize = 1024
)

Types

type Block

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

func (Block) Difficulty

func (b Block) Difficulty() *big.Int

func (Block) HashNoNonce

func (b Block) HashNoNonce() common.Hash

func (Block) MixDigest

func (b Block) MixDigest() common.Hash

func (Block) Nonce

func (b Block) Nonce() uint64

func (Block) NumberU64

func (b Block) NumberU64() uint64

type BlockTemplate

type BlockTemplate struct {
	sync.RWMutex
	Header               string
	Seed                 string
	Target               string
	Difficulty           *big.Int
	Height               uint64
	GetPendingBlockCache *rpc.GetBlockReplyPart
	// contains filtered or unexported fields
}

type Config

type Config struct {
	Name                  string        `json:"name"`
	Proxy                 Proxy         `json:"proxy"`
	Api                   api.ApiConfig `json:"api"`
	Upstream              []Upstream    `json:"upstream"`
	UpstreamCheckInterval string        `json:"upstreamCheckInterval"`

	Threads int `json:"threads"`

	Coin     string         `json:"coin"`
	Pplns    int64          `json:"pplns"`
	CoinName string         `json:"coin-name"`
	Redis    storage.Config `json:"redis"`

	BlockUnlocker payouts.UnlockerConfig `json:"unlocker"`
	Payouts       payouts.PayoutsConfig  `json:"payouts"`

	Exchange exchange.ExchangeConfig `json:"exchange"`

	NewrelicName    string `json:"newrelicName"`
	NewrelicKey     string `json:"newrelicKey"`
	NewrelicVerbose bool   `json:"newrelicVerbose"`
	NewrelicEnabled bool   `json:"newrelicEnabled"`
}

type ErrorReply

type ErrorReply struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type JSONPushMessage

type JSONPushMessage struct {
	// FIXME: Temporarily add ID for Claymore compliance
	Id      int64       `json:"id"`
	Version string      `json:"jsonrpc"`
	Result  interface{} `json:"result"`
}

Stratum

type JSONRpcReq

type JSONRpcReq struct {
	Id     json.RawMessage `json:"id"`
	Method string          `json:"method"`
	Params json.RawMessage `json:"params"`
}

type JSONRpcReqNH

type JSONRpcReqNH struct {
	Id     interface{} `json:"id"`
	Method string      `json:"method"`
	Params interface{} `json:"params"`
}

type JSONRpcResp

type JSONRpcResp struct {
	Id      json.RawMessage `json:"id"`
	Version string          `json:"jsonrpc"`
	Result  interface{}     `json:"result"`
	Error   interface{}     `json:"error,omitempty"`
}

type Proxy

type Proxy struct {
	Enabled              bool   `json:"enabled"`
	Username             string `json:"user"`
	Password             string `json:"password"`
	Listen               string `json:"listen"`
	LimitHeadersSize     int    `json:"limitHeadersSize"`
	LimitBodySize        int64  `json:"limitBodySize"`
	BehindReverseProxy   bool   `json:"behindReverseProxy"`
	BlockRefreshInterval string `json:"blockRefreshInterval"`
	Difficulty           int64  `json:"difficulty"`
	StateUpdateInterval  string `json:"stateUpdateInterval"`
	HashrateExpiration   string `json:"hashrateExpiration"`

	Policy policy.Config `json:"policy"`

	MaxFails    int64 `json:"maxFails"`
	HealthCheck bool  `json:"healthCheck"`

	Stratum    Stratum    `json:"stratum"`
	StratumSSL StratumSSL `json:"stratum_ssl"`

	StratumNiceHash StratumNiceHash `json:"stratum_nice_hash"`
}

type ProxyServer

type ProxyServer struct {
	Extranonce string
	// contains filtered or unexported fields
}

func NewProxy

func NewProxy(cfg *Config, backend *storage.RedisClient) *ProxyServer

func (*ProxyServer) ListenNiceHashTCP

func (s *ProxyServer) ListenNiceHashTCP()

func (*ProxyServer) ListenSSLTCP

func (s *ProxyServer) ListenSSLTCP()

func (*ProxyServer) ListenTCP

func (s *ProxyServer) ListenTCP()

func (*ProxyServer) ServeHTTP

func (s *ProxyServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*ProxyServer) Start

func (s *ProxyServer) Start()

type Session

type Session struct {

	// Stratum
	sync.Mutex

	JobDeatils jobDetails
	// contains filtered or unexported fields
}

type Stratum

type Stratum struct {
	Enabled bool   `json:"enabled"`
	Listen  string `json:"listen"`
	Timeout string `json:"timeout"`
	MaxConn int    `json:"maxConn"`
}

type StratumNiceHash

type StratumNiceHash struct {
	Enabled bool   `json:"enabled"`
	Listen  string `json:"listen"`
	Timeout string `json:"timeout"`
	MaxConn int    `json:"maxConn"`
}

type StratumReq

type StratumReq struct {
	JSONRpcReq
	Worker string `json:"worker"`
}

type StratumSSL

type StratumSSL struct {
	Enabled  bool   `json:"enabled"`
	Listen   string `json:"listen"`
	Timeout  string `json:"timeout"`
	MaxConn  int    `json:"maxConn"`
	CertFile string `json:"certfile"`
	CertKey  string `json:"certkey"`
}

type SubmitReply

type SubmitReply struct {
	Status string `json:"status"`
}

type Upstream

type Upstream struct {
	Name     string `json:"name"`
	Url      string `json:"url"`
	Port     string `json:"port"`
	Timeout  string `json:"timeout"`
	Username string `json:"username"`
}