extworker

package
v2.26.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Dec 8, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package extworker provides an external worker service and related utilities.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Loopback

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

Loopback implements fnpb.BeamFnExternalWorkerPoolServer

func StartLoopback

func StartLoopback(ctx context.Context, port int) (*Loopback, error)

StartLoopback initializes a Loopback ExternalWorkerService, at the given port.

func (*Loopback) EnvironmentConfig

func (s *Loopback) EnvironmentConfig(context.Context) string

EnvironmentConfig returns the environment config for this service instance.

func (*Loopback) StartWorker

StartWorker initializes a new worker harness, implementing BeamFnExternalWorkerPoolServer.StartWorker.

func (*Loopback) Stop

func (s *Loopback) Stop(ctx context.Context) error

Stop terminates the service and stops all workers.

func (*Loopback) StopWorker

StopWorker terminates a worker harness, implementing BeamFnExternalWorkerPoolServer.StopWorker.

Jump to

Keyboard shortcuts

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