rpc

package

v0.30.1 Latest Latest Go to latest Published: Feb 12, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type NezhaHandler struct {
	Auth *authHandler
	// contains filtered or unexported fields
}

var NezhaHandlerSingleton *NezhaHandler

func NewNezhaHandler() *NezhaHandler

func (s *NezhaHandler) AgentConnected(streamId string, agentIo io.ReadWriteCloser) error

func (s *NezhaHandler) CloseStream(streamId string) error

func (s *NezhaHandler) CreateStream(streamId string)

func (s *NezhaHandler) GetStream(streamId string) (*ioStreamContext, error)

func (s *NezhaHandler) IOStream(stream pb.NezhaService_IOStreamServer) error

func (s *NezhaHandler) LookupGeoIP(c context.Context, r *pb.GeoIP) (*pb.GeoIP, error)

func (s *NezhaHandler) ReportSystemInfo(c context.Context, r *pb.Host) (*pb.Receipt, error)

func (s *NezhaHandler) ReportSystemState(c context.Context, r *pb.State) (*pb.Receipt, error)

func (s *NezhaHandler) ReportTask(c context.Context, r *pb.TaskResult) (*pb.Receipt, error)

func (s *NezhaHandler) RequestTask(h *pb.Host, stream pb.NezhaService_RequestTaskServer) error

func (s *NezhaHandler) StartStream(streamId string, timeout time.Duration) error

func (s *NezhaHandler) UserConnected(streamId string, userIo io.ReadWriteCloser) error