hatchery

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) ([]sdk.PoolWorker, error)