stream

Documentation

Index

• Constants
• Variables
• func RegisterStreamServer(s *grpc.Server, srv StreamServer)
• type Image
  • func (*Image) Descriptor() ([]byte, []int)
  • func (m *Image) GetHeight() int64
  • func (m *Image) GetImageData() []byte
  • func (m *Image) GetWidth() int64
  • func (m *Image) Marshal() (dAtA []byte, err error)
  • func (m *Image) MarshalTo(dAtA []byte) (int, error)
  • func (m *Image) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Image) ProtoMessage()
  • func (m *Image) Reset()
  • func (m *Image) Size() (n int)
  • func (m *Image) String() string
  • func (m *Image) Unmarshal(dAtA []byte) error
  • func (m *Image) XXX_DiscardUnknown()
  • func (m *Image) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Image) XXX_Merge(src proto.Message)
  • func (m *Image) XXX_Size() int
  • func (m *Image) XXX_Unmarshal(b []byte) error
• type Input
  • func (*Input) Descriptor() ([]byte, []int)
  • func (m *Input) Marshal() (dAtA []byte, err error)
  • func (m *Input) MarshalTo(dAtA []byte) (int, error)
  • func (m *Input) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Input) ProtoMessage()
  • func (m *Input) Reset()
  • func (m *Input) Size() (n int)
  • func (m *Input) String() string
  • func (m *Input) Unmarshal(dAtA []byte) error
  • func (m *Input) XXX_DiscardUnknown()
  • func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Input) XXX_Merge(src proto.Message)
  • func (m *Input) XXX_Size() int
  • func (m *Input) XXX_Unmarshal(b []byte) error
• type Server
  • func NewServer(r io.ReaderAt, addr int64) *Server
  • func (s *Server) GetImage(ctx context.Context, in *Input) (*Image, error)
  • func (s *Server) Start()
• type StreamClient
  • func NewStreamClient(cc *grpc.ClientConn) StreamClient
• type StreamServer
• type UnimplementedStreamServer
  • func (*UnimplementedStreamServer) GetImage(ctx context.Context, req *Input) (*Image, error)

Constants

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

Variables

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)