Documentation

Index

Constants

View Source
const (
	// ScreenWidth of the remarkable 2
	ScreenWidth = 1872
	// ScreenHeight of the remarkable 2
	ScreenHeight = 1404
)

Variables

View Source
var (
	ErrInvalidLengthDefs3        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDefs3          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDefs3 = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterStreamServer

func RegisterStreamServer(s *grpc.Server, srv StreamServer)

Types

type Image

type Image struct {
	Width                int64    `protobuf:"varint,1,opt,name=width,proto3" json:"width,omitempty"`
	Height               int64    `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	ImageData            []byte   `protobuf:"bytes,4,opt,name=image_data,json=imageData,proto3" json:"image_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Image) Descriptor

func (*Image) Descriptor() ([]byte, []int)

func (*Image) GetHeight

func (m *Image) GetHeight() int64

func (*Image) GetImageData

func (m *Image) GetImageData() []byte

func (*Image) GetWidth

func (m *Image) GetWidth() int64

func (*Image) Marshal

func (m *Image) Marshal() (dAtA []byte, err error)

func (*Image) MarshalTo

func (m *Image) MarshalTo(dAtA []byte) (int, error)

func (*Image) MarshalToSizedBuffer

func (m *Image) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Image) ProtoMessage

func (*Image) ProtoMessage()

func (*Image) Reset

func (m *Image) Reset()

func (*Image) Size

func (m *Image) Size() (n int)

func (*Image) String

func (m *Image) String() string

func (*Image) Unmarshal

func (m *Image) Unmarshal(dAtA []byte) error

func (*Image) XXX_DiscardUnknown

func (m *Image) XXX_DiscardUnknown()

func (*Image) XXX_Marshal

func (m *Image) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Image) XXX_Merge

func (m *Image) XXX_Merge(src proto.Message)

func (*Image) XXX_Size

func (m *Image) XXX_Size() int

func (*Image) XXX_Unmarshal

func (m *Image) XXX_Unmarshal(b []byte) error

type Input

type Input struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Input) Descriptor

func (*Input) Descriptor() ([]byte, []int)

func (*Input) Marshal

func (m *Input) Marshal() (dAtA []byte, err error)

func (*Input) MarshalTo

func (m *Input) MarshalTo(dAtA []byte) (int, error)

func (*Input) MarshalToSizedBuffer

func (m *Input) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Input) ProtoMessage

func (*Input) ProtoMessage()

func (*Input) Reset

func (m *Input) Reset()

func (*Input) Size

func (m *Input) Size() (n int)

func (*Input) String

func (m *Input) String() string

func (*Input) Unmarshal

func (m *Input) Unmarshal(dAtA []byte) error

func (*Input) XXX_DiscardUnknown

func (m *Input) XXX_DiscardUnknown()

func (*Input) XXX_Marshal

func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Input) XXX_Merge

func (m *Input) XXX_Merge(src proto.Message)

func (*Input) XXX_Size

func (m *Input) XXX_Size() int

func (*Input) XXX_Unmarshal

func (m *Input) XXX_Unmarshal(b []byte) error

type Server

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

    Server implementation

    func NewServer

    func NewServer(r io.ReaderAt, addr int64) *Server

      NewServer ...

      func (*Server) GetImage

      func (s *Server) GetImage(ctx context.Context, in *Input) (*Image, error)

        GetImage input is nil

        func (*Server) Start

        func (s *Server) Start()

          Start the pooling thread

          type StreamClient

          type StreamClient interface {
          	GetImage(ctx context.Context, in *Input, opts ...grpc.CallOption) (*Image, error)
          }

            StreamClient is the client API for Stream service.

            For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

            func NewStreamClient

            func NewStreamClient(cc *grpc.ClientConn) StreamClient

            type StreamServer

            type StreamServer interface {
            	GetImage(context.Context, *Input) (*Image, error)
            }

              StreamServer is the server API for Stream service.

              type UnimplementedStreamServer

              type UnimplementedStreamServer struct {
              }

                UnimplementedStreamServer can be embedded to have forward compatible implementations.

                func (*UnimplementedStreamServer) GetImage

                func (*UnimplementedStreamServer) GetImage(ctx context.Context, req *Input) (*Image, error)