jobs

Aug 21, 2019 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Jul 9, 2019 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Jun 24, 2019 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

May 22, 2019 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

May 7, 2019 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Apr 15, 2019 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Changes in this version

+ const IdmEventObjectUser

+ func IdmChangeEventName(objectType string, eventType idm.ChangeEventType) string

+ func MatchesIdmChangeEvent(eventName string, event *idm.ChangeEvent) bool

type Action

+ func (a *Action) MarshalLogObject(encoder zapcore.ObjectEncoder) error

type Job

+ NodeEventFilter *NodesSelector

+ UserEventFilter *UsersSelector

+ func (job *Job) MarshalLogObject(encoder zapcore.ObjectEncoder) error

+ func (m *Job) GetNodeEventFilter() *NodesSelector

+ func (m *Job) GetUserEventFilter() *UsersSelector

type Task

+ func (task *Task) MarshalLogObject(encoder zapcore.ObjectEncoder) error

Mar 5, 2019 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Feb 20, 2019 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Changes in this version

type ListJobsRequest

+ JobIDs []string

+ TasksLimit int32

+ TasksOffset int32

+ func (m *ListJobsRequest) GetJobIDs() []string

+ func (m *ListJobsRequest) GetTasksLimit() int32

+ func (m *ListJobsRequest) GetTasksOffset() int32

type Task

+ func (task *Task) GetCtxOperationID() string

+ func (task *Task) WithoutLogs() *Task

Jan 9, 2019 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Dec 13, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Changes in this version

type ActionOutput

+ Time int32

+ func (m *ActionOutput) GetTime() int32

Dec 7, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Dec 4, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Oct 29, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Oct 2, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Changes in this version

type Job

+ TasksSilentUpdate bool

+ func (m *Job) GetTasksSilentUpdate() bool

Sep 7, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Aug 3, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Jul 3, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Jun 18, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

May 15, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Apr 24, 2018 GO-2023-1808 +2 more

  GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

  GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

  GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Changes in this version

+ var Command_name = map[int32]string

+ var Command_value = map[string]int32

+ var TaskStatus_name = map[int32]string

+ var TaskStatus_value = map[string]int32

+ func NodeChangeEventName(event tree.NodeChangeEvent_EventType) string

+ func ParseNodeChangeEventName(eventName string) (tree.NodeChangeEvent_EventType, bool)

+ func RegisterJobServiceHandler(s server.Server, hdlr JobServiceHandler, opts ...server.HandlerOption)

+ func RegisterTaskServiceHandler(s server.Server, hdlr TaskServiceHandler, opts ...server.HandlerOption)

+ type Action struct

+ ChainedActions []*Action

+ ID string

+ NodesFilter *NodesSelector

+ NodesSelector *NodesSelector

+ Parameters map[string]string

+ SourceFilter *SourceFilter

+ UsersFilter *UsersSelector

+ UsersSelector *UsersSelector

+ func (*Action) Descriptor() ([]byte, []int)

+ func (*Action) ProtoMessage()

+ func (a *Action) ApplyFilters(input ActionMessage) ActionMessage

+ func (a *Action) CollectSelector(cl client.Client, ctx context.Context, selector InputSelector, ...)

+ func (a *Action) FanOutSelector(cl client.Client, ctx context.Context, selector InputSelector, ...)

+ func (a *Action) FanToNext(cl client.Client, ctx context.Context, index int, input ActionMessage, ...)

+ func (a *Action) HasSelectors() bool

+ func (a *Action) ResolveSelectors(startMessage ActionMessage, cl client.Client, ctx context.Context, ...)

+ func (a *Action) ToMessages(startMessage ActionMessage, c client.Client, ctx context.Context, ...)

+ func (a *Action) Zap() zapcore.Field

+ func (a *Action) ZapId() zapcore.Field

+ func (m *Action) GetChainedActions() []*Action

+ func (m *Action) GetID() string

+ func (m *Action) GetNodesFilter() *NodesSelector

+ func (m *Action) GetNodesSelector() *NodesSelector

+ func (m *Action) GetParameters() map[string]string

+ func (m *Action) GetSourceFilter() *SourceFilter

+ func (m *Action) GetUsersFilter() *UsersSelector

+ func (m *Action) GetUsersSelector() *UsersSelector

+ func (m *Action) Reset()

+ func (m *Action) String() string

+ type ActionLog struct

+ Action *Action

+ InputMessage *ActionMessage

+ OutputMessage *ActionMessage

+ func (*ActionLog) Descriptor() ([]byte, []int)

+ func (*ActionLog) ProtoMessage()

+ func (m *ActionLog) GetAction() *Action

+ func (m *ActionLog) GetInputMessage() *ActionMessage

+ func (m *ActionLog) GetOutputMessage() *ActionMessage

+ func (m *ActionLog) Reset()

+ func (m *ActionLog) String() string

+ type ActionMessage struct

+ Activities []*activity.Object

+ Event *google_protobuf.Any

+ Nodes []*tree.Node

+ OutputChain []*ActionOutput

+ Users []*idm.User

+ func (*ActionMessage) Descriptor() ([]byte, []int)

+ func (*ActionMessage) ProtoMessage()

+ func (a *ActionMessage) AppendOutput(output *ActionOutput)

+ func (a *ActionMessage) GetLastOutput() *ActionOutput

+ func (a *ActionMessage) GetOutputs() []*ActionOutput

+ func (a *ActionMessage) WithError(e error) ActionMessage

+ func (a *ActionMessage) WithIgnore() ActionMessage

+ func (a *ActionMessage) WithNode(n *tree.Node) ActionMessage

+ func (a *ActionMessage) WithNodes(nodes ...*tree.Node) ActionMessage

+ func (a *ActionMessage) WithUser(u *idm.User) ActionMessage

+ func (a *ActionMessage) WithUsers(users ...*idm.User) ActionMessage

+ func (m *ActionMessage) GetActivities() []*activity.Object

+ func (m *ActionMessage) GetEvent() *google_protobuf.Any

+ func (m *ActionMessage) GetNodes() []*tree.Node

+ func (m *ActionMessage) GetOutputChain() []*ActionOutput

+ func (m *ActionMessage) GetUsers() []*idm.User

+ func (m *ActionMessage) Reset()

+ func (m *ActionMessage) String() string

+ type ActionOutput struct

+ ErrorString string

+ Ignored bool

+ JsonBody []byte

+ RawBody []byte

+ StringBody string

+ Success bool

+ func (*ActionOutput) Descriptor() ([]byte, []int)

+ func (*ActionOutput) ProtoMessage()

+ func (m *ActionOutput) GetErrorString() string

+ func (m *ActionOutput) GetIgnored() bool

+ func (m *ActionOutput) GetJsonBody() []byte

+ func (m *ActionOutput) GetRawBody() []byte

+ func (m *ActionOutput) GetStringBody() string

+ func (m *ActionOutput) GetSuccess() bool

+ func (m *ActionOutput) Reset()

+ func (m *ActionOutput) String() string

+ type Command int32

+ const Command_Active

+ const Command_Delete

+ const Command_Inactive

+ const Command_None

+ const Command_Pause

+ const Command_Resume

+ const Command_RunOnce

+ const Command_Stop

+ func (Command) EnumDescriptor() ([]byte, []int)

+ func (x Command) String() string

+ type CtrlCommand struct

+ Cmd Command

+ JobId string

+ OwnerId string

+ TaskId string

+ func (*CtrlCommand) Descriptor() ([]byte, []int)

+ func (*CtrlCommand) ProtoMessage()

+ func (m *CtrlCommand) GetCmd() Command

+ func (m *CtrlCommand) GetJobId() string

