edas

Documentation

Index

• type EDAS
  • func (e *EDAS) Cancel(ctx context.Context, specObj interface{}) (interface{}, error)
  • func (e *EDAS) CapacityInfo() apistructs.CapacityInfoData
  • func (e *EDAS) CleanUpBeforeDelete()
  • func (e *EDAS) Create(ctx context.Context, specObj interface{}) (interface{}, error)
  • func (e *EDAS) Destroy(ctx context.Context, specObj interface{}) error
  • func (e *EDAS) Inspect(ctx context.Context, specObj interface{}) (interface{}, error)
  • func (e *EDAS) JobVolumeCreate(ctx context.Context, spec interface{}) (string, error)
  • func (e *EDAS) KillPod(podname string) error
  • func (e *EDAS) Kind() executortypes.Kind
  • func (e *EDAS) Name() executortypes.Name
  • func (e *EDAS) Precheck(ctx context.Context, specObj interface{}) (apistructs.ServiceGroupPrecheckData, error)
  • func (e *EDAS) Remove(ctx context.Context, specObj interface{}) error
  • func (e *EDAS) ResourceInfo(brief bool) (apistructs.ClusterResourceInfoData, error)
  • func (e *EDAS) Scale(ctx context.Context, specObj interface{}) (interface{}, error)
  • func (e *EDAS) SetNodeLabels(setting executortypes.NodeLabelSetting, hosts []string, ...) error
  • func (e *EDAS) Status(ctx context.Context, specObj interface{}) (apistructs.StatusDesc, error)
  • func (e *EDAS) Update(ctx context.Context, specObj interface{}) (interface{}, error)
  • func (e *EDAS) WaitEvent(lstore *sync.Map, stopCh chan struct{})

Types

type EDAS

type EDAS struct {
	// contains filtered or unexported fields
}

EDAS edas server structure

func (*EDAS) Cancel

func (e *EDAS) Cancel(ctx context.Context, specObj interface{}) (interface{}, error)

func (*EDAS) CapacityInfo

func (e *EDAS) CapacityInfo() apistructs.CapacityInfoData

func (*EDAS) CleanUpBeforeDelete

func (e *EDAS) CleanUpBeforeDelete()

func (*EDAS) Create

func (e *EDAS) Create(ctx context.Context, specObj interface{}) (interface{}, error)

Create edas create runtime

func (*EDAS) Destroy

func (e *EDAS) Destroy(ctx context.Context, specObj interface{}) error

Destroy edas destory runtime

func (*EDAS) Inspect

func (e *EDAS) Inspect(ctx context.Context, specObj interface{}) (interface{}, error)

Inspect Query runtime information

func (*EDAS) JobVolumeCreate

func (e *EDAS) JobVolumeCreate(ctx context.Context, spec interface{}) (string, error)

func (*EDAS) KillPod

func (e *EDAS) KillPod(podname string) error

func (*EDAS) Kind

func (e *EDAS) Kind() executortypes.Kind

Kind executor kind

func (*EDAS) Name

func (e *EDAS) Name() executortypes.Name

Name executor name

func (*EDAS) Precheck

func (e *EDAS) Precheck(ctx context.Context, specObj interface{}) (apistructs.ServiceGroupPrecheckData, error)

func (*EDAS) Remove

func (e *EDAS) Remove(ctx context.Context, specObj interface{}) error

Remove edas remove runtime Because it takes a long time for edas to delete the interface, which exceeds the timeout set by the console, the app is deleted in parallel

func (*EDAS) ResourceInfo

func (e *EDAS) ResourceInfo(brief bool) (apistructs.ClusterResourceInfoData, error)

func (*EDAS) Scale

func (e *EDAS) Scale(ctx context.Context, specObj interface{}) (interface{}, error)

func (*EDAS) SetNodeLabels

func (e *EDAS) SetNodeLabels(setting executortypes.NodeLabelSetting, hosts []string, labels map[string]string) error

func (*EDAS) Status

func (e *EDAS) Status(ctx context.Context, specObj interface{}) (apistructs.StatusDesc, error)

Status edas status of runtime

func (*EDAS) Update

func (e *EDAS) Update(ctx context.Context, specObj interface{}) (interface{}, error)

Update edas update runtime

func (*EDAS) WaitEvent

func (e *EDAS) WaitEvent(lstore *sync.Map, stopCh chan struct{})

Currently edas does not use an event-driven mechanism, so it uses polling to simulate each time