task

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

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

type CreatePersistTaskRequest struct {
	Payload *PersistTask `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type CreatePersistTaskResponse struct {
	Result *PersistTask `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type DeletePersistTaskRequest struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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

type ExecutePersistTaskRequest struct {
	Id     int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	DryRun bool  `protobuf:"varint,2,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

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

type ListPersistTasksRequest struct {
	Filter map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ListPersistTasksResponse struct {
	Results []*PersistTask `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type ListTasksRequest struct {
	Filter map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ListTasksResponse struct {
	Results []*Task `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type PersistTask struct {

	// @gotags: gorm:"primary_key;auto_increment"
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" gorm:"primary_key;auto_increment"`
	// @gotags: gorm:"serializer:protobuf_timestamp;type:datetime"
	CreatedAt *timestamppb.Timestamp `` /* 139-byte string literal not displayed */
	// @gotags: gorm:"serializer:protobuf_timestamp;type:datetime"
	UpdatedAt *timestamppb.Timestamp `` /* 139-byte string literal not displayed */
	// @gotags: gorm:"not null;unique"
	Name       string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty" gorm:"not null;unique"`
	Status     bool   `protobuf:"varint,5,opt,name=status,proto3" json:"status,omitempty"`
	Type       string `protobuf:"bytes,6,opt,name=type,proto3" json:"type,omitempty"`
	Option     string `protobuf:"bytes,7,opt,name=option,proto3" json:"option,omitempty"`
	CronOption string `protobuf:"bytes,8,opt,name=cron_option,json=cronOption,proto3" json:"cron_option,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

type Task struct {

	// @gotags: gorm:"not null;unique"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" gorm:"not null;unique"`
	// @gotags: gorm:"serializer:protobuf_timestamp;type:datetime"
	StartTime *timestamppb.Timestamp `` /* 139-byte string literal not displayed */
	// @gotags: gorm:"serializer:protobuf_timestamp;type:datetime"
	EndTime *timestamppb.Timestamp `` /* 133-byte string literal not displayed */
	// @gotags: gorm:"not null;"
	Name          string    `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty" gorm:"not null;"`
	State         TaskState `protobuf:"varint,5,opt,name=state,proto3,enum=api.task.TaskState" json:"state,omitempty"`
	Progress      float64   `protobuf:"fixed64,6,opt,name=progress,proto3" json:"progress,omitempty"`
	ProgressState string    `protobuf:"bytes,7,opt,name=progress_state,json=progressState,proto3" json:"progress_state,omitempty"`
	Log           string    `protobuf:"bytes,8,opt,name=log,proto3" json:"log,omitempty"`
	Err           string    `protobuf:"bytes,9,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type TaskServiceClient interface {
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	RetryTask(ctx context.Context, in *RetryTaskRequest, opts ...grpc.CallOption) (*RetryTaskResponse, error)
	CancelTask(ctx context.Context, in *CancelTaskRequest, opts ...grpc.CallOption) (*CancelTaskResponse, error)
	RemoveTask(ctx context.Context, in *RemoveTaskRequest, opts ...grpc.CallOption) (*RemoveTaskResponse, error)
	ListPersistTasks(ctx context.Context, in *ListPersistTasksRequest, opts ...grpc.CallOption) (*ListPersistTasksResponse, error)
	CreatePersistTask(ctx context.Context, in *CreatePersistTaskRequest, opts ...grpc.CallOption) (*CreatePersistTaskResponse, error)
	UpdatePersistTask(ctx context.Context, in *UpdatePersistTaskRequest, opts ...grpc.CallOption) (*UpdatePersistTaskResponse, error)
	DeletePersistTask(ctx context.Context, in *DeletePersistTaskRequest, opts ...grpc.CallOption) (*DeletePersistTaskResponse, error)
	TestPersistTask(ctx context.Context, in *TestPersistTaskRequest, opts ...grpc.CallOption) (*TestPersistTaskResponse, error)
	ExecutePersistTask(ctx context.Context, in *ExecutePersistTaskRequest, opts ...grpc.CallOption) (*ExecutePersistTaskResponse, error)
}

type TaskServiceServer interface {
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	RetryTask(context.Context, *RetryTaskRequest) (*RetryTaskResponse, error)
	CancelTask(context.Context, *CancelTaskRequest) (*CancelTaskResponse, error)
	RemoveTask(context.Context, *RemoveTaskRequest) (*RemoveTaskResponse, error)
	ListPersistTasks(context.Context, *ListPersistTasksRequest) (*ListPersistTasksResponse, error)
	CreatePersistTask(context.Context, *CreatePersistTaskRequest) (*CreatePersistTaskResponse, error)
	UpdatePersistTask(context.Context, *UpdatePersistTaskRequest) (*UpdatePersistTaskResponse, error)
	DeletePersistTask(context.Context, *DeletePersistTaskRequest) (*DeletePersistTaskResponse, error)
	TestPersistTask(context.Context, *TestPersistTaskRequest) (*TestPersistTaskResponse, error)
	ExecutePersistTask(context.Context, *ExecutePersistTaskRequest) (*ExecutePersistTaskResponse, error)
	// contains filtered or unexported methods
}

type TaskState int32

type TestPersistTaskRequest struct {
	Payload *PersistTask `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

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

type UnimplementedTaskServiceServer struct{}

type UnsafeTaskServiceServer interface {
	// contains filtered or unexported methods
}

type UpdatePersistTaskRequest struct {
	Payload *PersistTask `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type UpdatePersistTaskResponse struct {
	Result *PersistTask `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}