extworker

Documentation

Overview

Package extworker provides an external worker service and related utilities.

Index

• type Loopback
  • func StartLoopback(ctx context.Context, port int) (*Loopback, error)
  • func (s *Loopback) EnvironmentConfig(context.Context) string
  • func (s *Loopback) StartWorker(ctx context.Context, req *fnpb.StartWorkerRequest) (*fnpb.StartWorkerResponse, error)
  • func (s *Loopback) Stop(ctx context.Context) error
  • func (s *Loopback) StopWorker(ctx context.Context, req *fnpb.StopWorkerRequest) (*fnpb.StopWorkerResponse, error)

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

func (s *Loopback) StartWorker(ctx context.Context, req *fnpb.StartWorkerRequest) (*fnpb.StartWorkerResponse, error)

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

func (s *Loopback) StopWorker(ctx context.Context, req *fnpb.StopWorkerRequest) (*fnpb.StopWorkerResponse, error)

StopWorker terminates a worker harness, implementing BeamFnExternalWorkerPoolServer.StopWorker.