directinvoke

package
v0.0.0-...-07bf88e Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const DefaultRefillIntervalMs = 125

Variables

This section is empty.

Functions

func NewCancellableWriter

func NewCancellableWriter(ctx context.Context, w io.Writer) io.Writer

func NewStreamedResponseWriter

func NewStreamedResponseWriter(w io.Writer, responseBandwidthRate int64, responseBandwidthBurstSize int64) (*bandwidthlimiter.BandwidthLimitingWriter, context.CancelFunc, error)

Types

type CancellableWriter

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

func (*CancellableWriter) Write

func (w *CancellableWriter) Write(p []byte) (int, error)

type CustomerHeaders

type CustomerHeaders struct {
	CognitoIdentityID     string `json:"Cognito-Identity-Id"`
	CognitoIdentityPoolID string `json:"Cognito-Identity-Pool-Id"`
	ClientContext         string `json:"Client-Context"`
}

func (CustomerHeaders) Dump

func (s CustomerHeaders) Dump() string

func (*CustomerHeaders) Load

func (s *CustomerHeaders) Load(in string) error

type FlushingWriter

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

func NewFlushingWriter

func NewFlushingWriter(w io.Writer) *FlushingWriter

func (*FlushingWriter) Flush

func (w *FlushingWriter) Flush()

func (*FlushingWriter) Write

func (w *FlushingWriter) Write(p []byte) (n int, err error)

Jump to

Keyboard shortcuts

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