io

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AdaptReader 

func AdaptReader(t Reader) *rpc.Interface

func AdaptReaderAt 

func AdaptReaderAt(t ReaderAt) *rpc.Interface

func AdaptWriter 

func AdaptWriter(t Writer) *rpc.Interface

func AsReader 

func AsReader(ctx context.Context, rc ReaderClient) io.Reader

func AsReaderAt 

func AsReaderAt(ctx context.Context, rc ReaderAtClient) io.ReaderAt

func AsWriter 

func AsWriter(ctx context.Context, wc WriterClient) io.Writer

Types

type Reader 

type Reader interface {
	Read(ctx context.Context, state *ReaderRead) error
}

func ServeReader 

func ServeReader(r io.Reader) Reader

type ReaderAt 

type ReaderAt interface {
	ReadAt(ctx context.Context, state *ReaderAtReadAt) error
}

func ServeReaderAt 

func ServeReaderAt(r io.ReaderAt) ReaderAt

type ReaderAtClient 

type ReaderAtClient struct {
	rpc.Client
}

func NewReaderAtClient 

func NewReaderAtClient(client rpc.Client) *ReaderAtClient

func (ReaderAtClient) Export 

func (c ReaderAtClient) Export() ReaderAt

func (ReaderAtClient) ReadAt 

func (v ReaderAtClient) ReadAt(ctx context.Context, count int32, offset int64) (*ReaderAtClientReadAtResults, error)

type ReaderAtClientReadAtResults 

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

func (*ReaderAtClientReadAtResults) Data 

func (v *ReaderAtClientReadAtResults) Data() []byte

func (*ReaderAtClientReadAtResults) HasData 

func (v *ReaderAtClientReadAtResults) HasData() bool

type ReaderAtReadAt 

type ReaderAtReadAt struct {
	rpc.Call
	// contains filtered or unexported fields
}

func (*ReaderAtReadAt) Args 

func (t *ReaderAtReadAt) Args() *ReaderAtReadAtArgs

func (*ReaderAtReadAt) Results 

func (t *ReaderAtReadAt) Results() *ReaderAtReadAtResults

type ReaderAtReadAtArgs 

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

func (*ReaderAtReadAtArgs) Count 

func (v *ReaderAtReadAtArgs) Count() int32

func (*ReaderAtReadAtArgs) HasCount 

func (v *ReaderAtReadAtArgs) HasCount() bool

func (*ReaderAtReadAtArgs) HasOffset 

func (v *ReaderAtReadAtArgs) HasOffset() bool

func (*ReaderAtReadAtArgs) MarshalCBOR 

func (v *ReaderAtReadAtArgs) MarshalCBOR() ([]byte, error)

func (*ReaderAtReadAtArgs) MarshalJSON 

func (v *ReaderAtReadAtArgs) MarshalJSON() ([]byte, error)

func (*ReaderAtReadAtArgs) Offset 

func (v *ReaderAtReadAtArgs) Offset() int64

func (*ReaderAtReadAtArgs) UnmarshalCBOR 

func (v *ReaderAtReadAtArgs) UnmarshalCBOR(data []byte) error

func (*ReaderAtReadAtArgs) UnmarshalJSON 

func (v *ReaderAtReadAtArgs) UnmarshalJSON(data []byte) error

type ReaderAtReadAtResults 

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

func (*ReaderAtReadAtResults) MarshalCBOR 

func (v *ReaderAtReadAtResults) MarshalCBOR() ([]byte, error)

func (*ReaderAtReadAtResults) MarshalJSON 

func (v *ReaderAtReadAtResults) MarshalJSON() ([]byte, error)

func (*ReaderAtReadAtResults) SetData 

func (v *ReaderAtReadAtResults) SetData(data []byte)

func (*ReaderAtReadAtResults) UnmarshalCBOR 

func (v *ReaderAtReadAtResults) UnmarshalCBOR(data []byte) error

func (*ReaderAtReadAtResults) UnmarshalJSON 

func (v *ReaderAtReadAtResults) UnmarshalJSON(data []byte) error

type ReaderClient 

type ReaderClient struct {
	rpc.Client
}

func NewReaderClient 

func NewReaderClient(client rpc.Client) *ReaderClient

func (ReaderClient) Export 

func (c ReaderClient) Export() Reader

func (ReaderClient) Read 

func (v ReaderClient) Read(ctx context.Context, count int32) (*ReaderClientReadResults, error)

type ReaderClientReadResults 

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

