streamio

Documentation

Overview

Package streamio contains wrappers intended for turning gRPC streams that send/receive messages with a []byte field into io.Writers and io.Readers.

Index

• Variables
• func NewReader(receiver func() ([]byte, error)) io.Reader
• func NewWriter(sender func(p []byte) error) io.Writer

Variables

var WriteBufferSize = 128 * 1024

WriteBufferSize is the largest []byte that Write() will pass to its underlying send function. This value can be changed at runtime using the GITALY_STREAMIO_WRITE_BUFFER_SIZE environment variable.

Functions

func NewReader

func NewReader(receiver func() ([]byte, error)) io.Reader

NewReader turns receiver into an io.Reader. Errors from the receiver function are passed on unmodified. This means receiver should emit io.EOF when done.

func NewWriter

func NewWriter(sender func(p []byte) error) io.Writer

NewWriter turns sender into an io.Writer. The sender callback will receive []byte arguments of length at most WriteBufferSize.