+ func (m *CtrlCommand) GetOwnerId() string

+ func (m *CtrlCommand) GetTaskId() string

+ func (m *CtrlCommand) Reset()

+ func (m *CtrlCommand) String() string

+ type CtrlCommandResponse struct

+ Msg string

+ func (*CtrlCommandResponse) Descriptor() ([]byte, []int)

+ func (*CtrlCommandResponse) ProtoMessage()

+ func (m *CtrlCommandResponse) GetMsg() string

+ func (m *CtrlCommandResponse) Reset()

+ func (m *CtrlCommandResponse) String() string

+ type DeleteJobRequest struct

+ CleanableJobs bool

+ JobID string

+ func (*DeleteJobRequest) Descriptor() ([]byte, []int)

+ func (*DeleteJobRequest) ProtoMessage()

+ func (m *DeleteJobRequest) GetCleanableJobs() bool

+ func (m *DeleteJobRequest) GetJobID() string

+ func (m *DeleteJobRequest) Reset()

+ func (m *DeleteJobRequest) String() string

+ type DeleteJobResponse struct

+ DeleteCount int32

+ Success bool

+ func (*DeleteJobResponse) Descriptor() ([]byte, []int)

+ func (*DeleteJobResponse) ProtoMessage()

+ func (m *DeleteJobResponse) GetDeleteCount() int32

+ func (m *DeleteJobResponse) GetSuccess() bool

+ func (m *DeleteJobResponse) Reset()

+ func (m *DeleteJobResponse) String() string

+ type DeleteTasksRequest struct

+ JobId string

+ PruneLimit int32

+ Status []TaskStatus

+ TaskID []string

+ func (*DeleteTasksRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTasksRequest) ProtoMessage()

+ func (m *DeleteTasksRequest) GetJobId() string

+ func (m *DeleteTasksRequest) GetPruneLimit() int32

+ func (m *DeleteTasksRequest) GetStatus() []TaskStatus

+ func (m *DeleteTasksRequest) GetTaskID() []string

+ func (m *DeleteTasksRequest) Reset()

+ func (m *DeleteTasksRequest) String() string

+ type DeleteTasksResponse struct

+ Deleted []string

+ func (*DeleteTasksResponse) Descriptor() ([]byte, []int)

+ func (*DeleteTasksResponse) ProtoMessage()

+ func (m *DeleteTasksResponse) GetDeleted() []string

+ func (m *DeleteTasksResponse) Reset()

+ func (m *DeleteTasksResponse) String() string

+ type DetectStuckTasksRequest struct

+ Since int32

+ func (*DetectStuckTasksRequest) Descriptor() ([]byte, []int)

+ func (*DetectStuckTasksRequest) ProtoMessage()

+ func (m *DetectStuckTasksRequest) GetSince() int32

+ func (m *DetectStuckTasksRequest) Reset()

+ func (m *DetectStuckTasksRequest) String() string

+ type DetectStuckTasksResponse struct

+ FixedTaskIds []string

+ func (*DetectStuckTasksResponse) Descriptor() ([]byte, []int)

+ func (*DetectStuckTasksResponse) ProtoMessage()

+ func (m *DetectStuckTasksResponse) GetFixedTaskIds() []string

+ func (m *DetectStuckTasksResponse) Reset()

+ func (m *DetectStuckTasksResponse) String() string

+ type GetJobRequest struct

+ JobID string

+ LoadTasks TaskStatus

+ func (*GetJobRequest) Descriptor() ([]byte, []int)

+ func (*GetJobRequest) ProtoMessage()

+ func (m *GetJobRequest) GetJobID() string

+ func (m *GetJobRequest) GetLoadTasks() TaskStatus

+ func (m *GetJobRequest) Reset()

+ func (m *GetJobRequest) String() string

+ type GetJobResponse struct

+ Job *Job

+ func (*GetJobResponse) Descriptor() ([]byte, []int)

+ func (*GetJobResponse) ProtoMessage()

+ func (m *GetJobResponse) GetJob() *Job

+ func (m *GetJobResponse) Reset()

+ func (m *GetJobResponse) String() string

+ type InputFilter interface

+ Filter func(input ActionMessage) ActionMessage

+ type InputSelector interface

+ MultipleSelection func() bool

+ Select func(cl client.Client, ctx context.Context, objects chan interface{}, ...) error

+ type Job struct

+ Actions []*Action

+ AutoClean bool

+ AutoStart bool

+ EventNames []string

+ ID string

+ Inactive bool

+ Label string

+ Languages []string

+ MaxConcurrency int32

+ Owner string

+ Schedule *Schedule

+ Tasks []*Task

+ func (*Job) Descriptor() ([]byte, []int)

+ func (*Job) ProtoMessage()

+ func (job *Job) Zap() zapcore.Field

+ func (job *Job) ZapId() zapcore.Field

+ func (m *Job) GetActions() []*Action

+ func (m *Job) GetAutoClean() bool

+ func (m *Job) GetAutoStart() bool

+ func (m *Job) GetEventNames() []string

+ func (m *Job) GetID() string

+ func (m *Job) GetInactive() bool

+ func (m *Job) GetLabel() string

+ func (m *Job) GetLanguages() []string

+ func (m *Job) GetMaxConcurrency() int32

+ func (m *Job) GetOwner() string

+ func (m *Job) GetSchedule() *Schedule

+ func (m *Job) GetTasks() []*Task

+ func (m *Job) Reset()

+ func (m *Job) String() string

+ type JobChangeEvent struct

+ JobRemoved string

+ JobUpdated *Job

+ func (*JobChangeEvent) Descriptor() ([]byte, []int)

+ func (*JobChangeEvent) ProtoMessage()

+ func (m *JobChangeEvent) GetJobRemoved() string

+ func (m *JobChangeEvent) GetJobUpdated() *Job

+ func (m *JobChangeEvent) Reset()

+ func (m *JobChangeEvent) String() string

+ type JobService struct

+ func (h *JobService) DeleteJob(ctx context.Context, in *DeleteJobRequest, out *DeleteJobResponse) error

+ func (h *JobService) DeleteTasks(ctx context.Context, in *DeleteTasksRequest, out *DeleteTasksResponse) error

+ func (h *JobService) DetectStuckTasks(ctx context.Context, in *DetectStuckTasksRequest, ...) error

+ func (h *JobService) GetJob(ctx context.Context, in *GetJobRequest, out *GetJobResponse) error

+ func (h *JobService) ListJobs(ctx context.Context, stream server.Streamer) error

+ func (h *JobService) ListTasks(ctx context.Context, stream server.Streamer) error

+ func (h *JobService) PutJob(ctx context.Context, in *PutJobRequest, out *PutJobResponse) error

+ func (h *JobService) PutTask(ctx context.Context, in *PutTaskRequest, out *PutTaskResponse) error

+ func (h *JobService) PutTaskStream(ctx context.Context, stream server.Streamer) error

+ type JobServiceClient interface

+ DeleteJob func(ctx context.Context, in *DeleteJobRequest, opts ...client.CallOption) (*DeleteJobResponse, error)

+ DeleteTasks func(ctx context.Context, in *DeleteTasksRequest, opts ...client.CallOption) (*DeleteTasksResponse, error)

+ DetectStuckTasks func(ctx context.Context, in *DetectStuckTasksRequest, opts ...client.CallOption) (*DetectStuckTasksResponse, error)

+ GetJob func(ctx context.Context, in *GetJobRequest, opts ...client.CallOption) (*GetJobResponse, error)

+ ListJobs func(ctx context.Context, in *ListJobsRequest, opts ...client.CallOption) (JobService_ListJobsClient, error)

+ ListTasks func(ctx context.Context, in *ListTasksRequest, opts ...client.CallOption) (JobService_ListTasksClient, error)

+ PutJob func(ctx context.Context, in *PutJobRequest, opts ...client.CallOption) (*PutJobResponse, error)

+ PutTask func(ctx context.Context, in *PutTaskRequest, opts ...client.CallOption) (*PutTaskResponse, error)

+ PutTaskStream func(ctx context.Context, opts ...client.CallOption) (JobService_PutTaskStreamClient, error)

+ func NewJobServiceClient(serviceName string, c client.Client) JobServiceClient

+ type JobServiceHandler interface

+ DeleteJob func(context.Context, *DeleteJobRequest, *DeleteJobResponse) error

+ DeleteTasks func(context.Context, *DeleteTasksRequest, *DeleteTasksResponse) error

+ DetectStuckTasks func(context.Context, *DetectStuckTasksRequest, *DetectStuckTasksResponse) error

+ GetJob func(context.Context, *GetJobRequest, *GetJobResponse) error

+ ListJobs func(context.Context, *ListJobsRequest, JobService_ListJobsStream) error

+ ListTasks func(context.Context, *ListTasksRequest, JobService_ListTasksStream) error

+ PutJob func(context.Context, *PutJobRequest, *PutJobResponse) error

+ PutTask func(context.Context, *PutTaskRequest, *PutTaskResponse) error

+ PutTaskStream func(context.Context, JobService_PutTaskStreamStream) error

+ type JobService_ListJobsClient interface

+ Close func() error

+ Recv func() (*ListJobsResponse, error)

+ RecvMsg func(interface{}) error

+ SendMsg func(interface{}) error

+ type JobService_ListJobsStream interface

+ Close func() error

+ RecvMsg func(interface{}) error

+ Send func(*ListJobsResponse) error

+ SendMsg func(interface{}) error

+ type JobService_ListTasksClient interface

+ Close func() error

+ Recv func() (*ListTasksResponse, error)

+ RecvMsg func(interface{}) error

+ SendMsg func(interface{}) error

+ type JobService_ListTasksStream interface

+ Close func() error

+ RecvMsg func(interface{}) error

+ Send func(*ListTasksResponse) error

+ SendMsg func(interface{}) error

+ type JobService_PutTaskStreamClient interface

+ Close func() error

+ Recv func() (*PutTaskResponse, error)

+ RecvMsg func(interface{}) error

+ Send func(*PutTaskRequest) error

+ SendMsg func(interface{}) error

+ type JobService_PutTaskStreamStream interface

+ Close func() error

+ Recv func() (*PutTaskRequest, error)

+ RecvMsg func(interface{}) error

+ Send func(*PutTaskResponse) error

+ SendMsg func(interface{}) error

+ type JobTriggerEvent struct

+ JobID string

+ RunNow bool

+ Schedule *Schedule

+ func (*JobTriggerEvent) Descriptor() ([]byte, []int)

+ func (*JobTriggerEvent) ProtoMessage()

+ func (m *JobTriggerEvent) GetJobID() string

+ func (m *JobTriggerEvent) GetRunNow() bool

+ func (m *JobTriggerEvent) GetSchedule() *Schedule

+ func (m *JobTriggerEvent) Reset()

+ func (m *JobTriggerEvent) String() string

+ type ListJobsRequest struct

+ EventsOnly bool

+ LoadTasks TaskStatus

+ Owner string

+ TimersOnly bool

+ func (*ListJobsRequest) Descriptor() ([]byte, []int)

+ func (*ListJobsRequest) ProtoMessage()

+ func (m *ListJobsRequest) GetEventsOnly() bool

+ func (m *ListJobsRequest) GetLoadTasks() TaskStatus

+ func (m *ListJobsRequest) GetOwner() string

+ func (m *ListJobsRequest) GetTimersOnly() bool

+ func (m *ListJobsRequest) Reset()

