Help us shape the future of Go! Take the 2026 Go Developer Survey

upload

package
v0.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 15, 2020 License: Apache-2.0 Imports: 16 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthUpload        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUpload          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupUpload = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterUploadServer

func RegisterUploadServer(s *grpc.Server, srv UploadServer)

Types

type BytesMessage

type BytesMessage struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

BytesMessage contains a chunk of byte data

func (*BytesMessage) Descriptor

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

func (*BytesMessage) Equal

func (this *BytesMessage) Equal(that interface{}) bool

func (*BytesMessage) GetData

func (m *BytesMessage) GetData() []byte

func (*BytesMessage) GoString

func (this *BytesMessage) GoString() string

func (*BytesMessage) Marshal

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

func (*BytesMessage) MarshalTo

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

func (*BytesMessage) MarshalToSizedBuffer added in v0.7.0

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

func (*BytesMessage) ProtoMessage

func (*BytesMessage) ProtoMessage()

func (*BytesMessage) Reset

func (m *BytesMessage) Reset()

func (*BytesMessage) Size

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

func (*BytesMessage) String

func (this *BytesMessage) String() string

func (*BytesMessage) Unmarshal

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

func (*BytesMessage) XXX_DiscardUnknown

func (m *BytesMessage) XXX_DiscardUnknown()

func (*BytesMessage) XXX_Marshal

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

func (*BytesMessage) XXX_Merge

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

func (*BytesMessage) XXX_Size

func (m *BytesMessage) XXX_Size() int

func (*BytesMessage) XXX_Unmarshal

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

type UnimplementedUploadServer added in v0.7.0

type UnimplementedUploadServer struct {
}

UnimplementedUploadServer can be embedded to have forward compatible implementations.

func (*UnimplementedUploadServer) Pull added in v0.7.0

type Upload

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

func New

func New(ctx context.Context, c session.Caller, url *url.URL) (*Upload, error)

func (*Upload) WriteTo

func (u *Upload) WriteTo(w io.Writer) (int, error)

type UploadClient

type UploadClient interface {
	Pull(ctx context.Context, opts ...grpc.CallOption) (Upload_PullClient, error)
}

UploadClient is the client API for Upload service.

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

func NewUploadClient

func NewUploadClient(cc *grpc.ClientConn) UploadClient

type UploadServer

type UploadServer interface {
	Pull(Upload_PullServer) error
}

UploadServer is the server API for Upload service.

type Upload_PullClient

type Upload_PullClient interface {
	Send(*BytesMessage) error
	Recv() (*BytesMessage, error)
	grpc.ClientStream
}

type Upload_PullServer

type Upload_PullServer interface {
	Send(*BytesMessage) error
	Recv() (*BytesMessage, error)
	grpc.ServerStream
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL