Documentation
¶
Index ¶
- func NewActService() actservice.ActServiceServer
- type ActService
- func (service *ActService) CancelActJob(_ context.Context, cancelJob *actservice.CancelJob) (*actservice.CancelJobResult, error)
- func (service *ActService) JobLogStream(request *actservice.JobLogRequest, ...) error
- func (service *ActService) ScheduleActJob(_ context.Context, job *actservice.Job) (*actservice.JobResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewActService ¶
func NewActService() actservice.ActServiceServer
Types ¶
type ActService ¶
type ActService struct {
actservice.UnimplementedActServiceServer
JobCtxCancels map[string]context.CancelFunc
FileListenersPool *ActService_listen_file.LogFileListeners
}
func (*ActService) CancelActJob ¶
func (service *ActService) CancelActJob( _ context.Context, cancelJob *actservice.CancelJob, ) (*actservice.CancelJobResult, error)
func (*ActService) JobLogStream ¶
func (service *ActService) JobLogStream( request *actservice.JobLogRequest, stream actservice.ActService_JobLogStreamServer, ) error
func (*ActService) ScheduleActJob ¶
func (service *ActService) ScheduleActJob(_ context.Context, job *actservice.Job) (*actservice.JobResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.