+ func (m *ListJobsRequest) String() string

+ type ListJobsResponse struct

+ Job *Job

+ func (*ListJobsResponse) Descriptor() ([]byte, []int)

+ func (*ListJobsResponse) ProtoMessage()

+ func (m *ListJobsResponse) GetJob() *Job

+ func (m *ListJobsResponse) Reset()

+ func (m *ListJobsResponse) String() string

+ type ListTasksRequest struct

+ JobID string

+ Status TaskStatus

+ func (*ListTasksRequest) Descriptor() ([]byte, []int)

+ func (*ListTasksRequest) ProtoMessage()

+ func (m *ListTasksRequest) GetJobID() string

+ func (m *ListTasksRequest) GetStatus() TaskStatus

+ func (m *ListTasksRequest) Reset()

+ func (m *ListTasksRequest) String() string

+ type ListTasksResponse struct

+ Task *Task

+ func (*ListTasksResponse) Descriptor() ([]byte, []int)

+ func (*ListTasksResponse) ProtoMessage()

+ func (m *ListTasksResponse) GetTask() *Task

+ func (m *ListTasksResponse) Reset()

+ func (m *ListTasksResponse) String() string

+ type NodesSelector struct

+ All bool

+ Collect bool

+ Nodes []*tree.Node

+ Pathes []string

+ Query *service.Query

+ func (*NodesSelector) Descriptor() ([]byte, []int)

+ func (*NodesSelector) ProtoMessage()

+ func (m *NodesSelector) GetAll() bool

+ func (m *NodesSelector) GetCollect() bool

+ func (m *NodesSelector) GetNodes() []*tree.Node

+ func (m *NodesSelector) GetPathes() []string

+ func (m *NodesSelector) GetQuery() *service.Query

+ func (m *NodesSelector) Reset()

+ func (m *NodesSelector) String() string

+ func (n *NodesSelector) Filter(input ActionMessage) ActionMessage

+ func (n *NodesSelector) MultipleSelection() bool

+ func (n *NodesSelector) Select(cl client.Client, ctx context.Context, objects chan interface{}, ...) error

+ type PutJobRequest struct

+ Job *Job

+ func (*PutJobRequest) Descriptor() ([]byte, []int)

+ func (*PutJobRequest) ProtoMessage()

+ func (m *PutJobRequest) GetJob() *Job

+ func (m *PutJobRequest) Reset()

+ func (m *PutJobRequest) String() string

+ type PutJobResponse struct

+ Job *Job

+ func (*PutJobResponse) Descriptor() ([]byte, []int)

+ func (*PutJobResponse) ProtoMessage()

+ func (m *PutJobResponse) GetJob() *Job

+ func (m *PutJobResponse) Reset()

+ func (m *PutJobResponse) String() string

+ type PutTaskRequest struct

+ Task *Task

+ func (*PutTaskRequest) Descriptor() ([]byte, []int)

+ func (*PutTaskRequest) ProtoMessage()

+ func (m *PutTaskRequest) GetTask() *Task

+ func (m *PutTaskRequest) Reset()

+ func (m *PutTaskRequest) String() string

+ type PutTaskResponse struct

+ Task *Task

+ func (*PutTaskResponse) Descriptor() ([]byte, []int)

+ func (*PutTaskResponse) ProtoMessage()

+ func (m *PutTaskResponse) GetTask() *Task

+ func (m *PutTaskResponse) Reset()

+ func (m *PutTaskResponse) String() string

+ type Schedule struct

+ Iso8601MinDelta string

+ Iso8601Schedule string

+ func (*Schedule) Descriptor() ([]byte, []int)

+ func (*Schedule) ProtoMessage()

+ func (m *Schedule) GetIso8601MinDelta() string

+ func (m *Schedule) GetIso8601Schedule() string

+ func (m *Schedule) Reset()

+ func (m *Schedule) String() string

