task

package
v0.0.0-...-f3e39e2 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_task_proto protoreflect.FileDescriptor
View Source 
var NewTaskCallbackClientProxy = func(opts ...client.Option) TaskCallbackClientProxy {
	return &TaskCallbackClientProxyImpl{client: client.DefaultClient, opts: opts}
}
View Source 
var NewTaskClientProxy = func(opts ...client.Option) TaskClientProxy {
	return &TaskClientProxyImpl{client: client.DefaultClient, opts: opts}
}
View Source 
var TaskCallbackServer_ServiceDesc = server.ServiceDesc{
	ServiceName: "trpc.media.task.TaskCallback",
	HandlerType: ((*TaskCallbackService)(nil)),
	Methods: []server.Method{
		{
			Name: "/FinishedTask",
			Func: TaskCallbackService_FinishedTask_Handler,
		},
		{
			Name: "/trpc.media.task.TaskCallback/FinishedTask",
			Func: TaskCallbackService_FinishedTask_Handler,
		},
	},
}

TaskCallbackServer_ServiceDesc descriptor for server.RegisterService.

View Source 
var TaskServer_ServiceDesc = server.ServiceDesc{
	ServiceName: "trpc.media.task.Task",
	HandlerType: ((*TaskService)(nil)),
	Methods: []server.Method{
		{
			Name: "/DescribeSupportedMediaTypes",
			Func: TaskService_DescribeSupportedMediaTypes_Handler,
		},
		{
			Name: "/CreateTask",
			Func: TaskService_CreateTask_Handler,
		},
		{
			Name: "/DescribeTask",
			Func: TaskService_DescribeTask_Handler,
		},
		{
			Name: "/DescribeTasks",
			Func: TaskService_DescribeTasks_Handler,
		},
		{
			Name: "/StartTask",
			Func: TaskService_StartTask_Handler,
		},
		{
			Name: "/StartTasks",
			Func: TaskService_StartTasks_Handler,
		},
		{
			Name: "/StopTask",
			Func: TaskService_StopTask_Handler,
		},
		{
			Name: "/StopTasks",
			Func: TaskService_StopTasks_Handler,
		},
		{
			Name: "/DeleteTask",
			Func: TaskService_DeleteTask_Handler,
		},
		{
			Name: "/TopTask",
			Func: TaskService_TopTask_Handler,
		},
		{
			Name: "/DescribeTaskDetail",
			Func: TaskService_DescribeTaskDetail_Handler,
		},
		{
			Name: "/ModifyTaskData",
			Func: TaskService_ModifyTaskData_Handler,
		},
		{
			Name: "/DescribeTaskListFile",
			Func: TaskService_DescribeTaskListFile_Handler,
		},
		{
			Name: "/DescribeStatistics",
			Func: TaskService_DescribeStatistics_Handler,
		},
		{
			Name: "/DescribeWorkflowProgress",
			Func: TaskService_DescribeWorkflowProgress_Handler,
		},
		{
			Name: "/StopTasksInner",
			Func: TaskService_StopTasksInner_Handler,
		},
		{
			Name: "/CheckWorkflowTemplate",
			Func: TaskService_CheckWorkflowTemplate_Handler,
		},
		{
			Name: "/DescribeTagAnalyseInput",
			Func: TaskService_DescribeTagAnalyseInput_Handler,
		},
		{
			Name: "/trpc.media.task.Task/DescribeSupportedMediaTypes",
			Func: TaskService_DescribeSupportedMediaTypes_Handler,
		},
		{
			Name: "/trpc.media.task.Task/CreateTask",
			Func: TaskService_CreateTask_Handler,
		},
		{
			Name: "/trpc.media.task.Task/DescribeTask",
			Func: TaskService_DescribeTask_Handler,
		},
		{
			Name: "/trpc.media.task.Task/DescribeTasks",
			Func: TaskService_DescribeTasks_Handler,
		},
		{
			Name: "/trpc.media.task.Task/StartTask",
			Func: TaskService_StartTask_Handler,
		},
		{
			Name: "/trpc.media.task.Task/StartTasks",
			Func: TaskService_StartTasks_Handler,
		},
		{
			Name: "/trpc.media.task.Task/StopTask",
			Func: TaskService_StopTask_Handler,
		},
		{
			Name: "/trpc.media.task.Task/StopTasks",
			Func: TaskService_StopTasks_Handler,
		},
		{
			Name: "/trpc.media.task.Task/DeleteTask",
			Func: TaskService_DeleteTask_Handler,
		},
		{
			Name: "/trpc.media.task.Task/TopTask",
			Func: TaskService_TopTask_Handler,
		},
		{
			Name: "/trpc.media.task.Task/DescribeTaskDetail",
			Func: TaskService_DescribeTaskDetail_Handler,
		},
		{
			Name: "/trpc.media.task.Task/ModifyTaskData",
			Func: TaskService_ModifyTaskData_Handler,
		},
		{
			Name: "/trpc.media.task.Task/DescribeTaskListFile",
			Func: TaskService_DescribeTaskListFile_Handler,
		},
		{
			Name: "/trpc.media.task.Task/DescribeStatistics",
			Func: TaskService_DescribeStatistics_Handler,
		},
		{
			Name: "/trpc.media.task.Task/DescribeWorkflowProgress",
			Func: TaskService_DescribeWorkflowProgress_Handler,
		},
		{
			Name: "/trpc.media.task.Task/StopTasksInner",
			Func: TaskService_StopTasksInner_Handler,
		},
		{
			Name: "/trpc.media.task.Task/CheckWorkflowTemplate",
			Func: TaskService_CheckWorkflowTemplate_Handler,
		},
		{
			Name: "/trpc.media.task.Task/DescribeTagAnalyseInput",
			Func: TaskService_DescribeTagAnalyseInput_Handler,
		},
	},
}

TaskServer_ServiceDesc descriptor for server.RegisterService.

Functions

func RegisterTaskCallbackService 

func RegisterTaskCallbackService(s server.Service, svr TaskCallbackService)

RegisterTaskCallbackService registers service.

func RegisterTaskService 

func RegisterTaskService(s server.Service, svr TaskService)

RegisterTaskService registers service.

func TaskCallbackService_FinishedTask_Handler 

func TaskCallbackService_FinishedTask_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_CheckWorkflowTemplate_Handler 

func TaskService_CheckWorkflowTemplate_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_CreateTask_Handler 

func TaskService_CreateTask_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_DeleteTask_Handler 

func TaskService_DeleteTask_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_DescribeStatistics_Handler 

func TaskService_DescribeStatistics_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_DescribeSupportedMediaTypes_Handler 

func TaskService_DescribeSupportedMediaTypes_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_DescribeTagAnalyseInput_Handler 

func TaskService_DescribeTagAnalyseInput_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_DescribeTaskDetail_Handler 

func TaskService_DescribeTaskDetail_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_DescribeTaskListFile_Handler 

func TaskService_DescribeTaskListFile_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_DescribeTask_Handler 

func TaskService_DescribeTask_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_DescribeTasks_Handler 

func TaskService_DescribeTasks_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_DescribeWorkflowProgress_Handler 

func TaskService_DescribeWorkflowProgress_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_ModifyTaskData_Handler 

func TaskService_ModifyTaskData_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_StartTask_Handler 

func TaskService_StartTask_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_StartTasks_Handler 

func TaskService_StartTasks_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_StopTask_Handler 

func TaskService_StopTask_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_StopTasksInner_Handler 

func TaskService_StopTasksInner_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_StopTasks_Handler 

func TaskService_StopTasks_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func TaskService_TopTask_Handler 

func TaskService_TopTask_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

Types

type CheckWorkflowTemplateRequest 

