tworker

package

v0.2.2 Latest Latest Go to latest Published: Sep 14, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Binding struct {
	Interval       time.Duration
	RestartOnError bool
}

Binding defines a background worker schedule.

func Every(d time.Duration) Binding

Every binds an action to run as a background worker continuously.

func (b Binding) String() string

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

func New() *Transport

func (t *Transport) AsAction() action.AnyAction

func (t *Transport) CanHandle(b action.Binding) bool

func (t *Transport) Do(ctx context.Context, _ any) (any, error)

func (t *Transport) Mount(actions []action.AnyAction)

func (t *Transport) String() string