task

package
v0.0.0-...-c4f7e29 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DependencySet = wire.NewSet(
	NewInProcessExecutorLogger,
	NewExecutor,

	wire.Bind(new(Executor), new(*InProcessExecutor)),
	wire.Struct(new(InProcessQueue), "*"),
)

Functions

This section is empty.

Types

type Executor 

type Executor interface {
	Run(ctx context.Context, param task.Param)
}

type InProcessExecutor 

type InProcessExecutor struct {
	Logger InProcessExecutorLogger
	// contains filtered or unexported fields
}

func NewExecutor 

func NewExecutor(
	logger InProcessExecutorLogger,
	sendMessageTask *tasks.SendMessagesTask,
) *InProcessExecutor

func (*InProcessExecutor) Register 

func (e *InProcessExecutor) Register(name string, t task.Task)

func (*InProcessExecutor) Run 

func (e *InProcessExecutor) Run(ctx context.Context, param task.Param)

type InProcessExecutorLogger 

type InProcessExecutorLogger struct{ *log.Logger }

func NewInProcessExecutorLogger 

func NewInProcessExecutorLogger(lf *log.Factory) InProcessExecutorLogger

type InProcessQueue 

type InProcessQueue struct {
	Executor Executor
}

func (*InProcessQueue) Enqueue 

func (q *InProcessQueue) Enqueue(param task.Param)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.