proxy

Feb 21, 2025

Changes in this version

+ const CONNECTION_TIMEOUT

+ const DIAL_TIMEOUT

+ const MAX_CONSEQUENT_INVALID_SHARES

+ const RECONNECT_TIMEOUT

+ const RESPONSE_TIMEOUT

+ const WRITE_TIMEOUT

+ var ErrAutoreadStarted = errors.New("autoread already started")

+ var ErrChangeDest = errors.New("destination change error")

+ var ErrConnectDest = errors.New("failure during connecting to destination")

+ var ErrConnectSource = errors.New("failure during source connection")

+ var ErrDest = errors.New("destination connection error")

+ var ErrHandshakeDest = errors.New("failure during handshake with destination")

+ var ErrHandshakeSource = errors.New("failure during handshake with source")

+ var ErrIdleReadTimeout = fmt.Errorf("connection idle read timeout")

+ var ErrIdleWriteTimeout = fmt.Errorf("connection idle write timeout")

+ var ErrNotAValidator = errors.New("not a validator for this contract")

+ var ErrNotAuthorizedPool = errors.New("not authorized in the pool")

+ var ErrNotStratum = errors.New("not a stratum protocol")

+ var ErrProxy = errors.New("proxy error")

+ var ErrSource = errors.New("source connection error")

+ var ErrUnknownContract = errors.New("incoming connection for unknown contract")

+ func NewPipeSync(stream1, stream2 i.StratumReadWriter, interceptor1, interceptor2 Interceptor) *pipeSync

+ type ConnDest struct

+ func ConnectDest(ctx context.Context, destURL *url.URL, valid *validator.Validator, ...) (*ConnDest, error)

+ func NewDestConn(conn *StratumConnection, valid *validator.Validator, url *url.URL, ...) *ConnDest

+ func (c *ConnDest) AutoRead(ctx context.Context) error

+ func (c *ConnDest) AutoReadStart(ctx context.Context, cb func(err error)) (ok bool)

+ func (c *ConnDest) AutoReadStop() error

+ func (c *ConnDest) GetDiff() float64

+ func (c *ConnDest) GetExtraNonce() (extraNonce string, extraNonceSize int)

+ func (c *ConnDest) GetFirstJobSignal() <-chan struct{}

+ func (c *ConnDest) GetHR() gi.Hashrate

+ func (c *ConnDest) GetIdleCloseAt() time.Time

+ func (c *ConnDest) GetLatestJob() (*validator.MiningJob, bool)

+ func (c *ConnDest) GetStats() *DestStats

+ func (c *ConnDest) GetUserName() string

+ func (c *ConnDest) GetVersionRolling() (versionRolling bool, versionRollingMask string)

+ func (c *ConnDest) HasJob(jobID string) bool

+ func (c *ConnDest) ID() string

+ func (c *ConnDest) Read(ctx context.Context) (i.MiningMessageGeneric, error)

+ func (c *ConnDest) ResetIdleCloseTimers()

+ func (c *ConnDest) SetExtraNonce(extraNonce string, extraNonceSize int)

+ func (c *ConnDest) SetUserName(userName string)

+ func (c *ConnDest) SetVersionRolling(versionRolling bool, versionRollingMask string)

+ func (c *ConnDest) ValidateAndAddShare(msg *sm.MiningSubmit) (float64, error)

+ func (c *ConnDest) Write(ctx context.Context, msg i.MiningMessageGeneric) error

+ func (s *ConnDest) WriteAwaitRes(parentCtx context.Context, msg i.MiningMessageWithID) (resMsg i.MiningMessageWithID, err error)

+ type ConnSource struct

+ func NewSourceConn(conn *StratumConnection, log globalInterfaces.ILogger) *ConnSource

+ func (c *ConnSource) GetConnectedAt() time.Time

+ func (c *ConnSource) GetExtraNonce() (extraNonce string, extraNonceSize int)

+ func (c *ConnSource) GetID() string

+ func (c *ConnSource) GetNegotiatedVersionRollingMask() string

+ func (c *ConnSource) GetStats() *SourceStats

+ func (c *ConnSource) GetUserName() string

+ func (c *ConnSource) GetVersionRolling() (mask string, minBitCount int)

+ func (c *ConnSource) Read(ctx context.Context) (interfaces.MiningMessageGeneric, error)

+ func (c *ConnSource) SetExtraNonce(extraNonce string, extraNonceSize int)

+ func (c *ConnSource) SetNegotiatedVersionRollingMask(mask string)

+ func (c *ConnSource) SetUserName(userName string)

+ func (c *ConnSource) SetVersionRolling(mask string, minBitCount int)

+ func (c *ConnSource) Write(ctx context.Context, msg interfaces.MiningMessageGeneric) error

+ type DestConnFactory = func(ctx context.Context, url *url.URL, srcWorker, srcAddr string) (*ConnDest, error)

+ type DestStats struct

+ WeAcceptedTheyAccepted atomic.Uint64

+ WeAcceptedTheyRejected atomic.Uint64

+ WeRejectedTheyAccepted atomic.Uint64

+ func (s *DestStats) GetStatsMap() map[string]int

+ func (s *DestStats) IncWeAcceptedTheyAccepted()

+ func (s *DestStats) IncWeAcceptedTheyRejected()

