runner

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Mar 17, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

* SPDX-FileCopyrightText: Copyright (c) 2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved. * SPDX-License-Identifier: Apache-2.0 * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Runner

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

A Runner specifies a long running goroutine which waits for certain condition to trigger a task.

func New

func New(tag string, initializer initFunc, waiter waiterFunc, runner runnerFunc) *Runner

New initializes and starts a new runner.

func (*Runner) SetStopping

func (r *Runner) SetStopping()

SetStopping sets the state of the runner to stopping, allowing it to be stopped, and goroutine be terminated once the current run has ended

func (*Runner) State

func (r *Runner) State() int

State returns the state of a runner in enum

func (*Runner) Status

func (r *Runner) Status() string

Status returns a runner's status

func (*Runner) Stop

func (r *Runner) Stop()

Stop stops a runner

Jump to

Keyboard shortcuts

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