sink

package
v0.6.49 Latest Latest
Warning

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

Go to latest
Published: Jul 10, 2026 License: AGPL-3.0, Apache-2.0, MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewConsoleWriter

func NewConsoleWriter(ctx context.Context, client console.Client, options ...Option) io.WriteCloser

Types

type ConsoleWriter

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

func (*ConsoleWriter) Close

func (in *ConsoleWriter) Close() error

Close implements io.Closer interface.

func (*ConsoleWriter) Write

func (in *ConsoleWriter) Write(p []byte) (int, error)

Write implements io.Writer interface.

type Option

type Option func(*ConsoleWriter)

func WithBufferSizeLimit

func WithBufferSizeLimit(limit int) Option

func WithID

func WithID(id string) Option

func WithOnFinish

func WithOnFinish(onFinish func()) Option

func WithStopChan

func WithStopChan(stopChan chan struct{}) Option

func WithThrottle

func WithThrottle(throttle time.Duration) Option

Jump to

Keyboard shortcuts

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