bytestreamio

Documentation

Overview

Package bytestreamio provides io interfaces on bytestream service.

Index

• func Exists(ctx context.Context, c pb.ByteStreamClient, resourceName string) error
• type Reader
  • func Open(ctx context.Context, c pb.ByteStreamClient, resourceName string) (*Reader, error)
  • func (r *Reader) Read(buf []byte) (int, error)
  • func (r *Reader) Size() int64
• type Writer
  • func Create(ctx context.Context, c pb.ByteStreamClient, resourceName string) (*Writer, error)
  • func (w *Writer) Close() error
  • func (w *Writer) Write(buf []byte) (int, error)

Functions

func Exists

func Exists(ctx context.Context, c pb.ByteStreamClient, resourceName string) error

Exists checks resource identified by resourceName exists in bytestream server.

Types

type Reader

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

Reader is a reader on bytestream.

func Open

func Open(ctx context.Context, c pb.ByteStreamClient, resourceName string) (*Reader, error)

Open opens reader on bytestream for resourceName. ctx will be used until Reader is closed.

func (*Reader) Read

func (r *Reader) Read(buf []byte) (int, error)

Read reads data from bytestream. The maximum data chunk size would be determined by server side.

func (*Reader) Size

func (r *Reader) Size() int64

Size reports read size by Read.

type Writer

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

Writer is a writer on bytestream.

func Create

func Create(ctx context.Context, c pb.ByteStreamClient, resourceName string) (*Writer, error)

Create creates writer on bytestream for resourceName. ctx will be used until Writer is closed.

func (*Writer) Close

func (w *Writer) Close() error

Close cloes the writer.

func (*Writer) Write

func (w *Writer) Write(buf []byte) (int, error)

Write writes data to bytestream. The maximum data chunk size would be determined by server side, so don't pass larger chunk than maximum data chunk size.