client

Documentation

Overview

Package client contains the runtime client worker.

Index

• func NewStatelessStorage(p2p rpc.P2P, runtimeID common.Namespace) storage.Backend
• type Worker
  • func New(grpcInternal *grpc.Server, commonWorker *workerCommon.Worker) (*Worker, error)
  • func (w *Worker) Cleanup()
  • func (w *Worker) Enabled() bool
  • func (w *Worker) Initialized() <-chan struct{}
  • func (w *Worker) Name() string
  • func (w *Worker) Quit() <-chan struct{}
  • func (w *Worker) Start() error
  • func (w *Worker) Stop()

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.