Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + const IdmEventObjectUser + 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 IdmChangeEventName(objectType string, eventType idm.ChangeEventType) string + func MatchesIdmChangeEvent(eventName string, event *idm.ChangeEvent) bool + 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) MarshalLogObject(encoder zapcore.ObjectEncoder) error + 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 + Time int32 + 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) GetTime() int32 + 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 + NodeEventFilter *NodesSelector + Owner string + Schedule *Schedule + Tasks []*Task + TasksSilentUpdate bool + UserEventFilter *UsersSelector + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (job *Job) MarshalLogObject(encoder zapcore.ObjectEncoder) error + 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) GetNodeEventFilter() *NodesSelector + func (m *Job) GetOwner() string + func (m *Job) GetSchedule() *Schedule + func (m *Job) GetTasks() []*Task + func (m *Job) GetTasksSilentUpdate() bool + func (m *Job) GetUserEventFilter() *UsersSelector + 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 + JobIDs []string + LoadTasks TaskStatus + Owner string + TasksLimit int32 + TasksOffset int32 + TimersOnly bool + func (*ListJobsRequest) Descriptor() ([]byte, []int) + func (*ListJobsRequest) ProtoMessage() + func (m *ListJobsRequest) GetEventsOnly() bool + func (m *ListJobsRequest) GetJobIDs() []string + func (m *ListJobsRequest) GetLoadTasks() TaskStatus + func (m *ListJobsRequest) GetOwner() string + func (m *ListJobsRequest) GetTasksLimit() int32 + func (m *ListJobsRequest) GetTasksOffset() int32 + 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) GetCtxOperationID() string + func (task *Task) MarshalLogObject(encoder zapcore.ObjectEncoder) error + func (task *Task) WithoutLogs() *Task + 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 Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020