type CheckWorkflowTemplateRequest struct {
	WorkflowTemplate *apicommon.WorkflowTemplate `protobuf:"bytes,1,opt,name=WorkflowTemplate,proto3" json:"WorkflowTemplate,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckWorkflowTemplateRequest) Descriptor deprecated 

func (*CheckWorkflowTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckWorkflowTemplateRequest.ProtoReflect.Descriptor instead.

func (*CheckWorkflowTemplateRequest) GetWorkflowTemplate 

func (x *CheckWorkflowTemplateRequest) GetWorkflowTemplate() *apicommon.WorkflowTemplate

func (*CheckWorkflowTemplateRequest) ProtoMessage 

func (*CheckWorkflowTemplateRequest) ProtoMessage()

func (*CheckWorkflowTemplateRequest) ProtoReflect 

func (x *CheckWorkflowTemplateRequest) ProtoReflect() protoreflect.Message

func (*CheckWorkflowTemplateRequest) Reset 

func (x *CheckWorkflowTemplateRequest) Reset()

func (*CheckWorkflowTemplateRequest) String 

func (x *CheckWorkflowTemplateRequest) String() string

type CheckWorkflowTemplateResponse 

type CheckWorkflowTemplateResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=Ok,proto3" json:"Ok,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=Reason,proto3" json:"Reason,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckWorkflowTemplateResponse) Descriptor deprecated 

func (*CheckWorkflowTemplateResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckWorkflowTemplateResponse.ProtoReflect.Descriptor instead.

func (*CheckWorkflowTemplateResponse) GetOk 

func (x *CheckWorkflowTemplateResponse) GetOk() bool

func (*CheckWorkflowTemplateResponse) GetReason 

func (x *CheckWorkflowTemplateResponse) GetReason() string

func (*CheckWorkflowTemplateResponse) ProtoMessage 

func (*CheckWorkflowTemplateResponse) ProtoMessage()

func (*CheckWorkflowTemplateResponse) ProtoReflect 

func (x *CheckWorkflowTemplateResponse) ProtoReflect() protoreflect.Message

func (*CheckWorkflowTemplateResponse) Reset 

func (x *CheckWorkflowTemplateResponse) Reset()

func (*CheckWorkflowTemplateResponse) String 

func (x *CheckWorkflowTemplateResponse) String() string

type CreateTaskRequest 

type CreateTaskRequest struct {
	MediaId            string           `protobuf:"bytes,1,opt,name=MediaId,proto3" json:"MediaId,omitempty"`
	TaskName           string           `protobuf:"bytes,2,opt,name=TaskName,proto3" json:"TaskName,omitempty"`
	CallbackURL        string           `protobuf:"bytes,3,opt,name=CallbackURL,proto3" json:"CallbackURL,omitempty"`
	RunImmediately     bool             `protobuf:"varint,4,opt,name=RunImmediately,proto3" json:"RunImmediately,omitempty"`
	Parameter          *structpb.Struct `protobuf:"bytes,5,opt,name=Parameter,proto3" json:"Parameter,omitempty"` // 可以接受任何 json 对应参数
	WorkflowTemplateId string           `protobuf:"bytes,6,opt,name=WorkflowTemplateId,proto3" json:"WorkflowTemplateId,omitempty"`
	ParentTaskId       string           `protobuf:"bytes,7,opt,name=ParentTaskId,proto3" json:"ParentTaskId,omitempty"`
	EffectiveTime      uint32           `protobuf:"varint,8,opt,name=EffectiveTime,proto3" json:"EffectiveTime,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskRequest) Descriptor deprecated 

func (*CreateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskRequest) GetCallbackURL 

func (x *CreateTaskRequest) GetCallbackURL() string

func (*CreateTaskRequest) GetEffectiveTime 

func (x *CreateTaskRequest) GetEffectiveTime() uint32

func (*CreateTaskRequest) GetMediaId 

func (x *CreateTaskRequest) GetMediaId() string

func (*CreateTaskRequest) GetParameter 

func (x *CreateTaskRequest) GetParameter() *structpb.Struct

func (*CreateTaskRequest) GetParentTaskId 

func (x *CreateTaskRequest) GetParentTaskId() string

func (*CreateTaskRequest) GetRunImmediately 

func (x *CreateTaskRequest) GetRunImmediately() bool

func (*CreateTaskRequest) GetTaskName 

func (x *CreateTaskRequest) GetTaskName() string

func (*CreateTaskRequest) GetWorkflowTemplateId 

func (x *CreateTaskRequest) GetWorkflowTemplateId() string

func (*CreateTaskRequest) ProtoMessage 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) ProtoReflect 

func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message

func (*CreateTaskRequest) Reset 

func (x *CreateTaskRequest) Reset()

func (*CreateTaskRequest) String 

func (x *CreateTaskRequest) String() string

type CreateTaskResponse 

type CreateTaskResponse struct {
	TaskId string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskResponse) Descriptor deprecated 

func (*CreateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateTaskResponse.ProtoReflect.Descriptor instead.

func (*CreateTaskResponse) GetTaskId 

func (x *CreateTaskResponse) GetTaskId() string

func (*CreateTaskResponse) ProtoMessage 

func (*CreateTaskResponse) ProtoMessage()

func (*CreateTaskResponse) ProtoReflect 

func (x *CreateTaskResponse) ProtoReflect() protoreflect.Message

func (*CreateTaskResponse) Reset 

func (x *CreateTaskResponse) Reset()

func (*CreateTaskResponse) String 

func (x *CreateTaskResponse) String() string

type DeleteTaskRequest 

type DeleteTaskRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTaskRequest) Descriptor deprecated 

func (*DeleteTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetTaskId 

func (x *DeleteTaskRequest) GetTaskId() string

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect 

func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteTaskRequest) Reset 

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String 

func (x *DeleteTaskRequest) String() string

type DeleteTaskResponse 

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

func (*DeleteTaskResponse) Descriptor deprecated 

func (*DeleteTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteTaskResponse) ProtoMessage 

func (*DeleteTaskResponse) ProtoMessage()

func (*DeleteTaskResponse) ProtoReflect 

func (x *DeleteTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteTaskResponse) Reset 

func (x *DeleteTaskResponse) Reset()

func (*DeleteTaskResponse) String 

func (x *DeleteTaskResponse) String() string

type DescribeStatisticsRequest 