+ type SourceFilter struct

+ Query *service.Query

+ func (*SourceFilter) Descriptor() ([]byte, []int)

+ func (*SourceFilter) ProtoMessage()

+ func (m *SourceFilter) GetQuery() *service.Query

+ func (m *SourceFilter) Reset()

+ func (m *SourceFilter) String() string

+ func (n *SourceFilter) Filter(input ActionMessage) ActionMessage

+ type Task struct

+ ActionsLogs []*ActionLog

+ CanPause bool

+ CanStop bool

+ EndTime int32

+ HasProgress bool

+ ID string

+ JobID string

+ Progress float32

+ StartTime int32

+ Status TaskStatus

+ StatusMessage string

+ TriggerOwner string

+ func (*Task) Descriptor() ([]byte, []int)

+ func (*Task) ProtoMessage()

+ func (m *Task) GetActionsLogs() []*ActionLog

+ func (m *Task) GetCanPause() bool

+ func (m *Task) GetCanStop() bool

+ func (m *Task) GetEndTime() int32

+ func (m *Task) GetHasProgress() bool

+ func (m *Task) GetID() string

+ func (m *Task) GetJobID() string

+ func (m *Task) GetProgress() float32

+ func (m *Task) GetStartTime() int32

+ func (m *Task) GetStatus() TaskStatus

+ func (m *Task) GetStatusMessage() string

+ func (m *Task) GetTriggerOwner() string

+ func (m *Task) Reset()

+ func (m *Task) String() string

+ func (task *Task) Zap() zapcore.Field

+ func (task *Task) ZapId() zapcore.Field

+ type TaskChangeEvent struct

+ Job *Job

+ TaskUpdated *Task

+ func (*TaskChangeEvent) Descriptor() ([]byte, []int)

+ func (*TaskChangeEvent) ProtoMessage()

+ func (m *TaskChangeEvent) GetJob() *Job

+ func (m *TaskChangeEvent) GetTaskUpdated() *Task

+ func (m *TaskChangeEvent) Reset()

+ func (m *TaskChangeEvent) String() string

+ type TaskService struct

+ func (h *TaskService) Control(ctx context.Context, in *CtrlCommand, out *CtrlCommandResponse) error

+ type TaskServiceClient interface

+ Control func(ctx context.Context, in *CtrlCommand, opts ...client.CallOption) (*CtrlCommandResponse, error)

+ func NewTaskServiceClient(serviceName string, c client.Client) TaskServiceClient

+ type TaskServiceHandler interface

+ Control func(context.Context, *CtrlCommand, *CtrlCommandResponse) error

+ type TaskStatus int32

+ const TaskStatus_Any

+ const TaskStatus_Error

+ const TaskStatus_Finished

+ const TaskStatus_Idle

+ const TaskStatus_Interrupted

+ const TaskStatus_Paused

+ const TaskStatus_Queued

+ const TaskStatus_Running

+ const TaskStatus_Unknown

+ func (TaskStatus) EnumDescriptor() ([]byte, []int)

+ func (x TaskStatus) String() string

+ type UsersSelector struct

+ All bool

+ Collect bool

+ Query *service.Query

+ Users []*idm.User

+ func (*UsersSelector) Descriptor() ([]byte, []int)

+ func (*UsersSelector) ProtoMessage()

+ func (m *UsersSelector) GetAll() bool

+ func (m *UsersSelector) GetCollect() bool

+ func (m *UsersSelector) GetQuery() *service.Query

+ func (m *UsersSelector) GetUsers() []*idm.User

+ func (m *UsersSelector) Reset()

+ func (m *UsersSelector) String() string

+ func (n *UsersSelector) Filter(input ActionMessage) ActionMessage

+ func (u *UsersSelector) MultipleSelection() bool

+ func (u *UsersSelector) Select(client client.Client, ctx context.Context, objects chan interface{}, ...) error