participantservicelogic

package
v0.1.19 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 5, 2024 License: MulanPSL-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApplyListLogic added in v0.1.14 

type ApplyListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewApplyListLogic added in v0.1.14 

func NewApplyListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ApplyListLogic

func (*ApplyListLogic) ApplyList added in v0.1.14 

func (l *ApplyListLogic) ApplyList(in *pcmCore.ApplyListReq) (*pcmCore.ApplyListResp, error)

applyList 执行任务列表

type DeleteListLogic added in v0.1.14 

type DeleteListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewDeleteListLogic added in v0.1.14 

func NewDeleteListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeleteListLogic

func (*DeleteListLogic) DeleteList added in v0.1.14 

func (l *DeleteListLogic) DeleteList(in *pcmCore.ApplyListReq) (*pcmCore.ApplyListResp, error)

DeleteList 删除任务列表

type ListParticipantLogic added in v0.1.8 

type ListParticipantLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewListParticipantLogic added in v0.1.8 

func NewListParticipantLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListParticipantLogic

func (*ListParticipantLogic) ListParticipant added in v0.1.8 

func (l *ListParticipantLogic) ListParticipant(in *pcmCore.ParticipantTenant) (*pcmCore.ParticipantServiceResp, error)

listParticipant 服务列表

type ListPhyAvailableLogic added in v0.1.8 

type ListPhyAvailableLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewListPhyAvailableLogic added in v0.1.8 

func NewListPhyAvailableLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListPhyAvailableLogic

func (*ListPhyAvailableLogic) ListPhyAvailable added in v0.1.8 

func (l *ListPhyAvailableLogic) ListPhyAvailable(in *pcmCore.ParticipantTenant) (*pcmCore.ListParticipantAvailResp, error)

listAvailable 集群动态信息列表

type ListPhyInformationLogic added in v0.1.8 

type ListPhyInformationLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewListPhyInformationLogic added in v0.1.8 

func NewListPhyInformationLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListPhyInformationLogic

func (*ListPhyInformationLogic) ListPhyInformation added in v0.1.8 

func (l *ListPhyInformationLogic) ListPhyInformation(in *pcmCore.ParticipantTenant) (*pcmCore.ListParticipantPhyResp, error)

listPhyInformation 集群静态信息列表

type ListTenantLogic added in v0.1.8 

type ListTenantLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewListTenantLogic added in v0.1.8 

func NewListTenantLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListTenantLogic

func (*ListTenantLogic) ListTenant added in v0.1.8 

func (l *ListTenantLogic) ListTenant(in *pcmCore.TenantInfo) (*pcmCore.ListTenantResp, error)

listTenant 租户列表信息

type PauseListLogic added in v0.1.18 

type PauseListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewPauseListLogic added in v0.1.18 

func NewPauseListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PauseListLogic

func (*PauseListLogic) PauseList added in v0.1.18 

func (l *PauseListLogic) PauseList(in *pcmCore.ApplyListReq) (*pcmCore.ApplyListResp, error)

PauseList 暂停任务列表

type RegisterParticipantLogic 

type RegisterParticipantLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewRegisterParticipantLogic 

func NewRegisterParticipantLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RegisterParticipantLogic

func (*RegisterParticipantLogic) RegisterParticipant 

func (l *RegisterParticipantLogic) RegisterParticipant(in *pcmCore.ParticipantPhyReq) (*pcmCore.ParticipantPhyResp, error)

RegisterParticipant Participant注册接口

type RegisterTenantLogic added in v0.1.8 

type RegisterTenantLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewRegisterTenantLogic added in v0.1.8 

func NewRegisterTenantLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RegisterTenantLogic

func (*RegisterTenantLogic) RegisterTenant added in v0.1.8 

func (l *RegisterTenantLogic) RegisterTenant(in *pcmCore.TenantInfo) (*pcmCore.TenantResp, error)

registerTenant 注册租户信息

type ReportAvailableLogic 

type ReportAvailableLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewReportAvailableLogic 

func NewReportAvailableLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ReportAvailableLogic

func (*ReportAvailableLogic) ReportAvailable 

func (l *ReportAvailableLogic) ReportAvailable(in *pcmCore.ParticipantAvailReq) (*pcmCore.ParticipantResp, error)

ReportAvailable 监控数据上报

type ReportHeartbeatLogic 

type ReportHeartbeatLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewReportHeartbeatLogic 

func NewReportHeartbeatLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ReportHeartbeatLogic

func (*ReportHeartbeatLogic) ReportHeartbeat 

func (l *ReportHeartbeatLogic) ReportHeartbeat(in *pcmCore.ParticipantHeartbeatReq) (*pcmCore.HealthCheckResp, error)

ReportHeartbeat 心跳请求

type RestartListLogic added in v0.1.15 

type RestartListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewRestartListLogic added in v0.1.15 

func NewRestartListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RestartListLogic

func (*RestartListLogic) RestartList added in v0.1.15 

func (l *RestartListLogic) RestartList(in *pcmCore.ApplyListReq) (*pcmCore.ApplyListResp, error)

RestartList 重启任务列表

type StartListLogic added in v0.1.18 

type StartListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewStartListLogic added in v0.1.18 

func NewStartListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *StartListLogic

func (*StartListLogic) StartList added in v0.1.18 

func (l *StartListLogic) StartList(in *pcmCore.ApplyListReq) (*pcmCore.ApplyListResp, error)

StartList 启动任务列表

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.