pipe

package

v0.8.2 Latest Latest Go to latest Published: Mar 31, 2026 License: AGPL-3.0 Imports: 0 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type Branch = *atomic.Value

type Buffer = *deque.Deque[any]

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

func NewError(err error) Error

func (e Error) Error() string

func (e Error) Main() gox.Elem

func (e Error) Payload() action.Payload

func (e Error) Release()

type Payload interface {
	Payload() action.Payload
	Release()
}

func EmptyPayload() Payload

type Pipe = *pipe

func NewPipe(
	ctx context.Context,
	runtime shredder.Runtime,
	renderFrame shredder.Frame,
	finalFrame *shredder.ValveFrame,
) Pipe

func (p Pipe) Branch() Branch

func (p Pipe) Context() context.Context

func (p Pipe) FinalFrame() *shredder.ValveFrame

func (p Pipe) IsEmpty() bool

func (p Pipe) RenderContent(content any)

func (p Pipe) RenderFrame() shredder.Frame

func (p Pipe) RenderProxy(el gox.Elem) (ProxyContainer, bool)

func (p Pipe) Runtime() shredder.Runtime

type ProxyContainer struct {
	Tag   string
	Attrs gox.Attrs
}

func (p ProxyContainer) Apply(pipe Pipe, containerCtx context.Context, doorID uint64, parentID uint64)

type Renderable interface {
	Render(p *pipe)
}

type Stack interface {
	Print(pr gox.Printer) error
}