sphere

Documentation

Index

• Variables
• type GRPCService
  • func NewGRPCService() *GRPCService
  • func (s *GRPCService) ClearShareHistory(height int32) (bool, error)
  • func (s *GRPCService) GetLatestStratumJob() (*service.StratumJob, error)
  • func (s *GRPCService) Init() error
  • func (s *GRPCService) Register(config *service.StratumConfig, sysInfo *service.SysInfo) error
  • func (s *GRPCService) SetConfig(config *conf.GRPCConfig) *GRPCService
  • func (s *GRPCService) SubmitShare(share *service.StratumShare, difficulty uint64) (service.ShareResult, error)
  • func (s *GRPCService) Subscribe(ctx context.Context, handler service.SubscribeHandler)
  • func (s *GRPCService) UnRegister() (bool, error)

Variables

var (
	RetryNum          = 1000
	ReconnectWaitTime = time.Second * 15
	Timeout           = time.Second * 30
)

Types

type GRPCService

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

func NewGRPCService

func NewGRPCService() *GRPCService

func (*GRPCService) ClearShareHistory

func (s *GRPCService) ClearShareHistory(height int32) (bool, error)

func (*GRPCService) GetLatestStratumJob

func (s *GRPCService) GetLatestStratumJob() (*service.StratumJob, error)

func (*GRPCService) Init

func (s *GRPCService) Init() error

func (*GRPCService) Register

func (s *GRPCService) Register(config *service.StratumConfig, sysInfo *service.SysInfo) error

func (*GRPCService) SetConfig

func (s *GRPCService) SetConfig(config *conf.GRPCConfig) *GRPCService

func (*GRPCService) SubmitShare

func (s *GRPCService) SubmitShare(share *service.StratumShare, difficulty uint64) (service.ShareResult, error)

func (*GRPCService) Subscribe

func (s *GRPCService) Subscribe(ctx context.Context, handler service.SubscribeHandler)

func (*GRPCService) UnRegister

func (s *GRPCService) UnRegister() (bool, error)