handler

package

v0.0.0-...-fb279e6 Latest Latest Go to latest Published: May 6, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/e2b-dev/infra

Links

Open Source Insights

Documentation ¶

Index ¶

type Handler
- func New(ctx context.Context, user *user.User, req *rpc.StartRequest, ...) (*Handler, error)
type MultiplexedChannel
- func NewMultiplexedChannel[T any](buffer int) *MultiplexedChannel[T]
- func (m *MultiplexedChannel[T]) Fork() (chan T, func())
type ProcessExit

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Handler ¶

type Handler struct {
	Config *rpc.ProcessConfig

	Tag *string

	DataEvent *MultiplexedChannel[rpc.ProcessEvent_Data]
	EndEvent  *MultiplexedChannel[rpc.ProcessEvent_End]
	// contains filtered or unexported fields
}

func New ¶

func New(
	ctx context.Context,
	user *user.User,
	req *rpc.StartRequest,
	logger *zerolog.Logger,
	defaults *execcontext.Defaults,
	cgroupManager cgroups.Manager,
	cancel context.CancelFunc,
) (*Handler, error)

func (*Handler) CloseStdin ¶

func (p *Handler) CloseStdin() error

CloseStdin closes the stdin pipe to signal EOF to the process. Only works for non-PTY processes.

func (*Handler) Pid ¶

func (p *Handler) Pid() uint32

This method must be called only after the process has been started

func (*Handler) ResizeTty ¶

func (p *Handler) ResizeTty(size *pty.Winsize) error

func (*Handler) SendSignal ¶

func (p *Handler) SendSignal(signal syscall.Signal) error

func (*Handler) Start ¶

func (p *Handler) Start(requestTimeout time.Duration) (uint32, error)

func (*Handler) Wait ¶

func (p *Handler) Wait()

func (*Handler) WriteStdin ¶

func (p *Handler) WriteStdin(data []byte) error

func (*Handler) WriteTty ¶

func (p *Handler) WriteTty(data []byte) error

type MultiplexedChannel ¶

type MultiplexedChannel[T any] struct {
	Source chan T
	// contains filtered or unexported fields
}

func NewMultiplexedChannel ¶

func NewMultiplexedChannel[T any](buffer int) *MultiplexedChannel[T]

func (*MultiplexedChannel[T]) Fork ¶

func (m *MultiplexedChannel[T]) Fork() (chan T, func())

type ProcessExit ¶

type ProcessExit struct {
	Error  *string
	Status string
	Exited bool
	Code   int32
}

Source Files ¶

View all Source files

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