type DescribeStatisticsRequest struct {
	ApiModuleSet []string                `protobuf:"bytes,5,rep,name=ApiModuleSet,proto3" json:"ApiModuleSet,omitempty"`
	TimeInterval *apicommon.TimeInterval `protobuf:"bytes,6,opt,name=TimeInterval,proto3" json:"TimeInterval,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeStatisticsRequest) Descriptor deprecated 

func (*DescribeStatisticsRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeStatisticsRequest.ProtoReflect.Descriptor instead.

func (*DescribeStatisticsRequest) GetApiModuleSet 

func (x *DescribeStatisticsRequest) GetApiModuleSet() []string

func (*DescribeStatisticsRequest) GetTimeInterval 

func (x *DescribeStatisticsRequest) GetTimeInterval() *apicommon.TimeInterval

func (*DescribeStatisticsRequest) ProtoMessage 

func (*DescribeStatisticsRequest) ProtoMessage()

func (*DescribeStatisticsRequest) ProtoReflect 

func (x *DescribeStatisticsRequest) ProtoReflect() protoreflect.Message

func (*DescribeStatisticsRequest) Reset 

func (x *DescribeStatisticsRequest) Reset()

func (*DescribeStatisticsRequest) String 

func (x *DescribeStatisticsRequest) String() string

type DescribeStatisticsResponse 

type DescribeStatisticsResponse struct {
	StatisticsData *StatisticsData `protobuf:"bytes,3,opt,name=StatisticsData,proto3" json:"StatisticsData,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeStatisticsResponse) Descriptor deprecated 

func (*DescribeStatisticsResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeStatisticsResponse.ProtoReflect.Descriptor instead.

func (*DescribeStatisticsResponse) GetStatisticsData 

func (x *DescribeStatisticsResponse) GetStatisticsData() *StatisticsData

func (*DescribeStatisticsResponse) ProtoMessage 

func (*DescribeStatisticsResponse) ProtoMessage()

func (*DescribeStatisticsResponse) ProtoReflect 

func (x *DescribeStatisticsResponse) ProtoReflect() protoreflect.Message

func (*DescribeStatisticsResponse) Reset 

func (x *DescribeStatisticsResponse) Reset()

func (*DescribeStatisticsResponse) String 

func (x *DescribeStatisticsResponse) String() string

type DescribeSupportedMediaTypesRequest 

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

func (*DescribeSupportedMediaTypesRequest) Descriptor deprecated 

func (*DescribeSupportedMediaTypesRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeSupportedMediaTypesRequest.ProtoReflect.Descriptor instead.

func (*DescribeSupportedMediaTypesRequest) ProtoMessage 

func (*DescribeSupportedMediaTypesRequest) ProtoMessage()

func (*DescribeSupportedMediaTypesRequest) ProtoReflect 

func (x *DescribeSupportedMediaTypesRequest) ProtoReflect() protoreflect.Message

func (*DescribeSupportedMediaTypesRequest) Reset 

func (x *DescribeSupportedMediaTypesRequest) Reset()

func (*DescribeSupportedMediaTypesRequest) String 

func (x *DescribeSupportedMediaTypesRequest) String() string

type DescribeSupportedMediaTypesResponse 

type DescribeSupportedMediaTypesResponse struct {
	MediaTypeSet []apicommon.MediaType `protobuf:"varint,1,rep,packed,name=MediaTypeSet,proto3,enum=trpc.media.common.MediaType" json:"MediaTypeSet,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeSupportedMediaTypesResponse) Descriptor deprecated 

func (*DescribeSupportedMediaTypesResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeSupportedMediaTypesResponse.ProtoReflect.Descriptor instead.

func (*DescribeSupportedMediaTypesResponse) GetMediaTypeSet 

func (x *DescribeSupportedMediaTypesResponse) GetMediaTypeSet() []apicommon.MediaType

func (*DescribeSupportedMediaTypesResponse) ProtoMessage 

func (*DescribeSupportedMediaTypesResponse) ProtoMessage()

func (*DescribeSupportedMediaTypesResponse) ProtoReflect 

func (x *DescribeSupportedMediaTypesResponse) ProtoReflect() protoreflect.Message

func (*DescribeSupportedMediaTypesResponse) Reset 

func (x *DescribeSupportedMediaTypesResponse) Reset()

func (*DescribeSupportedMediaTypesResponse) String 

func (x *DescribeSupportedMediaTypesResponse) String() string

type DescribeTagAnalyseInputRequest 

type DescribeTagAnalyseInputRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTagAnalyseInputRequest) Descriptor deprecated 

func (*DescribeTagAnalyseInputRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTagAnalyseInputRequest.ProtoReflect.Descriptor instead.

func (*DescribeTagAnalyseInputRequest) GetTaskId 

func (x *DescribeTagAnalyseInputRequest) GetTaskId() string

func (*DescribeTagAnalyseInputRequest) ProtoMessage 

func (*DescribeTagAnalyseInputRequest) ProtoMessage()

func (*DescribeTagAnalyseInputRequest) ProtoReflect 

func (x *DescribeTagAnalyseInputRequest) ProtoReflect() protoreflect.Message

func (*DescribeTagAnalyseInputRequest) Reset 

func (x *DescribeTagAnalyseInputRequest) Reset()

func (*DescribeTagAnalyseInputRequest) String 

func (x *DescribeTagAnalyseInputRequest) String() string

type DescribeTagAnalyseInputResponse 

type DescribeTagAnalyseInputResponse struct {
	SnippetDataSet []*SnippetData `protobuf:"bytes,3,rep,name=SnippetDataSet,proto3" json:"SnippetDataSet,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTagAnalyseInputResponse) Descriptor deprecated 

func (*DescribeTagAnalyseInputResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTagAnalyseInputResponse.ProtoReflect.Descriptor instead.

func (*DescribeTagAnalyseInputResponse) GetSnippetDataSet 

func (x *DescribeTagAnalyseInputResponse) GetSnippetDataSet() []*SnippetData

func (*DescribeTagAnalyseInputResponse) ProtoMessage 

func (*DescribeTagAnalyseInputResponse) ProtoMessage()

func (*DescribeTagAnalyseInputResponse) ProtoReflect 

func (x *DescribeTagAnalyseInputResponse) ProtoReflect() protoreflect.Message

func (*DescribeTagAnalyseInputResponse) Reset 

func (x *DescribeTagAnalyseInputResponse) Reset()

func (*DescribeTagAnalyseInputResponse) String 

func (x *DescribeTagAnalyseInputResponse) String() string

type DescribeTaskDetailRequest 

type DescribeTaskDetailRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskDetailRequest) Descriptor deprecated 

func (*DescribeTaskDetailRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTaskDetailRequest.ProtoReflect.Descriptor instead.

func (*DescribeTaskDetailRequest) GetTaskId 

func (x *DescribeTaskDetailRequest) GetTaskId() string

func (*DescribeTaskDetailRequest) ProtoMessage 

func (*DescribeTaskDetailRequest) ProtoMessage()

func (*DescribeTaskDetailRequest) ProtoReflect 

func (x *DescribeTaskDetailRequest) ProtoReflect() protoreflect.Message

func (*DescribeTaskDetailRequest) Reset 

func (x *DescribeTaskDetailRequest) Reset()

func (*DescribeTaskDetailRequest) String 

func (x *DescribeTaskDetailRequest) String() string

type DescribeTaskDetailResponse 

type DescribeTaskDetailResponse struct {
	TaskInfo *apicommon.TaskInfo   `protobuf:"bytes,1,opt,name=TaskInfo,proto3" json:"TaskInfo,omitempty"`
	TaskData *taskdata.AllTaskData `protobuf:"bytes,2,opt,name=TaskData,proto3" json:"TaskData,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskDetailResponse) Descriptor deprecated 

func (*DescribeTaskDetailResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTaskDetailResponse.ProtoReflect.Descriptor instead.

func (*DescribeTaskDetailResponse) GetTaskData 

func (x *DescribeTaskDetailResponse) GetTaskData() *taskdata.AllTaskData

func (*DescribeTaskDetailResponse) GetTaskInfo 

func (x *DescribeTaskDetailResponse) GetTaskInfo() *apicommon.TaskInfo

func (*DescribeTaskDetailResponse) ProtoMessage 

func (*DescribeTaskDetailResponse) ProtoMessage()

func (*DescribeTaskDetailResponse) ProtoReflect 

func (x *DescribeTaskDetailResponse) ProtoReflect() protoreflect.Message

func (*DescribeTaskDetailResponse) Reset 

func (x *DescribeTaskDetailResponse) Reset()

func (*DescribeTaskDetailResponse) String 

func (x *DescribeTaskDetailResponse) String() string

type DescribeTaskListFileRequest 

type DescribeTaskListFileRequest struct {
	ApiModuleSet []string                `protobuf:"bytes,5,rep,name=ApiModuleSet,proto3" json:"ApiModuleSet,omitempty"`
	TimeInterval *apicommon.TimeInterval `protobuf:"bytes,6,opt,name=TimeInterval,proto3" json:"TimeInterval,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskListFileRequest) Descriptor deprecated 

func (*DescribeTaskListFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTaskListFileRequest.ProtoReflect.Descriptor instead.

func (*DescribeTaskListFileRequest) GetApiModuleSet 

func (x *DescribeTaskListFileRequest) GetApiModuleSet() []string

func (*DescribeTaskListFileRequest) GetTimeInterval 

func (x *DescribeTaskListFileRequest) GetTimeInterval() *apicommon.TimeInterval

func (*DescribeTaskListFileRequest) ProtoMessage 

func (*DescribeTaskListFileRequest) ProtoMessage()

func (*DescribeTaskListFileRequest) ProtoReflect 

func (x *DescribeTaskListFileRequest) ProtoReflect() protoreflect.Message

func (*DescribeTaskListFileRequest) Reset 

func (x *DescribeTaskListFileRequest) Reset()

func (*DescribeTaskListFileRequest) String 

func (x *DescribeTaskListFileRequest) String() string

type DescribeTaskListFileResponse 

type DescribeTaskListFileResponse struct {
	DownloadURL string `protobuf:"bytes,3,opt,name=DownloadURL,proto3" json:"DownloadURL,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskListFileResponse) Descriptor deprecated 

func (*DescribeTaskListFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTaskListFileResponse.ProtoReflect.Descriptor instead.

func (*DescribeTaskListFileResponse) GetDownloadURL 

func (x *DescribeTaskListFileResponse) GetDownloadURL() string

func (*DescribeTaskListFileResponse) ProtoMessage 

func (*DescribeTaskListFileResponse) ProtoMessage()

func (*DescribeTaskListFileResponse) ProtoReflect 

func (x *DescribeTaskListFileResponse) ProtoReflect() protoreflect.Message

func (*DescribeTaskListFileResponse) Reset 

func (x *DescribeTaskListFileResponse) Reset()

func (*DescribeTaskListFileResponse) String 

func (x *DescribeTaskListFileResponse) String() string

type DescribeTaskRequest 

type DescribeTaskRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskRequest) Descriptor deprecated 

func (*DescribeTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTaskRequest.ProtoReflect.Descriptor instead.

func (*DescribeTaskRequest) GetTaskId 

func (x *DescribeTaskRequest) GetTaskId() string

func (*DescribeTaskRequest) ProtoMessage 

func (*DescribeTaskRequest) ProtoMessage()

func (*DescribeTaskRequest) ProtoReflect 

func (x *DescribeTaskRequest) ProtoReflect() protoreflect.Message

func (*DescribeTaskRequest) Reset 

func (x *DescribeTaskRequest) Reset()

func (*DescribeTaskRequest) String 

func (x *DescribeTaskRequest) String() string

type DescribeTaskResponse 

type DescribeTaskResponse struct {
	TaskInfo *apicommon.TaskInfo `protobuf:"bytes,1,opt,name=TaskInfo,proto3" json:"TaskInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskResponse) Descriptor deprecated 

func (*DescribeTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTaskResponse.ProtoReflect.Descriptor instead.

func (*DescribeTaskResponse) GetTaskInfo 

func (x *DescribeTaskResponse) GetTaskInfo() *apicommon.TaskInfo

func (*DescribeTaskResponse) ProtoMessage 

func (*DescribeTaskResponse) ProtoMessage()

func (*DescribeTaskResponse) ProtoReflect 

func (x *DescribeTaskResponse) ProtoReflect() protoreflect.Message

func (*DescribeTaskResponse) Reset 

func (x *DescribeTaskResponse) Reset()

func (*DescribeTaskResponse) String 

func (x *DescribeTaskResponse) String() string

type DescribeTasksRequest 

type DescribeTasksRequest struct {
	PageNumber     int32               `protobuf:"varint,1,opt,name=PageNumber,proto3" json:"PageNumber,omitempty"`
	PageSize       int32               `protobuf:"varint,2,opt,name=PageSize,proto3" json:"PageSize,omitempty"`
	FilterSet      []*apicommon.Filter `protobuf:"bytes,3,rep,name=FilterSet,proto3" json:"FilterSet,omitempty"`
	Sort           *SortBy             `protobuf:"bytes,4,opt,name=Sort,proto3" json:"Sort,omitempty"`
	CreateDayRange *apicommon.DayRange `protobuf:"bytes,5,opt,name=CreateDayRange,proto3" json:"CreateDayRange,omitempty"` // 筛选创建时间区间
	// contains filtered or unexported fields
}

func (*DescribeTasksRequest) Descriptor deprecated 

func (*DescribeTasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTasksRequest.ProtoReflect.Descriptor instead.

func (*DescribeTasksRequest) GetCreateDayRange 

func (x *DescribeTasksRequest) GetCreateDayRange() *apicommon.DayRange

func (*DescribeTasksRequest) GetFilterSet 

func (x *DescribeTasksRequest) GetFilterSet() []*apicommon.Filter

func (*DescribeTasksRequest) GetPageNumber 

func (x *DescribeTasksRequest) GetPageNumber() int32

func (*DescribeTasksRequest) GetPageSize 

func (x *DescribeTasksRequest) GetPageSize() int32

func (*DescribeTasksRequest) GetSort 

func (x *DescribeTasksRequest) GetSort() *SortBy

func (*DescribeTasksRequest) ProtoMessage 

func (*DescribeTasksRequest) ProtoMessage()

func (*DescribeTasksRequest) ProtoReflect 

func (x *DescribeTasksRequest) ProtoReflect() protoreflect.Message

func (*DescribeTasksRequest) Reset 

func (x *DescribeTasksRequest) Reset()

func (*DescribeTasksRequest) String 

func (x *DescribeTasksRequest) String() string

type DescribeTasksResponse 

type DescribeTasksResponse struct {
	TaskInfoSet []*apicommon.TaskInfo `protobuf:"bytes,1,rep,name=TaskInfoSet,proto3" json:"TaskInfoSet,omitempty"`
	TotalCount  uint32                `protobuf:"varint,2,opt,name=TotalCount,proto3" json:"TotalCount,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTasksResponse) Descriptor deprecated 

func (*DescribeTasksResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTasksResponse.ProtoReflect.Descriptor instead.

func (*DescribeTasksResponse) GetTaskInfoSet 

func (x *DescribeTasksResponse) GetTaskInfoSet() []*apicommon.TaskInfo

func (*DescribeTasksResponse) GetTotalCount 

func (x *DescribeTasksResponse) GetTotalCount() uint32

func (*DescribeTasksResponse) ProtoMessage 

func (*DescribeTasksResponse) ProtoMessage()

func (*DescribeTasksResponse) ProtoReflect 

func (x *DescribeTasksResponse) ProtoReflect() protoreflect.Message

func (*DescribeTasksResponse) Reset 

func (x *DescribeTasksResponse) Reset()

func (*DescribeTasksResponse) String 

func (x *DescribeTasksResponse) String() string

type DescribeWorkflowProgressRequest 

type DescribeWorkflowProgressRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeWorkflowProgressRequest) Descriptor deprecated 

func (*DescribeWorkflowProgressRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeWorkflowProgressRequest.ProtoReflect.Descriptor instead.

func (*DescribeWorkflowProgressRequest) GetTaskId 

func (x *DescribeWorkflowProgressRequest) GetTaskId() string

func (*DescribeWorkflowProgressRequest) ProtoMessage 

func (*DescribeWorkflowProgressRequest) ProtoMessage()

func (*DescribeWorkflowProgressRequest) ProtoReflect 

func (x *DescribeWorkflowProgressRequest) ProtoReflect() protoreflect.Message

func (*DescribeWorkflowProgressRequest) Reset 

func (x *DescribeWorkflowProgressRequest) Reset()

func (*DescribeWorkflowProgressRequest) String 

func (x *DescribeWorkflowProgressRequest) String() string

type DescribeWorkflowProgressResponse 

type DescribeWorkflowProgressResponse struct {
	TaskInfo       *apicommon.TaskInfo   `protobuf:"bytes,2,opt,name=TaskInfo,proto3" json:"TaskInfo,omitempty"`
	SubTaskInfoSet []*apicommon.TaskInfo `protobuf:"bytes,1,rep,name=SubTaskInfoSet,proto3" json:"SubTaskInfoSet,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeWorkflowProgressResponse) Descriptor deprecated 

func (*DescribeWorkflowProgressResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeWorkflowProgressResponse.ProtoReflect.Descriptor instead.

func (*DescribeWorkflowProgressResponse) GetSubTaskInfoSet 

func (x *DescribeWorkflowProgressResponse) GetSubTaskInfoSet() []*apicommon.TaskInfo

func (*DescribeWorkflowProgressResponse) GetTaskInfo 

func (x *DescribeWorkflowProgressResponse) GetTaskInfo() *apicommon.TaskInfo

func (*DescribeWorkflowProgressResponse) ProtoMessage 

func (*DescribeWorkflowProgressResponse) ProtoMessage()

func (*DescribeWorkflowProgressResponse) ProtoReflect 

func (x *DescribeWorkflowProgressResponse) ProtoReflect() protoreflect.Message

func (*DescribeWorkflowProgressResponse) Reset 

func (x *DescribeWorkflowProgressResponse) Reset()

func (*DescribeWorkflowProgressResponse) String 

func (x *DescribeWorkflowProgressResponse) String() string

type FinishedTaskRequest 

type FinishedTaskRequest struct {
	TaskId       string               `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	FLowId       string               `protobuf:"bytes,2,opt,name=FLowId,proto3" json:"FLowId,omitempty"`
	TaskStatus   apicommon.TaskStatus `protobuf:"varint,3,opt,name=TaskStatus,proto3,enum=trpc.media.common.TaskStatus" json:"TaskStatus,omitempty"`
	FailedReason string               `protobuf:"bytes,4,opt,name=FailedReason,proto3" json:"FailedReason,omitempty"`
	RequestId    string               `protobuf:"bytes,5,opt,name=RequestId,proto3" json:"RequestId,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishedTaskRequest) Descriptor deprecated 

func (*FinishedTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use FinishedTaskRequest.ProtoReflect.Descriptor instead.

func (*FinishedTaskRequest) GetFLowId 

func (x *FinishedTaskRequest) GetFLowId() string

func (*FinishedTaskRequest) GetFailedReason 

func (x *FinishedTaskRequest) GetFailedReason() string

func (*FinishedTaskRequest) GetRequestId 

func (x *FinishedTaskRequest) GetRequestId() string

func (*FinishedTaskRequest) GetTaskId 

func (x *FinishedTaskRequest) GetTaskId() string

func (*FinishedTaskRequest) GetTaskStatus 

func (x *FinishedTaskRequest) GetTaskStatus() apicommon.TaskStatus

func (*FinishedTaskRequest) ProtoMessage 

func (*FinishedTaskRequest) ProtoMessage()

func (*FinishedTaskRequest) ProtoReflect 

func (x *FinishedTaskRequest) ProtoReflect() protoreflect.Message

func (*FinishedTaskRequest) Reset 

func (x *FinishedTaskRequest) Reset()

func (*FinishedTaskRequest) String 

func (x *FinishedTaskRequest) String() string

type FinishedTaskResponse 

type FinishedTaskResponse struct {
	RequestId string `protobuf:"bytes,1,opt,name=RequestId,proto3" json:"RequestId,omitempty"`
	Error     string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishedTaskResponse) Descriptor deprecated 

func (*FinishedTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use FinishedTaskResponse.ProtoReflect.Descriptor instead.

func (*FinishedTaskResponse) GetError 

func (x *FinishedTaskResponse) GetError() string

func (*FinishedTaskResponse) GetRequestId 

func (x *FinishedTaskResponse) GetRequestId() string

func (*FinishedTaskResponse) ProtoMessage 

func (*FinishedTaskResponse) ProtoMessage()

func (*FinishedTaskResponse) ProtoReflect 

func (x *FinishedTaskResponse) ProtoReflect() protoreflect.Message

func (*FinishedTaskResponse) Reset 

func (x *FinishedTaskResponse) Reset()

func (*FinishedTaskResponse) String 

func (x *FinishedTaskResponse) String() string

type Indicator 

type Indicator struct {
	Name  string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*Indicator) Descriptor deprecated 

func (*Indicator) Descriptor() ([]byte, []int)

Deprecated: Use Indicator.ProtoReflect.Descriptor instead.

func (*Indicator) GetName 

func (x *Indicator) GetName() string

func (*Indicator) GetValue 

func (x *Indicator) GetValue() string

func (*Indicator) ProtoMessage 

func (*Indicator) ProtoMessage()

func (*Indicator) ProtoReflect 

func (x *Indicator) ProtoReflect() protoreflect.Message

func (*Indicator) Reset 

func (x *Indicator) Reset()

func (*Indicator) String 

func (x *Indicator) String() string

type ModifyTaskDataRequest 

type ModifyTaskDataRequest struct {
	TaskId            string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	JsonPath          string `protobuf:"bytes,2,opt,name=JsonPath,proto3" json:"JsonPath,omitempty"`
	NewTag            string `protobuf:"bytes,3,opt,name=NewTag,proto3" json:"NewTag,omitempty"`
	ReviseRelatedData bool   `protobuf:"varint,4,opt,name=ReviseRelatedData,proto3" json:"ReviseRelatedData,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyTaskDataRequest) Descriptor deprecated 

func (*ModifyTaskDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use ModifyTaskDataRequest.ProtoReflect.Descriptor instead.

func (*ModifyTaskDataRequest) GetJsonPath 

func (x *ModifyTaskDataRequest) GetJsonPath() string

func (*ModifyTaskDataRequest) GetNewTag 

func (x *ModifyTaskDataRequest) GetNewTag() string

func (*ModifyTaskDataRequest) GetReviseRelatedData 

func (x *ModifyTaskDataRequest) GetReviseRelatedData() bool

func (*ModifyTaskDataRequest) GetTaskId 

func (x *ModifyTaskDataRequest) GetTaskId() string

func (*ModifyTaskDataRequest) ProtoMessage 

func (*ModifyTaskDataRequest) ProtoMessage()

func (*ModifyTaskDataRequest) ProtoReflect 

func (x *ModifyTaskDataRequest) ProtoReflect() protoreflect.Message

func (*ModifyTaskDataRequest) Reset 

func (x *ModifyTaskDataRequest) Reset()

func (*ModifyTaskDataRequest) String 

func (x *ModifyTaskDataRequest) String() string

type ModifyTaskDataResponse 

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

func (*ModifyTaskDataResponse) Descriptor deprecated 

func (*ModifyTaskDataResponse) Descriptor() ([]byte, []int)

Deprecated: Use ModifyTaskDataResponse.ProtoReflect.Descriptor instead.

func (*ModifyTaskDataResponse) ProtoMessage 

func (*ModifyTaskDataResponse) ProtoMessage()

func (*ModifyTaskDataResponse) ProtoReflect 

func (x *ModifyTaskDataResponse) ProtoReflect() protoreflect.Message

func (*ModifyTaskDataResponse) Reset 

func (x *ModifyTaskDataResponse) Reset()

func (*ModifyTaskDataResponse) String 

func (x *ModifyTaskDataResponse) String() string

type SnippetData 

type SnippetData struct {
	StartTime   float32  `protobuf:"fixed32,1,opt,name=StartTime,proto3" json:"StartTime,omitempty"`
	EndTime     float32  `protobuf:"fixed32,2,opt,name=EndTime,proto3" json:"EndTime,omitempty"`
	SummarySet  []string `protobuf:"bytes,3,rep,name=SummarySet,proto3" json:"SummarySet,omitempty"`
	TitleSet    []string `protobuf:"bytes,4,rep,name=TitleSet,proto3" json:"TitleSet,omitempty"`
	AsrSet      []string `protobuf:"bytes,5,rep,name=AsrSet,proto3" json:"AsrSet,omitempty"`
	SubTitleSet []string `protobuf:"bytes,6,rep,name=SubTitleSet,proto3" json:"SubTitleSet,omitempty"`
	FrameTagSet []string `protobuf:"bytes,7,rep,name=FrameTagSet,proto3" json:"FrameTagSet,omitempty"`
	TextTagSet  []string `protobuf:"bytes,8,rep,name=TextTagSet,proto3" json:"TextTagSet,omitempty"`
	// contains filtered or unexported fields
}

func (*SnippetData) Descriptor deprecated 

func (*SnippetData) Descriptor() ([]byte, []int)

Deprecated: Use SnippetData.ProtoReflect.Descriptor instead.

func (*SnippetData) GetAsrSet 

func (x *SnippetData) GetAsrSet() []string

func (*SnippetData) GetEndTime 

func (x *SnippetData) GetEndTime() float32

func (*SnippetData) GetFrameTagSet 

func (x *SnippetData) GetFrameTagSet() []string

func (*SnippetData) GetStartTime 

func (x *SnippetData) GetStartTime() float32

func (*SnippetData) GetSubTitleSet 

func (x *SnippetData) GetSubTitleSet() []string

func (*SnippetData) GetSummarySet 

func (x *SnippetData) GetSummarySet() []string

func (*SnippetData) GetTextTagSet 

func (x *SnippetData) GetTextTagSet() []string

func (*SnippetData) GetTitleSet 

func (x *SnippetData) GetTitleSet() []string

func (*SnippetData) ProtoMessage 

func (*SnippetData) ProtoMessage()

func (*SnippetData) ProtoReflect 

func (x *SnippetData) ProtoReflect() protoreflect.Message

func (*SnippetData) Reset 

func (x *SnippetData) Reset()

func (*SnippetData) String 

func (x *SnippetData) String() string

type SortBy 

type SortBy struct {
	By      string `protobuf:"bytes,1,opt,name=By,proto3" json:"By,omitempty"`
	Descend bool   `protobuf:"varint,2,opt,name=Descend,proto3" json:"Descend,omitempty"`
	// contains filtered or unexported fields
}

func (*SortBy) Descriptor deprecated 

func (*SortBy) Descriptor() ([]byte, []int)

Deprecated: Use SortBy.ProtoReflect.Descriptor instead.

func (*SortBy) GetBy 

func (x *SortBy) GetBy() string

func (*SortBy) GetDescend 

func (x *SortBy) GetDescend() bool

func (*SortBy) ProtoMessage 

func (*SortBy) ProtoMessage()

func (*SortBy) ProtoReflect 

func (x *SortBy) ProtoReflect() protoreflect.Message

func (*SortBy) Reset 

func (x *SortBy) Reset()

func (*SortBy) String 

func (x *SortBy) String() string

type StartTaskRequest 

type StartTaskRequest struct {
	TaskId    string           `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	Parameter *structpb.Struct `protobuf:"bytes,2,opt,name=Parameter,proto3" json:"Parameter,omitempty"` // 可以接受任何 json 对应参数
	Top       bool             `protobuf:"varint,3,opt,name=Top,proto3" json:"Top,omitempty"`            // 任务优先级是否置顶
	// contains filtered or unexported fields
}

func (*StartTaskRequest) Descriptor deprecated 

func (*StartTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartTaskRequest.ProtoReflect.Descriptor instead.

func (*StartTaskRequest) GetParameter 

func (x *StartTaskRequest) GetParameter() *structpb.Struct

func (*StartTaskRequest) GetTaskId 

func (x *StartTaskRequest) GetTaskId() string

func (*StartTaskRequest) GetTop 

func (x *StartTaskRequest) GetTop() bool

func (*StartTaskRequest) ProtoMessage 

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) ProtoReflect 

func (x *StartTaskRequest) ProtoReflect() protoreflect.Message

func (*StartTaskRequest) Reset 

func (x *StartTaskRequest) Reset()

func (*StartTaskRequest) String 

func (x *StartTaskRequest) String() string

type StartTaskResponse 

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

func (*StartTaskResponse) Descriptor deprecated 

func (*StartTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartTaskResponse.ProtoReflect.Descriptor instead.

func (*StartTaskResponse) ProtoMessage 

func (*StartTaskResponse) ProtoMessage()

func (*StartTaskResponse) ProtoReflect 

func (x *StartTaskResponse) ProtoReflect() protoreflect.Message

func (*StartTaskResponse) Reset 

func (x *StartTaskResponse) Reset()

func (*StartTaskResponse) String 

func (x *StartTaskResponse) String() string

type StartTasksRequest 

type StartTasksRequest struct {
	TaskSet []*StartTaskRequest `protobuf:"bytes,1,rep,name=TaskSet,proto3" json:"TaskSet,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTasksRequest) Descriptor deprecated 

func (*StartTasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartTasksRequest.ProtoReflect.Descriptor instead.

func (*StartTasksRequest) GetTaskSet 

func (x *StartTasksRequest) GetTaskSet() []*StartTaskRequest

func (*StartTasksRequest) ProtoMessage 

func (*StartTasksRequest) ProtoMessage()

func (*StartTasksRequest) ProtoReflect 

func (x *StartTasksRequest) ProtoReflect() protoreflect.Message

func (*StartTasksRequest) Reset 

func (x *StartTasksRequest) Reset()

func (*StartTasksRequest) String 

func (x *StartTasksRequest) String() string

type StartTasksResponse 

type StartTasksResponse struct {
	OperateResponseSet []*TaskOperateResponse `protobuf:"bytes,1,rep,name=OperateResponseSet,proto3" json:"OperateResponseSet,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTasksResponse) Descriptor deprecated 

func (*StartTasksResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartTasksResponse.ProtoReflect.Descriptor instead.

func (*StartTasksResponse) GetOperateResponseSet 

func (x *StartTasksResponse) GetOperateResponseSet() []*TaskOperateResponse

func (*StartTasksResponse) ProtoMessage 

func (*StartTasksResponse) ProtoMessage()

func (*StartTasksResponse) ProtoReflect 

func (x *StartTasksResponse) ProtoReflect() protoreflect.Message

func (*StartTasksResponse) Reset 

func (x *StartTasksResponse) Reset()

func (*StartTasksResponse) String 

func (x *StartTasksResponse) String() string

type StatisticsData 

type StatisticsData struct {
	MediaStatisticsSet       []*Indicator `protobuf:"bytes,1,rep,name=MediaStatisticsSet,proto3" json:"MediaStatisticsSet,omitempty"`
	ProcessStatisticsSet     []*Indicator `protobuf:"bytes,2,rep,name=ProcessStatisticsSet,proto3" json:"ProcessStatisticsSet,omitempty"`
	MediaDurationClassiedSet []*Indicator `protobuf:"bytes,3,rep,name=MediaDurationClassiedSet,proto3" json:"MediaDurationClassiedSet,omitempty"`
	// contains filtered or unexported fields
}

func (*StatisticsData) Descriptor deprecated 

func (*StatisticsData) Descriptor() ([]byte, []int)

Deprecated: Use StatisticsData.ProtoReflect.Descriptor instead.

func (*StatisticsData) GetMediaDurationClassiedSet 

func (x *StatisticsData) GetMediaDurationClassiedSet() []*Indicator

func (*StatisticsData) GetMediaStatisticsSet 

func (x *StatisticsData) GetMediaStatisticsSet() []*Indicator

func (*StatisticsData) GetProcessStatisticsSet 

func (x *StatisticsData) GetProcessStatisticsSet() []*Indicator

func (*StatisticsData) ProtoMessage 

func (*StatisticsData) ProtoMessage()

func (*StatisticsData) ProtoReflect 

func (x *StatisticsData) ProtoReflect() protoreflect.Message

func (*StatisticsData) Reset 

func (x *StatisticsData) Reset()

func (*StatisticsData) String 

func (x *StatisticsData) String() string

type StopTaskRequest 

type StopTaskRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	// contains filtered or unexported fields
}

func (*StopTaskRequest) Descriptor deprecated 

func (*StopTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopTaskRequest.ProtoReflect.Descriptor instead.

func (*StopTaskRequest) GetTaskId 

func (x *StopTaskRequest) GetTaskId() string

func (*StopTaskRequest) ProtoMessage 

func (*StopTaskRequest) ProtoMessage()

func (*StopTaskRequest) ProtoReflect 

func (x *StopTaskRequest) ProtoReflect() protoreflect.Message

func (*StopTaskRequest) Reset 

func (x *StopTaskRequest) Reset()

func (*StopTaskRequest) String 

func (x *StopTaskRequest) String() string

type StopTaskResponse 

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

func (*StopTaskResponse) Descriptor deprecated 

func (*StopTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopTaskResponse.ProtoReflect.Descriptor instead.

func (*StopTaskResponse) ProtoMessage 

func (*StopTaskResponse) ProtoMessage()

func (*StopTaskResponse) ProtoReflect 

func (x *StopTaskResponse) ProtoReflect() protoreflect.Message

func (*StopTaskResponse) Reset 

func (x *StopTaskResponse) Reset()

func (*StopTaskResponse) String 

func (x *StopTaskResponse) String() string

type StopTasksRequest 

type StopTasksRequest struct {
	TaskIdSet []string `protobuf:"bytes,1,rep,name=TaskIdSet,proto3" json:"TaskIdSet,omitempty"`
	// contains filtered or unexported fields
}

func (*StopTasksRequest) Descriptor deprecated 

func (*StopTasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopTasksRequest.ProtoReflect.Descriptor instead.

func (*StopTasksRequest) GetTaskIdSet 

func (x *StopTasksRequest) GetTaskIdSet() []string

func (*StopTasksRequest) ProtoMessage 

func (*StopTasksRequest) ProtoMessage()

func (*StopTasksRequest) ProtoReflect 

func (x *StopTasksRequest) ProtoReflect() protoreflect.Message

func (*StopTasksRequest) Reset 

func (x *StopTasksRequest) Reset()

func (*StopTasksRequest) String 

func (x *StopTasksRequest) String() string

type StopTasksResponse 

type StopTasksResponse struct {
	OperateResponseSet []*TaskOperateResponse `protobuf:"bytes,1,rep,name=OperateResponseSet,proto3" json:"OperateResponseSet,omitempty"`
	// contains filtered or unexported fields
}

func (*StopTasksResponse) Descriptor deprecated 

func (*StopTasksResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopTasksResponse.ProtoReflect.Descriptor instead.

func (*StopTasksResponse) GetOperateResponseSet 

func (x *StopTasksResponse) GetOperateResponseSet() []*TaskOperateResponse

func (*StopTasksResponse) ProtoMessage 

func (*StopTasksResponse) ProtoMessage()

func (*StopTasksResponse) ProtoReflect 

func (x *StopTasksResponse) ProtoReflect() protoreflect.Message

func (*StopTasksResponse) Reset 

func (x *StopTasksResponse) Reset()

func (*StopTasksResponse) String 

func (x *StopTasksResponse) String() string

type TaskCallbackClientProxy 

type TaskCallbackClientProxy interface {
	FinishedTask(ctx context.Context, req *FinishedTaskRequest, opts ...client.Option) (rsp *FinishedTaskResponse, err error) // @alias=/FinishedTask
}

TaskCallbackClientProxy defines service client proxy

type TaskCallbackClientProxyImpl 

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

func (*TaskCallbackClientProxyImpl) FinishedTask 

func (c *TaskCallbackClientProxyImpl) FinishedTask(ctx context.Context, req *FinishedTaskRequest, opts ...client.Option) (*FinishedTaskResponse, error)

type TaskCallbackService 

type TaskCallbackService interface {
	FinishedTask(ctx context.Context, req *FinishedTaskRequest, rsp *FinishedTaskResponse) (err error) // @alias=/FinishedTask
}

TaskCallbackService defines service.

type TaskClientProxy 

type TaskClientProxy interface {
	// DescribeSupportedMediaTypes 任务管理
	DescribeSupportedMediaTypes(ctx context.Context, req *DescribeSupportedMediaTypesRequest, opts ...client.Option) (rsp *DescribeSupportedMediaTypesResponse, err error) // @alias=/DescribeSupportedMediaTypes

	CreateTask(ctx context.Context, req *CreateTaskRequest, opts ...client.Option) (rsp *CreateTaskResponse, err error) // @alias=/CreateTask

	DescribeTask(ctx context.Context, req *DescribeTaskRequest, opts ...client.Option) (rsp *DescribeTaskResponse, err error) // @alias=/DescribeTask

	DescribeTasks(ctx context.Context, req *DescribeTasksRequest, opts ...client.Option) (rsp *DescribeTasksResponse, err error) // @alias=/DescribeTasks

	StartTask(ctx context.Context, req *StartTaskRequest, opts ...client.Option) (rsp *StartTaskResponse, err error) // @alias=/StartTask

	StartTasks(ctx context.Context, req *StartTasksRequest, opts ...client.Option) (rsp *StartTasksResponse, err error) // @alias=/StartTasks

	StopTask(ctx context.Context, req *StopTaskRequest, opts ...client.Option) (rsp *StopTaskResponse, err error) // @alias=/StopTask

	StopTasks(ctx context.Context, req *StopTasksRequest, opts ...client.Option) (rsp *StopTasksResponse, err error) // @alias=/StopTasks

	DeleteTask(ctx context.Context, req *DeleteTaskRequest, opts ...client.Option) (rsp *DeleteTaskResponse, err error) // @alias=/DeleteTask

	TopTask(ctx context.Context, req *TopTaskRequest, opts ...client.Option) (rsp *TopTaskResponse, err error) // @alias=/TopTask

	DescribeTaskDetail(ctx context.Context, req *DescribeTaskDetailRequest, opts ...client.Option) (rsp *DescribeTaskDetailResponse, err error) // @alias=/DescribeTaskDetail
	// ModifyTaskData 标签修改
	ModifyTaskData(ctx context.Context, req *ModifyTaskDataRequest, opts ...client.Option) (rsp *ModifyTaskDataResponse, err error) // @alias=/ModifyTaskData
	// DescribeTaskListFile 数据统计相关
	DescribeTaskListFile(ctx context.Context, req *DescribeTaskListFileRequest, opts ...client.Option) (rsp *DescribeTaskListFileResponse, err error) // @alias=/DescribeTaskListFile

	DescribeStatistics(ctx context.Context, req *DescribeStatisticsRequest, opts ...client.Option) (rsp *DescribeStatisticsResponse, err error) // @alias=/DescribeStatistics
	// DescribeWorkflowProgress workflow
	DescribeWorkflowProgress(ctx context.Context, req *DescribeWorkflowProgressRequest, opts ...client.Option) (rsp *DescribeWorkflowProgressResponse, err error) // @alias=/DescribeWorkflowProgress
	// StopTasksInner 内部使用接口
	StopTasksInner(ctx context.Context, req *StopTasksRequest, opts ...client.Option) (rsp *StopTasksResponse, err error) // @alias=/StopTasksInner

	CheckWorkflowTemplate(ctx context.Context, req *CheckWorkflowTemplateRequest, opts ...client.Option) (rsp *CheckWorkflowTemplateResponse, err error) // @alias=/CheckWorkflowTemplate
	// DescribeTagAnalyseInput 标签分析任务输入太大，不适合作为 ppl 参数传入，采用拉取方式
	DescribeTagAnalyseInput(ctx context.Context, req *DescribeTagAnalyseInputRequest, opts ...client.Option) (rsp *DescribeTagAnalyseInputResponse, err error) // @alias=/DescribeTagAnalyseInput
}

TaskClientProxy defines service client proxy

type TaskClientProxyImpl 

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

func (*TaskClientProxyImpl) CheckWorkflowTemplate 

func (c *TaskClientProxyImpl) CheckWorkflowTemplate(ctx context.Context, req *CheckWorkflowTemplateRequest, opts ...client.Option) (*CheckWorkflowTemplateResponse, error)

func (*TaskClientProxyImpl) CreateTask 

func (c *TaskClientProxyImpl) CreateTask(ctx context.Context, req *CreateTaskRequest, opts ...client.Option) (*CreateTaskResponse, error)

func (*TaskClientProxyImpl) DeleteTask 

func (c *TaskClientProxyImpl) DeleteTask(ctx context.Context, req *DeleteTaskRequest, opts ...client.Option) (*DeleteTaskResponse, error)

func (*TaskClientProxyImpl) DescribeStatistics 

func (c *TaskClientProxyImpl) DescribeStatistics(ctx context.Context, req *DescribeStatisticsRequest, opts ...client.Option) (*DescribeStatisticsResponse, error)

func (*TaskClientProxyImpl) DescribeSupportedMediaTypes 

func (c *TaskClientProxyImpl) DescribeSupportedMediaTypes(ctx context.Context, req *DescribeSupportedMediaTypesRequest, opts ...client.Option) (*DescribeSupportedMediaTypesResponse, error)

func (*TaskClientProxyImpl) DescribeTagAnalyseInput 

func (c *TaskClientProxyImpl) DescribeTagAnalyseInput(ctx context.Context, req *DescribeTagAnalyseInputRequest, opts ...client.Option) (*DescribeTagAnalyseInputResponse, error)

func (*TaskClientProxyImpl) DescribeTask 

func (c *TaskClientProxyImpl) DescribeTask(ctx context.Context, req *DescribeTaskRequest, opts ...client.Option) (*DescribeTaskResponse, error)

func (*TaskClientProxyImpl) DescribeTaskDetail 

func (c *TaskClientProxyImpl) DescribeTaskDetail(ctx context.Context, req *DescribeTaskDetailRequest, opts ...client.Option) (*DescribeTaskDetailResponse, error)

func (*TaskClientProxyImpl) DescribeTaskListFile 

func (c *TaskClientProxyImpl) DescribeTaskListFile(ctx context.Context, req *DescribeTaskListFileRequest, opts ...client.Option) (*DescribeTaskListFileResponse, error)

func (*TaskClientProxyImpl) DescribeTasks 

func (c *TaskClientProxyImpl) DescribeTasks(ctx context.Context, req *DescribeTasksRequest, opts ...client.Option) (*DescribeTasksResponse, error)

func (*TaskClientProxyImpl) DescribeWorkflowProgress 

func (c *TaskClientProxyImpl) DescribeWorkflowProgress(ctx context.Context, req *DescribeWorkflowProgressRequest, opts ...client.Option) (*DescribeWorkflowProgressResponse, error)

func (*TaskClientProxyImpl) ModifyTaskData 

func (c *TaskClientProxyImpl) ModifyTaskData(ctx context.Context, req *ModifyTaskDataRequest, opts ...client.Option) (*ModifyTaskDataResponse, error)

func (*TaskClientProxyImpl) StartTask 

func (c *TaskClientProxyImpl) StartTask(ctx context.Context, req *StartTaskRequest, opts ...client.Option) (*StartTaskResponse, error)

func (*TaskClientProxyImpl) StartTasks 

func (c *TaskClientProxyImpl) StartTasks(ctx context.Context, req *StartTasksRequest, opts ...client.Option) (*StartTasksResponse, error)

func (*TaskClientProxyImpl) StopTask 

func (c *TaskClientProxyImpl) StopTask(ctx context.Context, req *StopTaskRequest, opts ...client.Option) (*StopTaskResponse, error)

func (*TaskClientProxyImpl) StopTasks 

func (c *TaskClientProxyImpl) StopTasks(ctx context.Context, req *StopTasksRequest, opts ...client.Option) (*StopTasksResponse, error)

func (*TaskClientProxyImpl) StopTasksInner 

func (c *TaskClientProxyImpl) StopTasksInner(ctx context.Context, req *StopTasksRequest, opts ...client.Option) (*StopTasksResponse, error)

func (*TaskClientProxyImpl) TopTask 

func (c *TaskClientProxyImpl) TopTask(ctx context.Context, req *TopTaskRequest, opts ...client.Option) (*TopTaskResponse, error)

type TaskOperateResponse 

type TaskOperateResponse struct {
	TaskId            string                     `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	TaskOperateStatus *apicommon.OperateResponse `protobuf:"bytes,2,opt,name=TaskOperateStatus,proto3" json:"TaskOperateStatus,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskOperateResponse) Descriptor deprecated 

func (*TaskOperateResponse) Descriptor() ([]byte, []int)

Deprecated: Use TaskOperateResponse.ProtoReflect.Descriptor instead.

func (*TaskOperateResponse) GetTaskId 

func (x *TaskOperateResponse) GetTaskId() string

func (*TaskOperateResponse) GetTaskOperateStatus 

func (x *TaskOperateResponse) GetTaskOperateStatus() *apicommon.OperateResponse

func (*TaskOperateResponse) ProtoMessage 

func (*TaskOperateResponse) ProtoMessage()

func (*TaskOperateResponse) ProtoReflect 

func (x *TaskOperateResponse) ProtoReflect() protoreflect.Message

func (*TaskOperateResponse) Reset 

func (x *TaskOperateResponse) Reset()

func (*TaskOperateResponse) String 

func (x *TaskOperateResponse) String() string

type TaskService 

type TaskService interface {
	// DescribeSupportedMediaTypes 任务管理
	DescribeSupportedMediaTypes(ctx context.Context, req *DescribeSupportedMediaTypesRequest, rsp *DescribeSupportedMediaTypesResponse) (err error) // @alias=/DescribeSupportedMediaTypes

	CreateTask(ctx context.Context, req *CreateTaskRequest, rsp *CreateTaskResponse) (err error) // @alias=/CreateTask

	DescribeTask(ctx context.Context, req *DescribeTaskRequest, rsp *DescribeTaskResponse) (err error) // @alias=/DescribeTask

	DescribeTasks(ctx context.Context, req *DescribeTasksRequest, rsp *DescribeTasksResponse) (err error) // @alias=/DescribeTasks

	StartTask(ctx context.Context, req *StartTaskRequest, rsp *StartTaskResponse) (err error) // @alias=/StartTask

	StartTasks(ctx context.Context, req *StartTasksRequest, rsp *StartTasksResponse) (err error) // @alias=/StartTasks

	StopTask(ctx context.Context, req *StopTaskRequest, rsp *StopTaskResponse) (err error) // @alias=/StopTask

	StopTasks(ctx context.Context, req *StopTasksRequest, rsp *StopTasksResponse) (err error) // @alias=/StopTasks

	DeleteTask(ctx context.Context, req *DeleteTaskRequest, rsp *DeleteTaskResponse) (err error) // @alias=/DeleteTask

	TopTask(ctx context.Context, req *TopTaskRequest, rsp *TopTaskResponse) (err error) // @alias=/TopTask

	DescribeTaskDetail(ctx context.Context, req *DescribeTaskDetailRequest, rsp *DescribeTaskDetailResponse) (err error) // @alias=/DescribeTaskDetail
	// ModifyTaskData 标签修改
	ModifyTaskData(ctx context.Context, req *ModifyTaskDataRequest, rsp *ModifyTaskDataResponse) (err error) // @alias=/ModifyTaskData
	// DescribeTaskListFile 数据统计相关
	DescribeTaskListFile(ctx context.Context, req *DescribeTaskListFileRequest, rsp *DescribeTaskListFileResponse) (err error) // @alias=/DescribeTaskListFile

	DescribeStatistics(ctx context.Context, req *DescribeStatisticsRequest, rsp *DescribeStatisticsResponse) (err error) // @alias=/DescribeStatistics
	// DescribeWorkflowProgress workflow
	DescribeWorkflowProgress(ctx context.Context, req *DescribeWorkflowProgressRequest, rsp *DescribeWorkflowProgressResponse) (err error) // @alias=/DescribeWorkflowProgress
	// StopTasksInner 内部使用接口
	StopTasksInner(ctx context.Context, req *StopTasksRequest, rsp *StopTasksResponse) (err error) // @alias=/StopTasksInner

	CheckWorkflowTemplate(ctx context.Context, req *CheckWorkflowTemplateRequest, rsp *CheckWorkflowTemplateResponse) (err error) // @alias=/CheckWorkflowTemplate
	// DescribeTagAnalyseInput 标签分析任务输入太大，不适合作为 ppl 参数传入，采用拉取方式
	DescribeTagAnalyseInput(ctx context.Context, req *DescribeTagAnalyseInputRequest, rsp *DescribeTagAnalyseInputResponse) (err error) // @alias=/DescribeTagAnalyseInput
}

TaskService defines service.

type TopTaskRequest 

type TopTaskRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	// contains filtered or unexported fields
}

func (*TopTaskRequest) Descriptor deprecated 

func (*TopTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use TopTaskRequest.ProtoReflect.Descriptor instead.

func (*TopTaskRequest) GetTaskId 

func (x *TopTaskRequest) GetTaskId() string

func (*TopTaskRequest) ProtoMessage 

func (*TopTaskRequest) ProtoMessage()

func (*TopTaskRequest) ProtoReflect 

func (x *TopTaskRequest) ProtoReflect() protoreflect.Message

func (*TopTaskRequest) Reset 

func (x *TopTaskRequest) Reset()

func (*TopTaskRequest) String 

func (x *TopTaskRequest) String() string

type TopTaskResponse 

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

func (*TopTaskResponse) Descriptor deprecated 

func (*TopTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use TopTaskResponse.ProtoReflect.Descriptor instead.

func (*TopTaskResponse) ProtoMessage 

func (*TopTaskResponse) ProtoMessage()

func (*TopTaskResponse) ProtoReflect 

func (x *TopTaskResponse) ProtoReflect() protoreflect.Message

func (*TopTaskResponse) Reset 

func (x *TopTaskResponse) Reset()

func (*TopTaskResponse) String 

func (x *TopTaskResponse) String() string

type UnimplementedTask 

type UnimplementedTask struct{}

func (*UnimplementedTask) CheckWorkflowTemplate 

func (s *UnimplementedTask) CheckWorkflowTemplate(ctx context.Context, req *CheckWorkflowTemplateRequest, rsp *CheckWorkflowTemplateResponse) error

func (*UnimplementedTask) CreateTask 

func (s *UnimplementedTask) CreateTask(ctx context.Context, req *CreateTaskRequest, rsp *CreateTaskResponse) error

func (*UnimplementedTask) DeleteTask 

func (s *UnimplementedTask) DeleteTask(ctx context.Context, req *DeleteTaskRequest, rsp *DeleteTaskResponse) error

func (*UnimplementedTask) DescribeStatistics 

func (s *UnimplementedTask) DescribeStatistics(ctx context.Context, req *DescribeStatisticsRequest, rsp *DescribeStatisticsResponse) error

func (*UnimplementedTask) DescribeSupportedMediaTypes 

func (s *UnimplementedTask) DescribeSupportedMediaTypes(ctx context.Context, req *DescribeSupportedMediaTypesRequest, rsp *DescribeSupportedMediaTypesResponse) error

DescribeSupportedMediaTypes 任务管理

func (*UnimplementedTask) DescribeTagAnalyseInput 

func (s *UnimplementedTask) DescribeTagAnalyseInput(ctx context.Context, req *DescribeTagAnalyseInputRequest, rsp *DescribeTagAnalyseInputResponse) error

DescribeTagAnalyseInput 标签分析任务输入太大，不适合作为 ppl 参数传入，采用拉取方式

func (*UnimplementedTask) DescribeTask 

func (s *UnimplementedTask) DescribeTask(ctx context.Context, req *DescribeTaskRequest, rsp *DescribeTaskResponse) error

func (*UnimplementedTask) DescribeTaskDetail 

func (s *UnimplementedTask) DescribeTaskDetail(ctx context.Context, req *DescribeTaskDetailRequest, rsp *DescribeTaskDetailResponse) error

func (*UnimplementedTask) DescribeTaskListFile 

func (s *UnimplementedTask) DescribeTaskListFile(ctx context.Context, req *DescribeTaskListFileRequest, rsp *DescribeTaskListFileResponse) error

DescribeTaskListFile 数据统计相关

func (*UnimplementedTask) DescribeTasks 

func (s *UnimplementedTask) DescribeTasks(ctx context.Context, req *DescribeTasksRequest, rsp *DescribeTasksResponse) error

func (*UnimplementedTask) DescribeWorkflowProgress 

func (s *UnimplementedTask) DescribeWorkflowProgress(ctx context.Context, req *DescribeWorkflowProgressRequest, rsp *DescribeWorkflowProgressResponse) error

DescribeWorkflowProgress workflow

func (*UnimplementedTask) ModifyTaskData 

func (s *UnimplementedTask) ModifyTaskData(ctx context.Context, req *ModifyTaskDataRequest, rsp *ModifyTaskDataResponse) error

ModifyTaskData 标签修改

func (*UnimplementedTask) StartTask 

func (s *UnimplementedTask) StartTask(ctx context.Context, req *StartTaskRequest, rsp *StartTaskResponse) error

func (*UnimplementedTask) StartTasks 

func (s *UnimplementedTask) StartTasks(ctx context.Context, req *StartTasksRequest, rsp *StartTasksResponse) error

func (*UnimplementedTask) StopTask 

func (s *UnimplementedTask) StopTask(ctx context.Context, req *StopTaskRequest, rsp *StopTaskResponse) error

func (*UnimplementedTask) StopTasks 

func (s *UnimplementedTask) StopTasks(ctx context.Context, req *StopTasksRequest, rsp *StopTasksResponse) error

func (*UnimplementedTask) StopTasksInner 

func (s *UnimplementedTask) StopTasksInner(ctx context.Context, req *StopTasksRequest, rsp *StopTasksResponse) error

StopTasksInner 内部使用接口

func (*UnimplementedTask) TopTask 

func (s *UnimplementedTask) TopTask(ctx context.Context, req *TopTaskRequest, rsp *TopTaskResponse) error

type UnimplementedTaskCallback 

type UnimplementedTaskCallback struct{}

func (*UnimplementedTaskCallback) FinishedTask 

func (s *UnimplementedTaskCallback) FinishedTask(ctx context.Context, req *FinishedTaskRequest, rsp *FinishedTaskResponse) error

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.