io

Documentation

Index

• Variables
• func InspectReader(ctx context.Context, bo BufferOptions, f func([]byte) (int, error), ...) io.ReadCloser
• type BufferOptions
• type MaxBufferHandling

Variables

var (
	ErrClosed  = errors.New("reader closed")
	ErrBlocked = errors.New("blocked string match found in stream")
)

var (
	ErrMatcherBufferFull = errors.New("matcher buffer full")
)

Functions

func InspectReader

func InspectReader(ctx context.Context, bo BufferOptions, f func([]byte) (int, error), rc io.ReadCloser) io.ReadCloser

InspectReader wraps the given ReadCloser such that the given function f can inspect the streaming while streaming to the target. A target can be any io.ReadCloser, so for example the request body to the backend or the response body to the client. InspectReader applies given BufferOptions to the matcher.

NOTE: This function is *experimental* and will likely change or disappear in the future.

Types

type BufferOptions

type BufferOptions struct {
	MaxBufferHandling MaxBufferHandling
	ReadBufferSize    uint64
}

type MaxBufferHandling

type MaxBufferHandling int

const (
	MaxBufferBestEffort MaxBufferHandling = iota
	MaxBufferAbort
)