+ func (s *DestStats) IncWeRejectedTheyAccepted()

+ type GetContractFromStoreFn func(id string) (resources.Contract, bool)

+ type GlobalHashrateCounter interface

+ OnConnect func(workerName string)

+ OnSubmit func(workerName string, diff float64)

+ type HandlerChangeDest struct

+ func NewHandlerChangeDest(proxy *Proxy, destFactory DestConnFactory) *HandlerChangeDest

+ type HandlerFirstConnect struct

+ func NewHandlerFirstConnect(proxy *Proxy) *HandlerFirstConnect

+ func (p *HandlerFirstConnect) Connect(ctx context.Context) error

+ type HandlerMining struct

+ func NewHandlerMining(proxy *Proxy) *HandlerMining

+ type Hashrate interface

+ GetHashrateAvgGHSAll func() map[string]float64

+ GetHashrateAvgGHSCustom func(ID string) (hrGHS float64, ok bool)

+ GetLastSubmitTime func() time.Time

+ GetTotalDuration func() time.Duration

+ GetTotalShares func() int

+ GetTotalWork func() float64

+ type HashrateCounter interface

+ OnSubmit func(diff float64)

+ type HashrateCounterFunc func(diff float64)

+ type HashrateFactory = func() *hashrate.Hashrate

+ type Interceptor = func(context.Context, i.MiningMessageGeneric) (i.MiningMessageGeneric, error)

+ type Pipe struct

+ func NewPipe(source, dest i.StratumReadWriter, ...) *Pipe

+ func (p *Pipe) GetDest() i.StratumReadWriter

+ func (p *Pipe) GetSource() i.StratumReadWriter

+ func (p *Pipe) Run(ctx context.Context) error

+ func (p *Pipe) SetDest(dest i.StratumReadWriter)

+ func (p *Pipe) SetSource(source i.StratumReadWriter)

+ func (p *Pipe) StartDestToSource(ctx context.Context)

+ func (p *Pipe) StartSourceToDest(ctx context.Context)

+ func (p *Pipe) StopDestToSource() <-chan struct{}

+ func (p *Pipe) StopSourceToDest() <-chan struct{}

+ type Proxy struct

+ ID string

+ func NewProxy(ID string, source *ConnSource, destFactory DestConnFactory, ...) *Proxy

+ func (p *Proxy) Connect(ctx context.Context) error

+ func (p *Proxy) ConnectDest(ctx context.Context, newDestURL *url.URL) error

+ func (p *Proxy) GetConnectedAt() time.Time

+ func (p *Proxy) GetDest() *url.URL

+ func (p *Proxy) GetDestByJobID(jobID string) *ConnDest

+ func (p *Proxy) GetDestByJobIDAndValidate(msg *stratumv1_message.MiningSubmit) (*ConnDest, float64, error)

+ func (p *Proxy) GetDestConns() *map[string]string

+ func (p *Proxy) GetDestWorkerName() string

+ func (p *Proxy) GetDifficulty() float64

+ func (p *Proxy) GetHashrate() Hashrate

+ func (p *Proxy) GetID() string

+ func (p *Proxy) GetIncomingContractID() *string

+ func (p *Proxy) GetMinerConnectedAt() time.Time

+ func (p *Proxy) GetSourceWorkerName() string

+ func (p *Proxy) GetStats() map[string]int

+ func (p *Proxy) IsVetting() bool

+ func (p *Proxy) Run(ctx context.Context) error

+ func (p *Proxy) SetDest(ctx context.Context, newDestURL *url.URL, onSubmit func(diff float64)) error

+ func (p *Proxy) SetDestWithoutAutoread(ctx context.Context, newDestURL *url.URL, onSubmit func(diff float64)) error

+ func (p *Proxy) VettingDone() <-chan struct{}

+ type ResultHandler = func(a *m.MiningResult) (msg i.MiningMessageWithID, err error)

+ type SourceStats struct

+ WeAcceptedShares atomic.Uint64

+ WeAcceptedTheyRejected atomic.Uint64

+ WeRejectedShares atomic.Uint64

+ WeRejectedTheyAccepted atomic.Uint64

+ func (s *SourceStats) GetStatsMap() map[string]int

+ func (s *SourceStats) IncWeAcceptedShares()

+ func (s *SourceStats) IncWeAcceptedTheyRejected()

+ func (s *SourceStats) IncWeRejectedShares()

+ func (s *SourceStats) IncWeRejectedTheyAccepted()

+ type StratumConnection struct

+ func Connect(address *url.URL, idleReadCloseTimeout, idleWriteCloseTimeout time.Duration, ...) (*StratumConnection, error)

+ func CreateConnection(conn net.Conn, address string, idleReadTimeout, idleWriteTimeout time.Duration, ...) *StratumConnection

+ func (c *StratumConnection) Close() error

+ func (c *StratumConnection) GetConnectedAt() time.Time

+ func (c *StratumConnection) GetID() string

+ func (c *StratumConnection) GetIdleCloseAt() time.Time

+ func (c *StratumConnection) LocalPort() string

+ func (c *StratumConnection) Read(ctx context.Context) (interfaces.MiningMessageGeneric, error)

+ func (c *StratumConnection) ResetIdleCloseTimers()

+ func (c *StratumConnection) Write(ctx context.Context, msg interfaces.MiningMessageGeneric) error