runner

package

v0.6.0 Latest Latest Go to latest Published: Mar 27, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cloudfoundry/cf-app-sd-release

Links

Open Source Insights

Documentation ¶

Index ¶

func PartitionRange(start, end, partitionSize int) []int
type Runner
- func NewRunner(c publisher.ConnectionCreator, j publisher.Job, numGoRoutines int, ...) *Runner

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func PartitionRange ¶

func PartitionRange(start, end, partitionSize int) []int

Types ¶

type Runner ¶

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

func NewRunner ¶

func NewRunner(c publisher.ConnectionCreator, j publisher.Job, numGoRoutines int, heartbeatInterval time.Duration, publishDelay time.Duration) *Runner

func (*Runner) Start ¶

func (r *Runner) Start() error

func (*Runner) Stop ¶

func (r *Runner) Stop()

func (*Runner) Wait ¶

func (r *Runner) Wait() error

Source Files ¶

View all Source files

runner.go

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