hatchery

Documentation

Index

• type Common
  • func (c *Common) CDSClient() cdsclient.Interface
  • func (c *Common) CDSClientV2() cdsclient.HatcheryServiceClient
  • func (c *Common) CommonServe(ctx context.Context, h hatchery.Interface) error
  • func (c *Common) GenerateWorkerConfig(ctx context.Context, h hatchery.Interface, spawnArgs hatchery.SpawnArguments) workerruntime.WorkerConfig
  • func (c *Common) GetGoRoutines() *sdk.GoRoutines
  • func (c *Common) GetMapPendingWorkerCreation() *sdk.HatcheryPendingWorkerCreation
  • 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
  • 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, ...) error
  • func (c *Common) WorkerList(ctx context.Context) ([]WorkerInterface, error)
• type WorkerInterface

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

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

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

func (*Common) GetPrivateKey

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

func (*Common) GetRegion

func (c *Common) GetRegion() string

func (*Common) Heartbeat

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

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

func (*Common) Init

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

func (*Common) MaxHeartbeat

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

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

func (*Common) WorkerList

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

type WorkerInterface

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