hatchery

package

v0.53.0 Latest Latest Go to latest Published: Sep 4, 2023 License: BSD-3-Clause Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

CDSClient returns cdsclient instance

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

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

CommonServe start the HatcheryLocal server

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

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

GetGoRoutines returns the goRoutines manager

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

func (c *Common) GetRegion() string

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 (c *Common) HeartbeatV2(ctx context.Context, status func(ctx context.Context) *sdk.MonitoringStatus) error

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

func (c *Common) MaxHeartbeat() int

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

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

func (c *Common) ServiceName() string

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

Path	Synopsis
kubernetes
local
openstack
swarm
vsphere
mock_vsphere Package mock_vsphere is a generated GoMock package.	Package mock_vsphere is a generated GoMock package.