shredder

package

v0.9.2 Latest Latest Go to latest Published: Apr 19, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

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

Repository

github.com/doors-dev/doors

Links

Open Source Insights

Documentation ¶

Index ¶

type AfterFrame
- func (f *AfterFrame) Activate()
- func (f *AfterFrame) Run(ctx context.Context, r Runtime, fun func(bool))
- func (f *AfterFrame) RunAfter(ctx context.Context, r Runtime, fun func(bool))
- func (f *AfterFrame) Submit(ctx context.Context, r Runtime, fun func(bool))
type AnyFrame
type Frame
- func Join(release bool, frames ...AnyFrame) Frame
type FreeFrame
- func (f FreeFrame) Release()
- func (f FreeFrame) Run(ctx context.Context, r Runtime, fun func(bool))
- func (f FreeFrame) Submit(ctx context.Context, r Runtime, fun func(bool))
type Guard
type ReadBlockingWriteThread
- func (f *ReadBlockingWriteThread) Read() Frame
- func (f *ReadBlockingWriteThread) Write() (write Frame, read Frame)
type ReadStarveWriteThread
- func (r *ReadStarveWriteThread) Read() Frame
- func (r *ReadStarveWriteThread) Write() Frame
type ReadWriteThread
- func (r *ReadWriteThread) Read() Frame
- func (r *ReadWriteThread) Write() Frame
type Runtime
- func NewRuntime(ctx context.Context, workerLimit int, shutdown Shutdown) Runtime
- func (r Runtime) Cancel()
- func (r Runtime) Context() context.Context
- func (r Runtime) Go(ctx context.Context, fun func(ctx context.Context))
- func (r Runtime) Run(ctx context.Context, fun func(bool), callback func(error))
- func (r Runtime) SafeCtxFun(ctx context.Context, fun func(context.Context))
- func (r Runtime) SafeHook(ctx context.Context, w http.ResponseWriter, req *http.Request, ...) (bool, error)
- func (r Runtime) Submit(ctx context.Context, fun func(bool), callback func(error))
type Shutdown
type SimpleFrame
type Thread
- func (s *Thread) Frame() Frame
- func (s *Thread) Guard() Guard
type ValveFrame
- func (f *ValveFrame) Activate()
- func (f *ValveFrame) Run(ctx context.Context, s Runtime, fun func(bool))
- func (f *ValveFrame) Submit(ctx context.Context, s Runtime, fun func(bool))

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AfterFrame ¶

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

func (*AfterFrame) Activate ¶

func (f *AfterFrame) Activate()

func (*AfterFrame) Run ¶

func (f *AfterFrame) Run(ctx context.Context, r Runtime, fun func(bool))

func (*AfterFrame) RunAfter ¶

func (f *AfterFrame) RunAfter(ctx context.Context, r Runtime, fun func(bool))

func (*AfterFrame) Submit ¶

func (f *AfterFrame) Submit(ctx context.Context, r Runtime, fun func(bool))

type AnyFrame ¶

type AnyFrame interface {
	// contains filtered or unexported methods
}

type Frame ¶

type Frame interface {
	Guard
	SimpleFrame
}

func Join ¶

func Join(release bool, frames ...AnyFrame) Frame

type FreeFrame ¶

type FreeFrame struct{}

func (FreeFrame) Release ¶ added in v0.8.14

func (f FreeFrame) Release()

func (FreeFrame) Run ¶

func (f FreeFrame) Run(ctx context.Context, r Runtime, fun func(bool))

func (FreeFrame) Submit ¶

func (f FreeFrame) Submit(ctx context.Context, r Runtime, fun func(bool))

type Guard ¶

type Guard interface {
	Release()
}

type ReadBlockingWriteThread ¶ added in v0.8.14

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

func (*ReadBlockingWriteThread) Read ¶ added in v0.8.14

func (f *ReadBlockingWriteThread) Read() Frame

func (*ReadBlockingWriteThread) Write ¶ added in v0.8.14

func (f *ReadBlockingWriteThread) Write() (write Frame, read Frame)

type ReadStarveWriteThread ¶ added in v0.8.14

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

func (*ReadStarveWriteThread) Read ¶ added in v0.8.14

func (r *ReadStarveWriteThread) Read() Frame

func (*ReadStarveWriteThread) Write ¶ added in v0.8.14

func (r *ReadStarveWriteThread) Write() Frame

type ReadWriteThread ¶ added in v0.8.14

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

func (*ReadWriteThread) Read ¶ added in v0.8.14

func (r *ReadWriteThread) Read() Frame

func (*ReadWriteThread) Write ¶ added in v0.8.14

func (r *ReadWriteThread) Write() Frame

type Runtime ¶

type Runtime = *runtime

func NewRuntime ¶

func NewRuntime(ctx context.Context, workerLimit int, shutdown Shutdown) Runtime

func (Runtime) Cancel ¶

func (r Runtime) Cancel()

func (Runtime) Context ¶

func (r Runtime) Context() context.Context

func (Runtime) Go ¶

func (r Runtime) Go(ctx context.Context, fun func(ctx context.Context))

func (Runtime) Run ¶

func (r Runtime) Run(ctx context.Context, fun func(bool), callback func(error))

func (Runtime) SafeCtxFun ¶

func (r Runtime) SafeCtxFun(ctx context.Context, fun func(context.Context))

func (Runtime) SafeHook ¶

func (r Runtime) SafeHook(ctx context.Context, w http.ResponseWriter, req *http.Request, handler func(context.Context, http.ResponseWriter, *http.Request) bool) (bool, error)

func (Runtime) Submit ¶

func (r Runtime) Submit(ctx context.Context, fun func(bool), callback func(error))

type Shutdown ¶

type Shutdown interface {
	Shutdown()
}

type SimpleFrame ¶

type SimpleFrame interface {
	Run(ctx context.Context, r Runtime, fun func(bool))
	Submit(ctx context.Context, r Runtime, fun func(bool))
	AnyFrame
}

type Thread ¶

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

func (*Thread) Frame ¶

func (s *Thread) Frame() Frame

func (*Thread) Guard ¶

func (s *Thread) Guard() Guard

type ValveFrame ¶

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

func (*ValveFrame) Activate ¶

func (f *ValveFrame) Activate()

func (*ValveFrame) Run ¶

func (f *ValveFrame) Run(ctx context.Context, s Runtime, fun func(bool))

func (*ValveFrame) Submit ¶

func (f *ValveFrame) Submit(ctx context.Context, s Runtime, fun func(bool))

Source Files ¶

View all Source files

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