indexers

Documentation

Index

• type Server
  • func NewServer() *Server
  • func (s *Server) CollectBlock(stream ci_pb.Rover_CollectBlockServer) error
  • func (s *Server) IsBeforeSettleHeight(context.Context, *ci_pb.SettleTxCheckReq) (*ci_pb.SettleTxCheckResponse, error)
  • func (s *Server) Join(joinReq *ci_pb.RoverIdent, stream ci_pb.Rover_JoinServer) error
  • func (s *Server) PushRoverRequest(rover string, req *ci_pb.RoverMessage)
  • func (s *Server) ReportBlockRange(context.Context, *ci_pb.RoverMessage_RoverBlockRange) (*ci_pb.Null, error)
  • func (s *Server) ReportSyncStatus(ctx context.Context, status *ci_pb.RoverSyncStatus) (*ci_pb.Null, error)

Types

type Server

type Server struct {
	ci_pb.UnimplementedRoverServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer() *Server

func (*Server) CollectBlock

func (s *Server) CollectBlock(stream ci_pb.Rover_CollectBlockServer) error

func (*Server) IsBeforeSettleHeight

func (s *Server) IsBeforeSettleHeight(context.Context, *ci_pb.SettleTxCheckReq) (*ci_pb.SettleTxCheckResponse, error)

func (*Server) Join

func (s *Server) Join(joinReq *ci_pb.RoverIdent, stream ci_pb.Rover_JoinServer) error

func (*Server) PushRoverRequest

func (s *Server) PushRoverRequest(rover string, req *ci_pb.RoverMessage)

func (*Server) ReportBlockRange

func (s *Server) ReportBlockRange(context.Context, *ci_pb.RoverMessage_RoverBlockRange) (*ci_pb.Null, error)

func (*Server) ReportSyncStatus

func (s *Server) ReportSyncStatus(ctx context.Context, status *ci_pb.RoverSyncStatus) (*ci_pb.Null, error)