Documentation
¶
Index ¶
- Constants
- type Block
- type BlockTemplate
- type ClusterNode
- type Config
- type DiffAdjust
- type ErrorReply
- type JSONPushMessage
- type JSONRpcReq
- type JSONRpcResp
- type Log
- type Proxy
- type ProxyServer
- func (s *ProxyServer) DumpAllSessionNames() map[string]struct{}
- func (s *ProxyServer) ListenTCP(listenEndPoint string, timeOutStr string)
- func (s *ProxyServer) ListenTLS(listenEndPoint string, timeOutStr string, tlsCert string, tlsKey string)
- func (s *ProxyServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (s *ProxyServer) Start()
- func (s *ProxyServer) UpdateAllSessionCache()
- func (s *ProxyServer) UpdateAllSessionDiff()
- type Session
- type Stratum
- type StratumReq
- type StratumTls
- type StratumVIP
- type SubmitReply
- type Upstream
Constants ¶
View Source
const (
MaxReqSize = 1024
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Block ¶
type Block struct {
// contains filtered or unexported fields
}
func (Block) Difficulty ¶
func (Block) HashNoNonce ¶
type BlockTemplate ¶
type ClusterNode ¶
type Config ¶
type Config struct {
Name string `json:"-"`
LocalIP string `json:"-"`
Log Log `json:"log"`
Cluster []ClusterNode `json:"cluster"`
Proxy Proxy `json:"proxy"`
Api api.ApiConfig `json:"api"`
Upstream []Upstream `json:"upstream"`
UpstreamCheckInterval string `json:"upstreamCheckInterval"`
UpstreamCoinBaseEncrypted string `json:"upstreamCoinBaseEncrypted"`
UpstreamCoinBase string `json:"-"`
Threads int `json:"threads"`
Coin string `json:"coin"`
Redis storage.Config `json:"redis"`
RedisFailover storage.ConfigFailover `json:"redisFailover"`
BlockUnlocker payouts.UnlockerConfig `json:"unlocker"`
Payouts payouts.PayoutsConfig `json:"payouts"`
NewrelicName string `json:"newrelicName"`
NewrelicKey string `json:"newrelicKey"`
NewrelicVerbose bool `json:"newrelicVerbose"`
NewrelicEnabled bool `json:"newrelicEnabled"`
}
type DiffAdjust ¶
type ErrorReply ¶
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 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"`
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"`
StratumVIP StratumVIP `json:"stratumVIP"`
StratumTls StratumTls `json:"stratumTls"`
StratumMaxConn int `json:"stratumMaxConn"`
DiffAdjust DiffAdjust `json:"diffAdjust"`
}
type ProxyServer ¶
type ProxyServer struct {
// contains filtered or unexported fields
}
func NewProxy ¶
func NewProxy(cfg *Config, backend *storage.RedisClient) *ProxyServer
func (*ProxyServer) DumpAllSessionNames ¶
func (s *ProxyServer) DumpAllSessionNames() map[string]struct{}
func (*ProxyServer) ListenTCP ¶
func (s *ProxyServer) ListenTCP(listenEndPoint string, timeOutStr string)
func (*ProxyServer) ListenTLS ¶
func (s *ProxyServer) ListenTLS(listenEndPoint string, timeOutStr string, tlsCert string, tlsKey string)
func (*ProxyServer) ServeHTTP ¶
func (s *ProxyServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
func (*ProxyServer) Start ¶
func (s *ProxyServer) Start()
func (*ProxyServer) UpdateAllSessionCache ¶
func (s *ProxyServer) UpdateAllSessionCache()
func (*ProxyServer) UpdateAllSessionDiff ¶
func (s *ProxyServer) UpdateAllSessionDiff()
type StratumReq ¶
type StratumReq struct {
JSONRpcReq
Worker string `json:"worker"`
}
type StratumTls ¶
type StratumVIP ¶
type SubmitReply ¶
type SubmitReply struct {
Status string `json:"status"`
}
Click to show internal directories.
Click to hide internal directories.