func (*ReaderClientReadResults) Data 

func (v *ReaderClientReadResults) Data() []byte

func (*ReaderClientReadResults) HasData 

func (v *ReaderClientReadResults) HasData() bool

type ReaderRead 

type ReaderRead struct {
	rpc.Call
	// contains filtered or unexported fields
}

func (*ReaderRead) Args 

func (t *ReaderRead) Args() *ReaderReadArgs

func (*ReaderRead) Results 

func (t *ReaderRead) Results() *ReaderReadResults

type ReaderReadArgs 

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

func (*ReaderReadArgs) Count 

func (v *ReaderReadArgs) Count() int32

func (*ReaderReadArgs) HasCount 

func (v *ReaderReadArgs) HasCount() bool

func (*ReaderReadArgs) MarshalCBOR 

func (v *ReaderReadArgs) MarshalCBOR() ([]byte, error)

func (*ReaderReadArgs) MarshalJSON 

func (v *ReaderReadArgs) MarshalJSON() ([]byte, error)

func (*ReaderReadArgs) UnmarshalCBOR 

func (v *ReaderReadArgs) UnmarshalCBOR(data []byte) error

func (*ReaderReadArgs) UnmarshalJSON 

func (v *ReaderReadArgs) UnmarshalJSON(data []byte) error

type ReaderReadResults 

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

func (*ReaderReadResults) MarshalCBOR 

func (v *ReaderReadResults) MarshalCBOR() ([]byte, error)

func (*ReaderReadResults) MarshalJSON 

func (v *ReaderReadResults) MarshalJSON() ([]byte, error)

func (*ReaderReadResults) SetData 

func (v *ReaderReadResults) SetData(data []byte)

func (*ReaderReadResults) UnmarshalCBOR 

func (v *ReaderReadResults) UnmarshalCBOR(data []byte) error

func (*ReaderReadResults) UnmarshalJSON 

func (v *ReaderReadResults) UnmarshalJSON(data []byte) error

type Writer 

type Writer interface {
	Write(ctx context.Context, state *WriterWrite) error
}

func ServeWriter 

func ServeWriter(w io.Writer) Writer

type WriterClient 

type WriterClient struct {
	rpc.Client
}

func NewWriterClient 

func NewWriterClient(client rpc.Client) *WriterClient

func (WriterClient) Export 

func (c WriterClient) Export() Writer

func (WriterClient) Write 

func (v WriterClient) Write(ctx context.Context, data []byte) (*WriterClientWriteResults, error)

type WriterClientWriteResults 

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

func (*WriterClientWriteResults) Count 

func (v *WriterClientWriteResults) Count() int32

func (*WriterClientWriteResults) HasCount 

func (v *WriterClientWriteResults) HasCount() bool

type WriterWrite 

type WriterWrite struct {
	rpc.Call
	// contains filtered or unexported fields
}

func (*WriterWrite) Args 

func (t *WriterWrite) Args() *WriterWriteArgs

func (*WriterWrite) Results 

func (t *WriterWrite) Results() *WriterWriteResults

type WriterWriteArgs 

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

func (*WriterWriteArgs) Data 

func (v *WriterWriteArgs) Data() []byte

func (*WriterWriteArgs) HasData 

func (v *WriterWriteArgs) HasData() bool

func (*WriterWriteArgs) MarshalCBOR 

func (v *WriterWriteArgs) MarshalCBOR() ([]byte, error)

func (*WriterWriteArgs) MarshalJSON 

func (v *WriterWriteArgs) MarshalJSON() ([]byte, error)

func (*WriterWriteArgs) UnmarshalCBOR 

func (v *WriterWriteArgs) UnmarshalCBOR(data []byte) error

func (*WriterWriteArgs) UnmarshalJSON 

func (v *WriterWriteArgs) UnmarshalJSON(data []byte) error

type WriterWriteResults 

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

func (*WriterWriteResults) MarshalCBOR 

func (v *WriterWriteResults) MarshalCBOR() ([]byte, error)

func (*WriterWriteResults) MarshalJSON 

func (v *WriterWriteResults) MarshalJSON() ([]byte, error)

func (*WriterWriteResults) SetCount 

func (v *WriterWriteResults) SetCount(count int32)

func (*WriterWriteResults) UnmarshalCBOR 

func (v *WriterWriteResults) UnmarshalCBOR(data []byte) error

func (*WriterWriteResults) UnmarshalJSON 

func (v *WriterWriteResults) UnmarshalJSON(data []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.