device

Documentation

Index

• type Server
  • 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
  • func (s *Session) GetChannel() xproto.Channel
  • func (s *Session) GetTarget() string
  • func (s *Session) SetChannel(ch xproto.Channel)
  • func (s *Session) SetTarget(target string)

Types

type Server

type Server struct {
	pb.UnimplementedDeviceServer

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

func NewServer

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

func (*Server) Connect

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

func (*Server) DisConnect

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

func (*Server) Focus

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

func (*Server) Input

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

func (*Server) OnReceive

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

func (*Server) Output

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

func (*Server) ReConnect

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

type Session

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

func (*Session) GetChannel

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

func (*Session) GetTarget

func (s *Session) GetTarget() string

func (*Session) SetChannel

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

func (*Session) SetTarget

func (s *Session) SetTarget(target string)