client

package
v0.2202.6 Latest Latest
Warning

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

Go to latest
Published: Feb 7, 2023 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package client contains the runtime client worker.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewStatelessStorage

func NewStatelessStorage(p2p rpc.P2P, runtimeID common.Namespace) storage.Backend

NewStatelessStorage creates a stateless storage backend that uses the P2P transport and the storagepub protocol to query storage state.

Types

type Worker

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

Worker is a runtime client worker handling many runtimes.

func New

func New(grpcInternal *grpc.Server, commonWorker *workerCommon.Worker) (*Worker, error)

New creates a new runtime client worker.

func (*Worker) Cleanup

func (w *Worker) Cleanup()

Cleanup performs the service specific post-termination cleanup.

func (*Worker) Enabled

func (w *Worker) Enabled() bool

Enabled returns if worker is enabled.

func (*Worker) Initialized

func (w *Worker) Initialized() <-chan struct{}

Initialized returns a channel that will be closed when the client worker is initialized and ready to service requests.

func (*Worker) Name

func (w *Worker) Name() string

Name returns the service name.

func (*Worker) Quit

func (w *Worker) Quit() <-chan struct{}

Quit returns a channel that will be closed when the service terminates.

func (*Worker) Start

func (w *Worker) Start() error

Start starts the service.

func (*Worker) Stop

func (w *Worker) Stop()

Stop halts the service.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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