hatchery

package
v0.54.1 Latest Latest
Warning

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

Go to latest
Published: Mar 29, 2024 License: BSD-3-Clause Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Common

type Common struct {
	service.Common
	Router   *api.Router
	Clientv2 cdsclient.HatcheryServiceClient
	// contains filtered or unexported fields
}

func (*Common) CDSClient

func (c *Common) CDSClient() cdsclient.Interface

CDSClient returns cdsclient instance

func (*Common) CDSClientV2 added in v0.53.0

func (c *Common) CDSClientV2() cdsclient.HatcheryServiceClient

func (*Common) CommonServe

func (c *Common) CommonServe(ctx context.Context, h hatchery.Interface) error

CommonServe start the HatcheryLocal server

func (*Common) GenerateWorkerConfig

func (c *Common) GenerateWorkerConfig(ctx context.Context, h hatchery.Interface, spawnArgs hatchery.SpawnArguments) workerruntime.WorkerConfig

func (*Common) GetGoRoutines

func (c *Common) GetGoRoutines() *sdk.GoRoutines

GetGoRoutines returns the goRoutines manager

func (*Common) GetMapPendingWorkerCreation added in v0.53.1

func (c *Common) GetMapPendingWorkerCreation() *sdk.HatcheryPendingWorkerCreation

func (*Common) GetPrivateKey

func (c *Common) GetPrivateKey() *rsa.PrivateKey

func (*Common) GetRegion added in v0.53.0

func (c *Common) GetRegion() string

func (*Common) Heartbeat added in v0.53.0

func (c *Common) Heartbeat(ctx context.Context, status func(ctx context.Context) *sdk.MonitoringStatus) error

Heartbeat have to be launch as a goroutine, call DoHeartBeat each 30s

func (*Common) HeartbeatV2 added in v0.53.0

func (c *Common) HeartbeatV2(ctx context.Context, status func(ctx context.Context) *sdk.MonitoringStatus) error

func (*Common) Init added in v0.52.0

func (c *Common) Init(ctx context.Context, h hatchery.Interface) error

func (*Common) MaxHeartbeat added in v0.53.0

func (c *Common) MaxHeartbeat() int

func (*Common) SendServiceLog

func (c *Common) SendServiceLog(ctx context.Context, servicesLogs []cdslog.Message, terminated bool)

func (*Common) Service

func (c *Common) Service() *sdk.Service

func (*Common) ServiceName

func (c *Common) ServiceName() string

func (*Common) SigninV2 added in v0.53.0

func (c *Common) SigninV2(ctx context.Context, clientConfig cdsclient.ServiceConfig, srvConfig interface{}) error

func (*Common) WorkerList added in v0.53.1

func (c *Common) WorkerList(ctx context.Context) ([]WorkerInterface, error)

type WorkerInterface added in v0.53.1

type WorkerInterface interface {
	Name() string
	Status() string
}

Directories

Path Synopsis
mock_vsphere
Package mock_vsphere is a generated GoMock package.
Package mock_vsphere is a generated GoMock package.

Jump to

Keyboard shortcuts

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