device

package

v0.1.0 Latest Latest Go to latest Published: Feb 27, 2023 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Server struct {
	pb.UnimplementedDeviceServer

	*xgrpc.Server
	// contains filtered or unexported fields
}

func NewServer(c *xgrpc.ServerConfig, d *device.Device) *Server

func (s *Server) Connect(ctx context.Context, req *pb.ConnectReq) (*pb.ConnectReply, error)

func (s *Server) DisConnect(context.Context, *pb.DisConnectReq) (*pb.DisConnectReply, error)

func (s *Server) Focus(ctx context.Context, req *pb.FocusReq) (*pb.FocusReply, error)

func (s *Server) Input(req pb.Device_InputServer) error

func (s *Server) OnReceive(c *net.IMConn, proto *comet.Proto) error

func (s *Server) Output(req *pb.OutputReq, reply pb.Device_OutputServer) error

func (s *Server) ReConnect(ctx context.Context, req *pb.ReConnectReq) (*pb.ReConnectReply, error)

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

func (s *Session) GetChannel() xproto.Channel

func (s *Session) GetTarget() string

func (s *Session) SetChannel(ch xproto.Channel)

func (s *Session) SetTarget(target string)

Path	Synopsis
api