nodes

Documentation

Index

• type Nodes
  • func New(db *dbclient.DBClient, bdl *bundle.Bundle, ...) *Nodes
  • func (n *Nodes) AddCSNodes(ctx context.Context, req apistructs.CloudNodesRequest, userid string) (uint64, error)
  • func (n *Nodes) AddCloudNodes(ctx context.Context, req apistructs.CloudNodesRequest, userid string) (uint64, error)
  • func (n *Nodes) AddNodes(req apistructs.AddNodesRequest, userid string) (uint64, error)
  • func (n *Nodes) DeleteEssNodes(req apistructs.DeleteNodesRequest, userid string, orgid string) (uint64, error)
  • func (n *Nodes) DeleteEssNodesCron(req apistructs.DeleteNodesCronRequest, userid string, orgid string) (*uint64, error)
  • func (n *Nodes) Logs(orgName string, req apistructs.OpLogsRequest) (*apistructs.DashboardSpotLogData, error)
  • func (n *Nodes) Merge(rs []dbclient.Record) ([]RecordWithPipeline, error)
  • func (n *Nodes) Query(req apistructs.RecordRequest) (*apistructs.RecordsResponseData, error)
  • func (n *Nodes) RmNodes(req apistructs.RmNodesRequest, userid string, orgid string) (uint64, error)
  • func (n *Nodes) Sync(rs []dbclient.Record) ([]dbclient.Record, error)
  • func (n *Nodes) UpdateCronJobRecord(req apistructs.RecordUpdateRequest) error
• type RecordWithPipeline

Types

type Nodes

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

func New

func New(db *dbclient.DBClient, bdl *bundle.Bundle, clusterSvc clusterpb.ClusterServiceServer, pipelineSvc pipelinepb.PipelineServiceServer) *Nodes

func (*Nodes) AddCSNodes

func (n *Nodes) AddCSNodes(ctx context.Context, req apistructs.CloudNodesRequest, userid string) (uint64, error)

func (*Nodes) AddCloudNodes

func (n *Nodes) AddCloudNodes(ctx context.Context, req apistructs.CloudNodesRequest, userid string) (uint64, error)

func (*Nodes) AddNodes

func (n *Nodes) AddNodes(req apistructs.AddNodesRequest, userid string) (uint64, error)

func (*Nodes) DeleteEssNodes

func (n *Nodes) DeleteEssNodes(req apistructs.DeleteNodesRequest, userid string, orgid string) (uint64, error)

ess remove nodes & delete nodes in cloud resource

func (*Nodes) DeleteEssNodesCron

func (n *Nodes) DeleteEssNodesCron(req apistructs.DeleteNodesCronRequest, userid string, orgid string) (*uint64, error)

ess remove nodes & delete nodes in cron mode

func (*Nodes) Logs

func (n *Nodes) Logs(orgName string, req apistructs.OpLogsRequest) (*apistructs.DashboardSpotLogData, error)

func (*Nodes) Merge

func (n *Nodes) Merge(rs []dbclient.Record) ([]RecordWithPipeline, error)

func (*Nodes) Query

func (n *Nodes) Query(req apistructs.RecordRequest) (*apistructs.RecordsResponseData, error)

func (*Nodes) RmNodes

func (n *Nodes) RmNodes(req apistructs.RmNodesRequest, userid string, orgid string) (uint64, error)

func (*Nodes) Sync

func (n *Nodes) Sync(rs []dbclient.Record) ([]dbclient.Record, error)

func (*Nodes) UpdateCronJobRecord

func (n *Nodes) UpdateCronJobRecord(req apistructs.RecordUpdateRequest) error

type RecordWithPipeline

type RecordWithPipeline struct {
	dbclient.Record
	PipelineDetailDTO *pipelinepb.PipelineDetailDTO
}