shredder

package
v0.8.2 Latest Latest
Warning

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

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

Documentation

Index

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, first AnyFrame, others ...AnyFrame) Frame

type FreeFrame 

type FreeFrame struct{}

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 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 (m *ValveFrame) Activate()

func (*ValveFrame) Run 

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

func (*ValveFrame) Submit 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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