impl

Documentation

Index

• type SphereServer
  • func (s *SphereServer) ClearShareHistory(ctx context.Context, in *pb.ClearShareHistoryRequest) (*pb.ClearShareHistoryResponse, error)
  • func (s *SphereServer) GetLatestStratumJob(ctx context.Context, in *pb.GetLatestStratumJobRequest) (*pb.GetLatestStratumJobResponse, error)
  • func (s *SphereServer) Register(ctx context.Context, in *pb.RegisterRequest) (*pb.RegisterResponse, error)
  • func (s *SphereServer) SubmitShare(ctx context.Context, in *pb.SubmitShareRequest) (*pb.SubmitShareResponse, error)
  • func (s *SphereServer) Subscribe(in *pb.GetLatestStratumJobRequest, stream pb.Sphere_SubscribeServer) error
  • func (s *SphereServer) UnRegister(ctx context.Context, in *pb.UnRegisterRequest) (*pb.UnRegisterResponse, error)

Types

type SphereServer

type SphereServer struct {
	Conf *conf.SphereConfig
	Mgr  *service.Manager
	// contains filtered or unexported fields
}

func (*SphereServer) ClearShareHistory

func (s *SphereServer) ClearShareHistory(ctx context.Context, in *pb.ClearShareHistoryRequest) (*pb.ClearShareHistoryResponse, error)

func (*SphereServer) GetLatestStratumJob

func (s *SphereServer) GetLatestStratumJob(ctx context.Context, in *pb.GetLatestStratumJobRequest) (*pb.GetLatestStratumJobResponse, error)

func (*SphereServer) Register

func (s *SphereServer) Register(ctx context.Context, in *pb.RegisterRequest) (*pb.RegisterResponse, error)

func (*SphereServer) SubmitShare

func (s *SphereServer) SubmitShare(ctx context.Context, in *pb.SubmitShareRequest) (*pb.SubmitShareResponse, error)

func (*SphereServer) Subscribe

func (s *SphereServer) Subscribe(in *pb.GetLatestStratumJobRequest, stream pb.Sphere_SubscribeServer) error

func (*SphereServer) UnRegister

func (s *SphereServer) UnRegister(ctx context.Context, in *pb.UnRegisterRequest) (*pb.UnRegisterResponse, error)