worker

package

v1.0.1 Latest Latest Go to latest Published: Feb 6, 2025 License: Apache-2.0 Imports: 11 Imported by: 1

Details

This section is empty.

This section is empty.

func LoadWorkerDesc(metadata map[string]string) map[string]string

type Option func(o *options)

func WithLogger(logger log.Logger) Option

func WithReportResourceInterval(interval time.Duration) Option

func WithShutdownTimeout(timeout time.Duration) Option

func WithTriggerResync(interval time.Duration) Option

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

func NewWorker(
	id string,
	ip string,
	port int,
	discover discover.Interface,
	taskRepo taskrepo.Interface,
	opts ...Option,
) *Worker

func (w *Worker) Run(ctx context.Context) error