jobs

package
v5.0.0-...-b98a0e9 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2024 License: AGPL-3.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IndexedContextKey = "chainIndex"
)

Variables

View Source 
var (
	IdmSelectorType_name = map[int32]string{
		0: "User",
		1: "Role",
		2: "Workspace",
		3: "Acl",
	}
	IdmSelectorType_value = map[string]int32{
		"User":      0,
		"Role":      1,
		"Workspace": 2,
		"Acl":       3,
	}
)

Enum value maps for IdmSelectorType.

View Source 
var (
	DataSourceSelectorType_name = map[int32]string{
		0: "DataSource",
		1: "Object",
	}
	DataSourceSelectorType_value = map[string]int32{
		"DataSource": 0,
		"Object":     1,
	}
)

Enum value maps for DataSourceSelectorType.

View Source 
var (
	ContextMetaFilterType_name = map[int32]string{
		0: "RequestMeta",
		1: "ContextUser",
	}
	ContextMetaFilterType_value = map[string]int32{
		"RequestMeta": 0,
		"ContextUser": 1,
	}
)

Enum value maps for ContextMetaFilterType.

View Source 
var (
	TaskStatus_name = map[int32]string{
		0: "Unknown",
		1: "Idle",
		2: "Running",
		3: "Finished",
		4: "Interrupted",
		5: "Paused",
		6: "Any",
		7: "Error",
		8: "Queued",
	}
	TaskStatus_value = map[string]int32{
		"Unknown":     0,
		"Idle":        1,
		"Running":     2,
		"Finished":    3,
		"Interrupted": 4,
		"Paused":      5,
		"Any":         6,
		"Error":       7,
		"Queued":      8,
	}
)

Enum value maps for TaskStatus.

View Source 
var (
	Command_name = map[int32]string{
		0: "None",
		1: "Pause",
		2: "Resume",
		3: "Stop",
		4: "Delete",
		5: "RunOnce",
		6: "Inactive",
		7: "Active",
	}
	Command_value = map[string]int32{
		"None":     0,
		"Pause":    1,
		"Resume":   2,
		"Stop":     3,
		"Delete":   4,
		"RunOnce":  5,
		"Inactive": 6,
		"Active":   7,
	}
)

Enum value maps for Command.

View Source 
var File_cells_jobs_proto protoreflect.FileDescriptor
View Source 
var JobService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jobs.JobService",
	HandlerType: (*JobServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PutJob",
			Handler:    _JobService_PutJob_Handler,
		},
		{
			MethodName: "GetJob",
			Handler:    _JobService_GetJob_Handler,
		},
		{
			MethodName: "DeleteJob",
			Handler:    _JobService_DeleteJob_Handler,
		},
		{
			MethodName: "PutTask",
			Handler:    _JobService_PutTask_Handler,
		},
		{
			MethodName: "DeleteTasks",
			Handler:    _JobService_DeleteTasks_Handler,
		},
		{
			MethodName: "DetectStuckTasks",
			Handler:    _JobService_DetectStuckTasks_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListJobs",
			Handler:       _JobService_ListJobs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "PutTaskStream",
			Handler:       _JobService_PutTaskStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ListTasks",
			Handler:       _JobService_ListTasks_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-jobs.proto",
}

JobService_ServiceDesc is the grpc.ServiceDesc for JobService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jobs.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Control",
			Handler:    _TaskService_Control_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-jobs.proto",
}

TaskService_ServiceDesc is the grpc.ServiceDesc for TaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func DefaultRunParametersComputer 

func DefaultRunParametersComputer(ctx context.Context, input *ActionMessage, job *Job, event interface{}) map[string]string

func EvaluateFieldBool 

func EvaluateFieldBool(ctx context.Context, input *ActionMessage, value string) (bool, error)

func EvaluateFieldInt 

func EvaluateFieldInt(ctx context.Context, input *ActionMessage, value string) (int, error)

func EvaluateFieldInt64 

func EvaluateFieldInt64(ctx context.Context, input *ActionMessage, value string) (int64, error)

func EvaluateFieldStr 

func EvaluateFieldStr(ctx context.Context, input *ActionMessage, value string) string

EvaluateFieldStr goes through all registered evaluators to modify string value on the fly

func EvaluateFieldStrSlice 

func EvaluateFieldStrSlice(ctx context.Context, input *ActionMessage, values []string) []string

EvaluateFieldStrSlice goes through all registered evaluators to modify string value on the fly

func IdmChangeEventName 

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

IdmChangeEventName builds a string representation for scheduler events for listening to a specific IDM event. For the moment ONLY USER EVENTS are supported

func MatchesIdmChangeEvent 

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

MatchesIdmChangeEvent compares a string representation of scheduler trigger event with an actual idm.ChangeEvent - Only User Events are supported

func MustMarshalAny 

func MustMarshalAny(pb proto.Message) *anypb.Any

MustMarshalAny is an util function to avoid error check

func MustMarshalAnyMultiple 

func MustMarshalAnyMultiple(pbs ...proto.Message) (out []*anypb.Any)

MustMarshalAnyMultiple is an util function to avoid error check

func NewIAction 

func NewIAction(x any) error

func NewIJob 

func NewIJob(x any) error

func NewIJobHook 

func NewIJobHook(x any) error

func NewIJobParameter 

func NewIJobParameter(x any) error

func NodeChangeEventName 

func NodeChangeEventName(event tree.NodeChangeEvent_EventType) string

NodeChangeEventName builds a simple string from a given event type

func ParseNodeChangeEventName 

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

ParseNodeChangeEventName parses the passed string and return the corresponding int32 code if it exists or (-1, false) otherwise

func RegisterClaimsUsernameParser 

func RegisterClaimsUsernameParser(f ClaimsUsernameParser)

func RegisterClientUniqueUser 

func RegisterClientUniqueUser(f ClientUniqueUser)

func RegisterClientUniqueWorkspace 

func RegisterClientUniqueWorkspace(f ClientUniqueWorkspace)

func RegisterConnexionResolver 

func RegisterConnexionResolver(f ConnexionResolver)

func RegisterDefault 

func RegisterDefault(j *Job, service string)

RegisterDefault appends a job to the internal registry

func RegisterFieldEvaluator 

func RegisterFieldEvaluator(evaluator FieldEvaluator)

RegisterFieldEvaluator adds a new evaluator to internal registry

func RegisterJobServiceServer 

func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)

func RegisterNodesFreeStringEvaluator 

func RegisterNodesFreeStringEvaluator(f FreeStringEvaluator)

func RegisterTaskServiceServer 

func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)

Types

type Action 

type Action struct {

	// String Identifier for specific action
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// User-defined label for this action
	Label string `protobuf:"bytes,13,opt,name=Label,proto3" json:"Label,omitempty"`
	// User-defined comment for this action
	Description string `protobuf:"bytes,14,opt,name=Description,proto3" json:"Description,omitempty"`
	// Bypass this action (forward input to output and do nothing)
	Bypass bool `protobuf:"varint,15,opt,name=Bypass,proto3" json:"Bypass,omitempty"`
	// Stop full chain now : do not carry on executing next actions
	BreakAfter bool `protobuf:"varint,16,opt,name=BreakAfter,proto3" json:"BreakAfter,omitempty"`
	// Optional timeout for this action
	Timeout string `protobuf:"bytes,20,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// Nodes Selector
	NodesSelector *NodesSelector `protobuf:"bytes,2,opt,name=NodesSelector,proto3" json:"NodesSelector,omitempty"`
	// Node Filter
	NodesFilter *NodesSelector `protobuf:"bytes,4,opt,name=NodesFilter,proto3" json:"NodesFilter,omitempty"`
	// Users Selector (deprecated in favor of IdmSelector)
	UsersSelector *UsersSelector `protobuf:"bytes,3,opt,name=UsersSelector,proto3" json:"UsersSelector,omitempty"`
	// User Filter (deprecated in favor of IdmSelector)
	UsersFilter *UsersSelector `protobuf:"bytes,5,opt,name=UsersFilter,proto3" json:"UsersFilter,omitempty"`
	// Idm objects collector
	IdmSelector *IdmSelector `protobuf:"bytes,9,opt,name=IdmSelector,proto3" json:"IdmSelector,omitempty"`
	// Idm objects filter
	IdmFilter *IdmSelector `protobuf:"bytes,10,opt,name=IdmFilter,proto3" json:"IdmFilter,omitempty"`
	// DataSource objects collector
	DataSourceSelector *DataSourceSelector `protobuf:"bytes,17,opt,name=DataSourceSelector,proto3" json:"DataSourceSelector,omitempty"`
	// DataSource objects filter
	DataSourceFilter *DataSourceSelector `protobuf:"bytes,18,opt,name=DataSourceFilter,proto3" json:"DataSourceFilter,omitempty"`
	// Previous action output filter
	ActionOutputFilter *ActionOutputFilter `protobuf:"bytes,6,opt,name=ActionOutputFilter,proto3" json:"ActionOutputFilter,omitempty"`
	// Metadata policy-based filter
	ContextMetaFilter *ContextMetaFilter `protobuf:"bytes,11,opt,name=ContextMetaFilter,proto3" json:"ContextMetaFilter,omitempty"`
	// Filter on specific triggers
	TriggerFilter *TriggerFilter `protobuf:"bytes,19,opt,name=TriggerFilter,proto3" json:"TriggerFilter,omitempty"`
	// Collect/select values from JsonBody
	DataSelector *DataSelector `protobuf:"bytes,22,opt,name=DataSelector,proto3" json:"DataSelector,omitempty"`
	// Filter values from JsonBody
	DataFilter *DataSelector `protobuf:"bytes,23,opt,name=DataFilter,proto3" json:"DataFilter,omitempty"`
	// Defined parameters for this action
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// Other actions to perform after this one is finished,
	// using the Output of this action as Input for the next.
	// If there are many, it is considered they can be triggered
	// in parallel
	ChainedActions []*Action `protobuf:"bytes,8,rep,name=ChainedActions,proto3" json:"ChainedActions,omitempty"`
	// If any Filter is used, next actions can be triggered on Failure
	// This adds ability to create conditional Yes/No branches
	FailedFilterActions []*Action `protobuf:"bytes,12,rep,name=FailedFilterActions,proto3" json:"FailedFilterActions,omitempty"`
	// CollectAction adds starts another chain after the whole ChainedAction/FailedFilterActions have been performed
	MergeAction *Action `protobuf:"bytes,21,opt,name=MergeAction,proto3" json:"MergeAction,omitempty"`
	// contains filtered or unexported fields
}

func (*Action) ApplyFilters 

func (a *Action) ApplyFilters(ctx context.Context, ff []InputFilter, input *ActionMessage) (output *ActionMessage, excluded *ActionMessage, passThrough bool)

func (*Action) BuildTaskActionPath 

func (a *Action) BuildTaskActionPath(ctx context.Context, suffix string, indexTag ...int) (string, context.Context)

func (*Action) CollectSelector 

func (a *Action) CollectSelector(ctx context.Context, selector InputSelector, input *ActionMessage, output chan *ActionMessage, done chan bool, errors chan error)

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) FanOutSelector 

func (a *Action) FanOutSelector(ctx context.Context, selector InputSelector, input *ActionMessage, output chan *ActionMessage, done chan bool, errors chan error)

func (*Action) FanToNext 

func (a *Action) FanToNext(ctx context.Context, index int, input *ActionMessage, output chan *ActionMessage, errors chan error, done chan bool)

func (*Action) GetActionOutputFilter 

func (x *Action) GetActionOutputFilter() *ActionOutputFilter

func (*Action) GetBreakAfter 

func (x *Action) GetBreakAfter() bool

func (*Action) GetBypass 

func (x *Action) GetBypass() bool

func (*Action) GetChainedActions 

func (x *Action) GetChainedActions() []*Action

func (*Action) GetContextMetaFilter 

func (x *Action) GetContextMetaFilter() *ContextMetaFilter

func (*Action) GetDataFilter 

func (x *Action) GetDataFilter() *DataSelector

func (*Action) GetDataSelector 

func (x *Action) GetDataSelector() *DataSelector

func (*Action) GetDataSourceFilter 

func (x *Action) GetDataSourceFilter() *DataSourceSelector

func (*Action) GetDataSourceSelector 

func (x *Action) GetDataSourceSelector() *DataSourceSelector

func (*Action) GetDescription 

func (x *Action) GetDescription() string

func (*Action) GetFailedFilterActions 

func (x *Action) GetFailedFilterActions() []*Action

func (*Action) GetID 

func (x *Action) GetID() string

func (*Action) GetIdmFilter 

func (x *Action) GetIdmFilter() *IdmSelector

func (*Action) GetIdmSelector 

func (x *Action) GetIdmSelector() *IdmSelector

func (*Action) GetLabel 

func (x *Action) GetLabel() string

func (*Action) GetMergeAction 

func (x *Action) GetMergeAction() *Action

func (*Action) GetNodesFilter 

func (x *Action) GetNodesFilter() *NodesSelector

func (*Action) GetNodesSelector 

func (x *Action) GetNodesSelector() *NodesSelector

func (*Action) GetParameters 

func (x *Action) GetParameters() map[string]string

func (*Action) GetTimeout 

func (x *Action) GetTimeout() string

func (*Action) GetTriggerFilter 

func (x *Action) GetTriggerFilter() *TriggerFilter

func (*Action) GetUsersFilter 

func (x *Action) GetUsersFilter() *UsersSelector

func (*Action) GetUsersSelector 

func (x *Action) GetUsersSelector() *UsersSelector

func (*Action) HasSelectors 

func (a *Action) HasSelectors() bool

func (*Action) MarshalLogObject 

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

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

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

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) SetActionOutputFilter 

func (x *Action) SetActionOutputFilter(v *ActionOutputFilter)

func (*Action) SetBreakAfter 

func (x *Action) SetBreakAfter(v bool)

func (*Action) SetBypass 

func (x *Action) SetBypass(v bool)

func (*Action) SetChainedActions 

func (x *Action) SetChainedActions(v []*Action)

func (*Action) SetContextMetaFilter 

func (x *Action) SetContextMetaFilter(v *ContextMetaFilter)

func (*Action) SetDataFilter 

func (x *Action) SetDataFilter(v *DataSelector)

func (*Action) SetDataSelector 

func (x *Action) SetDataSelector(v *DataSelector)

func (*Action) SetDataSourceFilter 

func (x *Action) SetDataSourceFilter(v *DataSourceSelector)

func (*Action) SetDataSourceSelector 

func (x *Action) SetDataSourceSelector(v *DataSourceSelector)

func (*Action) SetDescription 

func (x *Action) SetDescription(v string)

func (*Action) SetFailedFilterActions 

func (x *Action) SetFailedFilterActions(v []*Action)

func (*Action) SetID 

func (x *Action) SetID(v string)

func (*Action) SetIdmFilter 

func (x *Action) SetIdmFilter(v *IdmSelector)

func (*Action) SetIdmSelector 

func (x *Action) SetIdmSelector(v *IdmSelector)

func (*Action) SetLabel 

func (x *Action) SetLabel(v string)

func (*Action) SetMergeAction 

func (x *Action) SetMergeAction(v *Action)

func (*Action) SetNodesFilter 

func (x *Action) SetNodesFilter(v *NodesSelector)

func (*Action) SetNodesSelector 

func (x *Action) SetNodesSelector(v *NodesSelector)

func (*Action) SetParameters 

func (x *Action) SetParameters(v map[string]string)

func (*Action) SetTimeout 

func (x *Action) SetTimeout(v string)

func (*Action) SetTriggerFilter 

func (x *Action) SetTriggerFilter(v *TriggerFilter)

func (*Action) SetUsersFilter 

func (x *Action) SetUsersFilter(v *UsersSelector)

func (*Action) SetUsersSelector 

func (x *Action) SetUsersSelector(v *UsersSelector)

func (*Action) String 

func (x *Action) String() string

func (*Action) ToMessages 

func (a *Action) ToMessages(startMessage *ActionMessage, ctx context.Context, output, failedFilter chan *ActionMessage, errors chan error, done chan bool)

func (*Action) Zap 

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

Zap simply returns a zapcore.Field object populated with this Action under a standard key

func (*Action) ZapId 

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

ZapId simply calls zap.String() with ActionId standard key and this Action id

type ActionGetter 

type ActionGetter interface {
	GetID() string
	GetLabel() string
	GetDescription() string
	GetBypass() bool
	GetBreakAfter() bool
	GetTimeout() string
	GetNodesSelector() *NodesSelector
	GetNodesFilter() *NodesSelector
	GetUsersSelector() *UsersSelector
	GetUsersFilter() *UsersSelector
	GetIdmSelector() *IdmSelector
	GetIdmFilter() *IdmSelector
	GetDataSourceSelector() *DataSourceSelector
	GetDataSourceFilter() *DataSourceSelector
	GetActionOutputFilter() *ActionOutputFilter
	GetContextMetaFilter() *ContextMetaFilter
	GetTriggerFilter() *TriggerFilter
	GetDataSelector() *DataSelector
	GetDataFilter() *DataSelector
	GetParameters() map[string]string
	GetChainedActions() []*Action
	GetFailedFilterActions() []*Action
	GetMergeAction() *Action
}

type ActionLog 

type ActionLog struct {
	Action        *Action        `protobuf:"bytes,1,opt,name=Action,proto3" json:"Action,omitempty"`
	InputMessage  *ActionMessage `protobuf:"bytes,2,opt,name=InputMessage,proto3" json:"InputMessage,omitempty"`
	OutputMessage *ActionMessage `protobuf:"bytes,3,opt,name=OutputMessage,proto3" json:"OutputMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionLog) Descriptor deprecated 

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

Deprecated: Use ActionLog.ProtoReflect.Descriptor instead.

func (*ActionLog) GetAction 

func (x *ActionLog) GetAction() *Action

func (*ActionLog) GetInputMessage 

func (x *ActionLog) GetInputMessage() *ActionMessage

func (*ActionLog) GetOutputMessage 

func (x *ActionLog) GetOutputMessage() *ActionMessage

func (*ActionLog) ProtoMessage 

func (*ActionLog) ProtoMessage()

func (*ActionLog) ProtoReflect 

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

func (*ActionLog) Reset 

func (x *ActionLog) Reset()

func (*ActionLog) String 

func (x *ActionLog) String() string

type ActionMessage 

type ActionMessage struct {

	// Initial event that triggered the Job
	Event *anypb.Any `protobuf:"bytes,1,opt,name=Event,proto3" json:"Event,omitempty"`
	// One or more Node
	Nodes []*tree.Node `protobuf:"bytes,2,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	// One or more User
	Users []*idm.User `protobuf:"bytes,3,rep,name=Users,proto3" json:"Users,omitempty"`
	// One or more Role
	Roles []*idm.Role `protobuf:"bytes,6,rep,name=Roles,proto3" json:"Roles,omitempty"`
	// One or more Workspace
	Workspaces []*idm.Workspace `protobuf:"bytes,7,rep,name=Workspaces,proto3" json:"Workspaces,omitempty"`
	// One or more ACL
	Acls []*idm.ACL `protobuf:"bytes,8,rep,name=Acls,proto3" json:"Acls,omitempty"`
	// One or more Activity
	Activities []*activity.Object `protobuf:"bytes,4,rep,name=Activities,proto3" json:"Activities,omitempty"`
	// One or more DataSource
	DataSources []*object.DataSource `protobuf:"bytes,9,rep,name=DataSources,proto3" json:"DataSources,omitempty"`
	// Stack of ActionOutput messages appended by all previous actions
	OutputChain []*ActionOutput `protobuf:"bytes,5,rep,name=OutputChain,proto3" json:"OutputChain,omitempty"`
	// contains filtered or unexported fields
}

Message passed along from one action to another, main properties are modified by the various actions. OutputChain is being stacked up when passing through actions

func (*ActionMessage) AppendOutput 

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

func (*ActionMessage) AsRunError 

func (a *ActionMessage) AsRunError(e error) (*ActionMessage, error)

AsRunError combines an input.WithError and the error itself

func (*ActionMessage) Clone 

func (a *ActionMessage) Clone() *ActionMessage

func (*ActionMessage) Descriptor deprecated 

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

Deprecated: Use ActionMessage.ProtoReflect.Descriptor instead.

func (*ActionMessage) EventFromAny 

func (a *ActionMessage) EventFromAny() (interface{}, error)

EventFromAny loads and unmarshal event from an anypb value

func (*ActionMessage) GetAcls 

func (x *ActionMessage) GetAcls() []*idm.ACL

func (*ActionMessage) GetActivities 

func (x *ActionMessage) GetActivities() []*activity.Object

func (*ActionMessage) GetDataSources 

func (x *ActionMessage) GetDataSources() []*object.DataSource

func (*ActionMessage) GetEvent 

func (x *ActionMessage) GetEvent() *anypb.Any

func (*ActionMessage) GetLastOutput 

func (a *ActionMessage) GetLastOutput() *ActionOutput

func (*ActionMessage) GetNodes 

func (x *ActionMessage) GetNodes() []*tree.Node

func (*ActionMessage) GetOutputChain 

func (x *ActionMessage) GetOutputChain() []*ActionOutput

func (*ActionMessage) GetOutputs 

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

func (*ActionMessage) GetRoles 

func (x *ActionMessage) GetRoles() []*idm.Role

func (*ActionMessage) GetUsers 

func (x *ActionMessage) GetUsers() []*idm.User

func (*ActionMessage) GetWorkspaces 

func (x *ActionMessage) GetWorkspaces() []*idm.Workspace

func (*ActionMessage) MarshalLogObject 

func (a *ActionMessage) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (*ActionMessage) ProtoMessage 

func (*ActionMessage) ProtoMessage()

func (*ActionMessage) ProtoReflect 

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

func (*ActionMessage) Reset 

func (x *ActionMessage) Reset()

func (*ActionMessage) ScanVar 

func (a *ActionMessage) ScanVar(name string, output interface{}) error

func (*ActionMessage) StackedVars 

func (a *ActionMessage) StackedVars(expected ...string) map[string]interface{}

func (*ActionMessage) StackedVarsKeys 

func (a *ActionMessage) StackedVarsKeys() (keys []string)

func (*ActionMessage) String 

func (x *ActionMessage) String() string

func (*ActionMessage) WithAcl 

func (a *ActionMessage) WithAcl(acl *idm.ACL) *ActionMessage

func (*ActionMessage) WithAcls 

func (a *ActionMessage) WithAcls(aa ...*idm.ACL) *ActionMessage

func (*ActionMessage) WithDataSource 

func (a *ActionMessage) WithDataSource(ds *object.DataSource) *ActionMessage

func (*ActionMessage) WithDataSources 

func (a *ActionMessage) WithDataSources(ds ...*object.DataSource) *ActionMessage

func (*ActionMessage) WithError 

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

func (*ActionMessage) WithIgnore 

func (a *ActionMessage) WithIgnore() *ActionMessage

func (*ActionMessage) WithNode 

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

func (*ActionMessage) WithNodes 

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

func (*ActionMessage) WithOutput 

func (a *ActionMessage) WithOutput(output *ActionOutput) *ActionMessage

func (*ActionMessage) WithRole 

func (a *ActionMessage) WithRole(r *idm.Role) *ActionMessage

func (*ActionMessage) WithRoles 

func (a *ActionMessage) WithRoles(r ...*idm.Role) *ActionMessage

func (*ActionMessage) WithUser 

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

func (*ActionMessage) WithUsers 

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

func (*ActionMessage) WithWorkspace 

func (a *ActionMessage) WithWorkspace(ws *idm.Workspace) *ActionMessage

func (*ActionMessage) WithWorkspaces 

func (a *ActionMessage) WithWorkspaces(ws ...*idm.Workspace) *ActionMessage

type ActionOutput 

type ActionOutput struct {

	// True if action succeeded
	Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	// Arbitrary bytes sequence
	RawBody []byte `protobuf:"bytes,2,opt,name=RawBody,proto3" json:"RawBody,omitempty"`
	// Arbitrary string
	StringBody string `protobuf:"bytes,3,opt,name=StringBody,proto3" json:"StringBody,omitempty"`
	// Arbitrary JSON-encoded bytes
	JsonBody []byte `protobuf:"bytes,4,opt,name=JsonBody,proto3" json:"JsonBody,omitempty"`
	// Error
	ErrorString string `protobuf:"bytes,5,opt,name=ErrorString,proto3" json:"ErrorString,omitempty"`
	// If action was returned WithIgnore()
	Ignored bool `protobuf:"varint,6,opt,name=Ignored,proto3" json:"Ignored,omitempty"`
	// Time taken to run the action
	Time int32 `protobuf:"varint,7,opt,name=Time,proto3" json:"Time,omitempty"`
	// Vars container, values are json-encoded.
	Vars map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

Standard output of an action. Success value is required other are optional

func (*ActionOutput) Descriptor deprecated 

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

Deprecated: Use ActionOutput.ProtoReflect.Descriptor instead.

func (*ActionOutput) FillVars 

func (m *ActionOutput) FillVars(vv map[string]interface{}, expected ...string)

FillVars append existing, json-decoded values to the input map

func (*ActionOutput) GetErrorString 

func (x *ActionOutput) GetErrorString() string

func (*ActionOutput) GetIgnored 

func (x *ActionOutput) GetIgnored() bool

func (*ActionOutput) GetJsonBody 

func (x *ActionOutput) GetJsonBody() []byte

func (*ActionOutput) GetRawBody 

func (x *ActionOutput) GetRawBody() []byte

func (*ActionOutput) GetStringBody 

func (x *ActionOutput) GetStringBody() string

func (*ActionOutput) GetSuccess 

func (x *ActionOutput) GetSuccess() bool

func (*ActionOutput) GetTime 

func (x *ActionOutput) GetTime() int32

func (*ActionOutput) GetVars 

func (x *ActionOutput) GetVars() map[string]string

func (*ActionOutput) JsonAsValue 

func (m *ActionOutput) JsonAsValue() configx.Values

JsonAsValue loads JsonBody into a configx.Value type to ease golang templating TODO - Recheck Jobs using this, it's now equivalent to JsonAsValues()

func (*ActionOutput) JsonAsValues 

func (m *ActionOutput) JsonAsValues() configx.Values

JsonAsValues loads JsonBody into a configx.Values type to ease golang templating

func (*ActionOutput) JsonObject 

func (m *ActionOutput) JsonObject() (map[string]interface{}, error)

func (*ActionOutput) JsonSliceOfInterfaces 

func (m *ActionOutput) JsonSliceOfInterfaces() ([]interface{}, error)

func (*ActionOutput) JsonSliceOfObjects 

func (m *ActionOutput) JsonSliceOfObjects() ([]map[string]interface{}, error)

func (*ActionOutput) LogVarsWithLimit 

func (m *ActionOutput) LogVarsWithLimit(vv map[string]interface{}, jsonSizeLimit int)

LogVarsWithLimit does the same as FillVars but does not json-decode values and truncate huge vars

func (*ActionOutput) MarshalLogObject 

func (m *ActionOutput) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore Marshaler interface

func (*ActionOutput) ProtoMessage 

func (*ActionOutput) ProtoMessage()

func (*ActionOutput) ProtoReflect 

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

func (*ActionOutput) Reset 

func (x *ActionOutput) Reset()

func (*ActionOutput) SetVar 

func (m *ActionOutput) SetVar(key string, value interface{})

SetVar json-encodes the value and store it in the Vars map

func (*ActionOutput) String 

func (x *ActionOutput) String() string

type ActionOutputFilter 

type ActionOutputFilter struct {

	// Query built from ActionOutputSingleQuery
	Query *service.Query `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"`
	// Selector custom label
	Label string `protobuf:"bytes,2,opt,name=Label,proto3" json:"Label,omitempty"`
	// Selector additional description
	Description string `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"`
	// contains filtered or unexported fields
}

ActionOutputFilter can be used to filter last message output

func (*ActionOutputFilter) Descriptor deprecated 

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

Deprecated: Use ActionOutputFilter.ProtoReflect.Descriptor instead.

func (*ActionOutputFilter) Filter 

func (n *ActionOutputFilter) Filter(ctx context.Context, input *ActionMessage) (*ActionMessage, *ActionMessage, bool)

func (*ActionOutputFilter) FilterID 

func (n *ActionOutputFilter) FilterID() string

func (*ActionOutputFilter) GetDescription 

func (x *ActionOutputFilter) GetDescription() string

func (*ActionOutputFilter) GetLabel 

func (x *ActionOutputFilter) GetLabel() string

func (*ActionOutputFilter) GetQuery 

func (x *ActionOutputFilter) GetQuery() *service.Query

func (*ActionOutputFilter) ProtoMessage 

func (*ActionOutputFilter) ProtoMessage()

func (*ActionOutputFilter) ProtoReflect 

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

func (*ActionOutputFilter) Reset 

func (x *ActionOutputFilter) Reset()

func (*ActionOutputFilter) String 

func (x *ActionOutputFilter) String() string

type ActionOutputSingleQuery 

type ActionOutputSingleQuery struct {

	// Check if ActionOutput has success
	IsSuccess bool `protobuf:"varint,1,opt,name=IsSuccess,proto3" json:"IsSuccess,omitempty"`
	// Occurrence of string in StringBody or JsonBody (as string)
	StringBodyRegexp string `protobuf:"bytes,2,opt,name=StringBodyRegexp,proto3" json:"StringBodyRegexp,omitempty"`
	// StringBody or JsonBody size bigger than
	StringBodySizeGreaterThan int32 `protobuf:"varint,3,opt,name=StringBodySizeGreaterThan,proto3" json:"StringBodySizeGreaterThan,omitempty"`
	// StringBody or JsonBody size smaller than
	StringBodySizeSmallerThan int32 `protobuf:"varint,4,opt,name=StringBodySizeSmallerThan,proto3" json:"StringBodySizeSmallerThan,omitempty"`
	// Exact match of StringBody or JsonBody (as string)
	JsonBodyRegexp string `protobuf:"bytes,5,opt,name=JsonBodyRegexp,proto3" json:"JsonBodyRegexp,omitempty"`
	// Check existence of key in json body
	JsonBodyHasKey string `protobuf:"bytes,6,opt,name=JsonBodyHasKey,proto3" json:"JsonBodyHasKey,omitempty"`
	// StringBody or JsonBody size bigger than
	JsonBodySizeGreaterThan int32 `protobuf:"varint,7,opt,name=JsonBodySizeGreaterThan,proto3" json:"JsonBodySizeGreaterThan,omitempty"`
	// StringBody or JsonBody size smaller than
	JsonBodySizeSmallerThan int32 `protobuf:"varint,8,opt,name=JsonBodySizeSmallerThan,proto3" json:"JsonBodySizeSmallerThan,omitempty"`
	// Time taken greater than
	TaskTimeGt int32 `protobuf:"varint,9,opt,name=TaskTimeGt,proto3" json:"TaskTimeGt,omitempty"`
	// Time taken shorter than
	TaskTimeLt int32 `protobuf:"varint,10,opt,name=TaskTimeLt,proto3" json:"TaskTimeLt,omitempty"`
	// Check occurrence on error string
	ErrorStringRegexp string `protobuf:"bytes,11,opt,name=ErrorStringRegexp,proto3" json:"ErrorStringRegexp,omitempty"`
	// FreeCondition can be built using templates or gval
	FreeCondition string `protobuf:"bytes,13,opt,name=FreeCondition,proto3" json:"FreeCondition,omitempty"`
	// Invert condition
	Not bool `protobuf:"varint,12,opt,name=Not,proto3" json:"Not,omitempty"`
	// contains filtered or unexported fields
}

ActionOutputSingleQuery provides a unitary query to filter ActionOutput messages

func (*ActionOutputSingleQuery) Descriptor deprecated 

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

Deprecated: Use ActionOutputSingleQuery.ProtoReflect.Descriptor instead.

func (*ActionOutputSingleQuery) GetErrorStringRegexp 

func (x *ActionOutputSingleQuery) GetErrorStringRegexp() string

func (*ActionOutputSingleQuery) GetFreeCondition 

func (x *ActionOutputSingleQuery) GetFreeCondition() string

func (*ActionOutputSingleQuery) GetIsSuccess 

func (x *ActionOutputSingleQuery) GetIsSuccess() bool

func (*ActionOutputSingleQuery) GetJsonBodyHasKey 

func (x *ActionOutputSingleQuery) GetJsonBodyHasKey() string

func (*ActionOutputSingleQuery) GetJsonBodyRegexp 

func (x *ActionOutputSingleQuery) GetJsonBodyRegexp() string

func (*ActionOutputSingleQuery) GetJsonBodySizeGreaterThan 

func (x *ActionOutputSingleQuery) GetJsonBodySizeGreaterThan() int32

func (*ActionOutputSingleQuery) GetJsonBodySizeSmallerThan 

func (x *ActionOutputSingleQuery) GetJsonBodySizeSmallerThan() int32

func (*ActionOutputSingleQuery) GetNot 

func (x *ActionOutputSingleQuery) GetNot() bool

func (*ActionOutputSingleQuery) GetStringBodyRegexp 

func (x *ActionOutputSingleQuery) GetStringBodyRegexp() string

func (*ActionOutputSingleQuery) GetStringBodySizeGreaterThan 

func (x *ActionOutputSingleQuery) GetStringBodySizeGreaterThan() int32

func (*ActionOutputSingleQuery) GetStringBodySizeSmallerThan 

func (x *ActionOutputSingleQuery) GetStringBodySizeSmallerThan() int32

func (*ActionOutputSingleQuery) GetTaskTimeGt 

func (x *ActionOutputSingleQuery) GetTaskTimeGt() int32

func (*ActionOutputSingleQuery) GetTaskTimeLt 

func (x *ActionOutputSingleQuery) GetTaskTimeLt() int32

func (*ActionOutputSingleQuery) ProtoMessage 

func (*ActionOutputSingleQuery) ProtoMessage()

func (*ActionOutputSingleQuery) ProtoReflect 

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

func (*ActionOutputSingleQuery) Reset 

func (x *ActionOutputSingleQuery) Reset()

func (*ActionOutputSingleQuery) String 

func (x *ActionOutputSingleQuery) String() string

type ActionSetter 

type ActionSetter interface {
	SetID(string)
	SetLabel(string)
	SetDescription(string)
	SetBypass(bool)
	SetBreakAfter(bool)
	SetTimeout(string)
	SetNodesSelector(*NodesSelector)
	SetNodesFilter(*NodesSelector)
	SetUsersSelector(*UsersSelector)
	SetUsersFilter(*UsersSelector)
	SetIdmSelector(*IdmSelector)
	SetIdmFilter(*IdmSelector)
	SetDataSourceSelector(*DataSourceSelector)
	SetDataSourceFilter(*DataSourceSelector)
	SetActionOutputFilter(*ActionOutputFilter)
	SetContextMetaFilter(*ContextMetaFilter)
	SetTriggerFilter(*TriggerFilter)
	SetDataSelector(*DataSelector)
	SetDataFilter(*DataSelector)
	SetParameters(map[string]string)
	SetChainedActions([]*Action)
	SetFailedFilterActions([]*Action)
	SetMergeAction(*Action)
}

type ClaimsUsernameParser 

type ClaimsUsernameParser func(ctx context.Context) (string, claim.Claims)

type ClientUniqueUser 

type ClientUniqueUser func(ctx context.Context, login string, uuid string, queries ...*idm.UserSingleQuery) (user *idm.User, err error)

type ClientUniqueWorkspace 

type ClientUniqueWorkspace func(ctx context.Context, wsUuid string, wsSlug string, queries ...*idm.WorkspaceSingleQuery) (*idm.Workspace, error)

type Command 

type Command int32
const (
	Command_None     Command = 0
	Command_Pause    Command = 1
	Command_Resume   Command = 2
	Command_Stop     Command = 3
	Command_Delete   Command = 4
	Command_RunOnce  Command = 5
	Command_Inactive Command = 6
	Command_Active   Command = 7
)

func (Command) Descriptor 

func (Command) Descriptor() protoreflect.EnumDescriptor

func (Command) Enum 

func (x Command) Enum() *Command

func (Command) EnumDescriptor deprecated 

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

Deprecated: Use Command.Descriptor instead.

func (Command) Number 

func (x Command) Number() protoreflect.EnumNumber

func (Command) String 

func (x Command) String() string

func (Command) Type 

func (Command) Type() protoreflect.EnumType

type ConnexionResolver 

type ConnexionResolver func(ctx context.Context, serviceName string) grpc2.ClientConnInterface

type ContextMetaFilter 

type ContextMetaFilter struct {

	// Type of context filter
	Type ContextMetaFilterType `protobuf:"varint,1,opt,name=Type,proto3,enum=jobs.ContextMetaFilterType" json:"Type,omitempty"`
	// Can be built with ContextMetaSingleQuery
	Query *service.Query `protobuf:"bytes,2,opt,name=Query,proto3" json:"Query,omitempty"`
	// Selector custom label
	Label string `protobuf:"bytes,3,opt,name=Label,proto3" json:"Label,omitempty"`
	// Selector additional description
	Description string `protobuf:"bytes,4,opt,name=Description,proto3" json:"Description,omitempty"`
	// contains filtered or unexported fields
}

PolicyContextFilter can be used to filter request metadata

func (*ContextMetaFilter) Descriptor deprecated 

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

Deprecated: Use ContextMetaFilter.ProtoReflect.Descriptor instead.

func (*ContextMetaFilter) Filter 

func (m *ContextMetaFilter) Filter(ctx context.Context, input *ActionMessage) (*ActionMessage, *ActionMessage, bool)

func (*ContextMetaFilter) FilterID 

func (m *ContextMetaFilter) FilterID() string

func (*ContextMetaFilter) GetDescription 

func (x *ContextMetaFilter) GetDescription() string

func (*ContextMetaFilter) GetLabel 

func (x *ContextMetaFilter) GetLabel() string

func (*ContextMetaFilter) GetQuery 

func (x *ContextMetaFilter) GetQuery() *service.Query

func (*ContextMetaFilter) GetType 

func (x *ContextMetaFilter) GetType() ContextMetaFilterType

func (*ContextMetaFilter) ProtoMessage 

func (*ContextMetaFilter) ProtoMessage()

func (*ContextMetaFilter) ProtoReflect 

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

func (*ContextMetaFilter) Reset 

func (x *ContextMetaFilter) Reset()

func (*ContextMetaFilter) String 

func (x *ContextMetaFilter) String() string

type ContextMetaFilterType 

type ContextMetaFilterType int32
const (
	ContextMetaFilterType_RequestMeta ContextMetaFilterType = 0
	ContextMetaFilterType_ContextUser ContextMetaFilterType = 1
)

func (ContextMetaFilterType) Descriptor 

func (ContextMetaFilterType) Descriptor() protoreflect.EnumDescriptor

func (ContextMetaFilterType) Enum 

func (x ContextMetaFilterType) Enum() *ContextMetaFilterType

func (ContextMetaFilterType) EnumDescriptor deprecated 

func (ContextMetaFilterType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ContextMetaFilterType.Descriptor instead.

func (ContextMetaFilterType) Number 

func (x ContextMetaFilterType) Number() protoreflect.EnumNumber

func (ContextMetaFilterType) String 

func (x ContextMetaFilterType) String() string

func (ContextMetaFilterType) Type 

func (ContextMetaFilterType) Type() protoreflect.EnumType

type ContextMetaSingleQuery 

type ContextMetaSingleQuery struct {

	// Field on which the Condition test will be applied
	FieldName string `protobuf:"bytes,1,opt,name=FieldName,proto3" json:"FieldName,omitempty"`
	// One of the available conditions as defined for Security Policies
	Condition *idm.PolicyCondition `protobuf:"bytes,2,opt,name=Condition,proto3" json:"Condition,omitempty"`
	// contains filtered or unexported fields
}

ContextMetaSingleQuery uses idm.PolicyCondition

func (*ContextMetaSingleQuery) Descriptor deprecated 

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

Deprecated: Use ContextMetaSingleQuery.ProtoReflect.Descriptor instead.

func (*ContextMetaSingleQuery) GetCondition 

func (x *ContextMetaSingleQuery) GetCondition() *idm.PolicyCondition

func (*ContextMetaSingleQuery) GetFieldName 

func (x *ContextMetaSingleQuery) GetFieldName() string

func (*ContextMetaSingleQuery) ProtoMessage 

func (*ContextMetaSingleQuery) ProtoMessage()

func (*ContextMetaSingleQuery) ProtoReflect 

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

func (*ContextMetaSingleQuery) Reset 

func (x *ContextMetaSingleQuery) Reset()

func (*ContextMetaSingleQuery) String 

func (x *ContextMetaSingleQuery) String() string

type CtrlCommand 

type CtrlCommand struct {

	// Type of command to send (None, Pause, Resume, Stop, Delete, RunOnce, Inactive, Active)
	Cmd Command `protobuf:"varint,1,opt,name=Cmd,proto3,enum=jobs.Command" json:"Cmd,omitempty"`
	// Id of the job
	JobId string `protobuf:"bytes,2,opt,name=JobId,proto3" json:"JobId,omitempty"`
	// Id of the associated task
	TaskId string `protobuf:"bytes,3,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	// Owner of the job
	OwnerId string `protobuf:"bytes,4,opt,name=OwnerId,proto3" json:"OwnerId,omitempty"`
	// Parameters used for RunOnce command
	RunParameters map[string]string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

Command sent to control a job or a task

func (*CtrlCommand) Descriptor deprecated 

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

Deprecated: Use CtrlCommand.ProtoReflect.Descriptor instead.

func (*CtrlCommand) GetCmd 

func (x *CtrlCommand) GetCmd() Command

func (*CtrlCommand) GetJobId 

func (x *CtrlCommand) GetJobId() string

func (*CtrlCommand) GetOwnerId 

func (x *CtrlCommand) GetOwnerId() string

func (*CtrlCommand) GetRunParameters 

func (x *CtrlCommand) GetRunParameters() map[string]string

func (*CtrlCommand) GetTaskId 

func (x *CtrlCommand) GetTaskId() string

func (*CtrlCommand) ProtoMessage 

func (*CtrlCommand) ProtoMessage()

func (*CtrlCommand) ProtoReflect 

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

func (*CtrlCommand) Reset 

func (x *CtrlCommand) Reset()

func (*CtrlCommand) String 

func (x *CtrlCommand) String() string

type CtrlCommandResponse 

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

Response to the CtrlCommand

func (*CtrlCommandResponse) Descriptor deprecated 

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

Deprecated: Use CtrlCommandResponse.ProtoReflect.Descriptor instead.

func (*CtrlCommandResponse) GetMsg 

func (x *CtrlCommandResponse) GetMsg() string

func (*CtrlCommandResponse) ProtoMessage 

func (*CtrlCommandResponse) ProtoMessage()

func (*CtrlCommandResponse) ProtoReflect 

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

func (*CtrlCommandResponse) Reset 

func (x *CtrlCommandResponse) Reset()

func (*CtrlCommandResponse) String 

func (x *CtrlCommandResponse) String() string

type DataSelector 

type DataSelector struct {

	// Selector custom label
	Label string `protobuf:"bytes,1,opt,name=Label,proto3" json:"Label,omitempty"`
	// Selector additional description
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	// Query used to compute output object or list of objects
	Query *service.Query `protobuf:"bytes,3,opt,name=Query,proto3" json:"Query,omitempty"`
	// Collect results
	Collect bool `protobuf:"varint,4,opt,name=Collect,proto3" json:"Collect,omitempty"`
	// Ignore query and just fan out input.LastOutput.JsonBody
	FanOutInput bool `protobuf:"varint,5,opt,name=FanOutInput,proto3" json:"FanOutInput,omitempty"`
	// Optional Timeout for this selector
	Timeout string `protobuf:"bytes,6,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// Clear previous selection
	ClearInput bool `protobuf:"varint,7,opt,name=ClearInput,proto3" json:"ClearInput,omitempty"`
	// contains filtered or unexported fields
}

func (*DataSelector) ApplyClearInput 

func (x *DataSelector) ApplyClearInput(msg *ActionMessage) *ActionMessage

func (*DataSelector) Descriptor deprecated 

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

Deprecated: Use DataSelector.ProtoReflect.Descriptor instead.

func (*DataSelector) GetClearInput 

func (x *DataSelector) GetClearInput() bool

func (*DataSelector) GetCollect 

func (x *DataSelector) GetCollect() bool

func (*DataSelector) GetDescription 

func (x *DataSelector) GetDescription() string

func (*DataSelector) GetFanOutInput 

func (x *DataSelector) GetFanOutInput() bool

func (*DataSelector) GetLabel 

func (x *DataSelector) GetLabel() string

func (*DataSelector) GetQuery 

func (x *DataSelector) GetQuery() *service.Query

func (*DataSelector) GetTimeout 

func (x *DataSelector) GetTimeout() string

func (*DataSelector) MultipleSelection 

func (x *DataSelector) MultipleSelection() bool

func (*DataSelector) PreParseJsonPath 

func (x *DataSelector) PreParseJsonPath(jp string) (input, jsonBody, vars bool, expectedVars []string)

func (*DataSelector) ProtoMessage 

func (*DataSelector) ProtoMessage()

func (*DataSelector) ProtoReflect 

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

func (*DataSelector) Reset 

func (x *DataSelector) Reset()

func (*DataSelector) Select 

func (x *DataSelector) Select(ctx context.Context, input *ActionMessage, objects chan interface{}, done chan bool) error

func (*DataSelector) SelectorID 

func (x *DataSelector) SelectorID() string

func (*DataSelector) SelectorLabel 

func (x *DataSelector) SelectorLabel() string

func (*DataSelector) String 

func (x *DataSelector) String() string

type DataSelectorSingleQuery 

type DataSelectorSingleQuery struct {

	// Perform a JsonPath query. Input data exposes JsonBody and Vars.
	JsonPath string `protobuf:"bytes,1,opt,name=JsonPath,proto3" json:"JsonPath,omitempty"`
	// contains filtered or unexported fields
}

func (*DataSelectorSingleQuery) Descriptor deprecated 

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

Deprecated: Use DataSelectorSingleQuery.ProtoReflect.Descriptor instead.

func (*DataSelectorSingleQuery) GetJsonPath 

func (x *DataSelectorSingleQuery) GetJsonPath() string

func (*DataSelectorSingleQuery) ProtoMessage 

func (*DataSelectorSingleQuery) ProtoMessage()

func (*DataSelectorSingleQuery) ProtoReflect 

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

func (*DataSelectorSingleQuery) Reset 

func (x *DataSelectorSingleQuery) Reset()

func (*DataSelectorSingleQuery) String 

func (x *DataSelectorSingleQuery) String() string

type DataSourceSelector 

type DataSourceSelector struct {

	// Selector custom label
	Label string `protobuf:"bytes,1,opt,name=Label,proto3" json:"Label,omitempty"`
	// Selector additional description
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	// Selector type, either DataSource or Object service
	Type DataSourceSelectorType `protobuf:"varint,3,opt,name=Type,proto3,enum=jobs.DataSourceSelectorType" json:"Type,omitempty"`
	// Select all
	All bool `protobuf:"varint,4,opt,name=All,proto3" json:"All,omitempty"`
	// Collect results
	Collect bool `protobuf:"varint,5,opt,name=Collect,proto3" json:"Collect,omitempty"`
	// Ignore query and just fan out input.DataSources
	FanOutInput bool `protobuf:"varint,8,opt,name=FanOutInput,proto3" json:"FanOutInput,omitempty"`
	// Composition of DataSourceSingleQueries
	Query *service.Query `protobuf:"bytes,6,opt,name=Query,proto3" json:"Query,omitempty"`
	// Optional Timeout for this selector
	Timeout string `protobuf:"bytes,7,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// Clear previous selection
	ClearInput bool `protobuf:"varint,9,opt,name=ClearInput,proto3" json:"ClearInput,omitempty"`
	// contains filtered or unexported fields
}

Selector/Filter for DataSource objects

func (*DataSourceSelector) ApplyClearInput 

func (m *DataSourceSelector) ApplyClearInput(msg *ActionMessage) *ActionMessage

func (*DataSourceSelector) Descriptor deprecated 

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

Deprecated: Use DataSourceSelector.ProtoReflect.Descriptor instead.

func (*DataSourceSelector) Filter 

func (m *DataSourceSelector) Filter(ctx context.Context, input *ActionMessage) (*ActionMessage, *ActionMessage, bool)

func (*DataSourceSelector) FilterID 

func (m *DataSourceSelector) FilterID() string

func (*DataSourceSelector) GetAll 

func (x *DataSourceSelector) GetAll() bool

func (*DataSourceSelector) GetClearInput 

func (x *DataSourceSelector) GetClearInput() bool

func (*DataSourceSelector) GetCollect 

func (x *DataSourceSelector) GetCollect() bool

func (*DataSourceSelector) GetDescription 

func (x *DataSourceSelector) GetDescription() string

func (*DataSourceSelector) GetFanOutInput 

func (x *DataSourceSelector) GetFanOutInput() bool

func (*DataSourceSelector) GetLabel 

func (x *DataSourceSelector) GetLabel() string

func (*DataSourceSelector) GetQuery 

func (x *DataSourceSelector) GetQuery() *service.Query

func (*DataSourceSelector) GetTimeout 

func (x *DataSourceSelector) GetTimeout() string

func (*DataSourceSelector) GetType 

func (x *DataSourceSelector) GetType() DataSourceSelectorType

func (*DataSourceSelector) MultipleSelection 

func (m *DataSourceSelector) MultipleSelection() bool

func (*DataSourceSelector) ProtoMessage 

func (*DataSourceSelector) ProtoMessage()

func (*DataSourceSelector) ProtoReflect 

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

func (*DataSourceSelector) Reset 

func (x *DataSourceSelector) Reset()

func (*DataSourceSelector) Select 

func (m *DataSourceSelector) Select(ctx context.Context, input *ActionMessage, objects chan interface{}, done chan bool) error

func (*DataSourceSelector) SelectorID 

func (m *DataSourceSelector) SelectorID() string

func (*DataSourceSelector) SelectorLabel 

func (m *DataSourceSelector) SelectorLabel() string

func (*DataSourceSelector) String 

func (x *DataSourceSelector) String() string

type DataSourceSelectorType 

type DataSourceSelectorType int32
const (
	DataSourceSelectorType_DataSource DataSourceSelectorType = 0
	DataSourceSelectorType_Object     DataSourceSelectorType = 1
)

func (DataSourceSelectorType) Descriptor 

func (DataSourceSelectorType) Descriptor() protoreflect.EnumDescriptor

func (DataSourceSelectorType) Enum 

func (x DataSourceSelectorType) Enum() *DataSourceSelectorType

func (DataSourceSelectorType) EnumDescriptor deprecated 

func (DataSourceSelectorType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DataSourceSelectorType.Descriptor instead.

func (DataSourceSelectorType) Number 

func (x DataSourceSelectorType) Number() protoreflect.EnumNumber

func (DataSourceSelectorType) String 

func (x DataSourceSelectorType) String() string

func (DataSourceSelectorType) Type 

func (DataSourceSelectorType) Type() protoreflect.EnumType

type DefaultJob 

type DefaultJob struct {
	*Job
	ServiceName string
}

func ListDefaults 

func ListDefaults() []*DefaultJob

ListDefaults returns the content of the internal registry

type DeleteJobRequest 

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

func (*DeleteJobRequest) Descriptor deprecated 

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

Deprecated: Use DeleteJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteJobRequest) GetCleanableJobs 

func (x *DeleteJobRequest) GetCleanableJobs() bool

func (*DeleteJobRequest) GetJobID 

func (x *DeleteJobRequest) GetJobID() string

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) ProtoReflect 

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

func (*DeleteJobRequest) Reset 

func (x *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String 

func (x *DeleteJobRequest) String() string

type DeleteJobResponse 

type DeleteJobResponse struct {
	Success     bool  `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	DeleteCount int32 `protobuf:"varint,2,opt,name=DeleteCount,proto3" json:"DeleteCount,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteJobResponse) Descriptor deprecated 

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

Deprecated: Use DeleteJobResponse.ProtoReflect.Descriptor instead.

func (*DeleteJobResponse) GetDeleteCount 

func (x *DeleteJobResponse) GetDeleteCount() int32

func (*DeleteJobResponse) GetSuccess 

func (x *DeleteJobResponse) GetSuccess() bool

func (*DeleteJobResponse) ProtoMessage 

func (*DeleteJobResponse) ProtoMessage()

func (*DeleteJobResponse) ProtoReflect 

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

func (*DeleteJobResponse) Reset 

func (x *DeleteJobResponse) Reset()

func (*DeleteJobResponse) String 

func (x *DeleteJobResponse) String() string

type DeleteTasksRequest 

type DeleteTasksRequest struct {

	// Id of the job
	JobId string `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	// Ids of tasks to delete
	TaskID []string `protobuf:"bytes,2,rep,name=TaskID,proto3" json:"TaskID,omitempty"`
	// If no TaskID and/or no JobID are passed, delete tasks by status
	Status []TaskStatus `protobuf:"varint,3,rep,packed,name=Status,proto3,enum=jobs.TaskStatus" json:"Status,omitempty"`
	// If deleting by status, optionally keep only a number of tasks
	PruneLimit int32 `protobuf:"varint,4,opt,name=PruneLimit,proto3" json:"PruneLimit,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTasksRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTasksRequest.ProtoReflect.Descriptor instead.

func (*DeleteTasksRequest) GetJobId 

func (x *DeleteTasksRequest) GetJobId() string

func (*DeleteTasksRequest) GetPruneLimit 

func (x *DeleteTasksRequest) GetPruneLimit() int32

func (*DeleteTasksRequest) GetStatus 

func (x *DeleteTasksRequest) GetStatus() []TaskStatus

func (*DeleteTasksRequest) GetTaskID 

func (x *DeleteTasksRequest) GetTaskID() []string

func (*DeleteTasksRequest) ProtoMessage 

func (*DeleteTasksRequest) ProtoMessage()

func (*DeleteTasksRequest) ProtoReflect 

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

func (*DeleteTasksRequest) Reset 

func (x *DeleteTasksRequest) Reset()

func (*DeleteTasksRequest) String 

func (x *DeleteTasksRequest) String() string

type DeleteTasksResponse 

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

func (*DeleteTasksResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTasksResponse.ProtoReflect.Descriptor instead.

func (*DeleteTasksResponse) GetDeleted 

func (x *DeleteTasksResponse) GetDeleted() []string

func (*DeleteTasksResponse) ProtoMessage 

func (*DeleteTasksResponse) ProtoMessage()

func (*DeleteTasksResponse) ProtoReflect 

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

func (*DeleteTasksResponse) Reset 

func (x *DeleteTasksResponse) Reset()

func (*DeleteTasksResponse) String 

func (x *DeleteTasksResponse) String() string

type DetectStuckTasksRequest 

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

func (*DetectStuckTasksRequest) Descriptor deprecated 

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

Deprecated: Use DetectStuckTasksRequest.ProtoReflect.Descriptor instead.

func (*DetectStuckTasksRequest) GetSince 

func (x *DetectStuckTasksRequest) GetSince() int32

func (*DetectStuckTasksRequest) ProtoMessage 

func (*DetectStuckTasksRequest) ProtoMessage()

func (*DetectStuckTasksRequest) ProtoReflect 

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

func (*DetectStuckTasksRequest) Reset 

func (x *DetectStuckTasksRequest) Reset()

func (*DetectStuckTasksRequest) String 

func (x *DetectStuckTasksRequest) String() string

type DetectStuckTasksResponse 

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

func (*DetectStuckTasksResponse) Descriptor deprecated 

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

Deprecated: Use DetectStuckTasksResponse.ProtoReflect.Descriptor instead.

func (*DetectStuckTasksResponse) GetFixedTaskIds 

func (x *DetectStuckTasksResponse) GetFixedTaskIds() []string

func (*DetectStuckTasksResponse) ProtoMessage 

func (*DetectStuckTasksResponse) ProtoMessage()

func (*DetectStuckTasksResponse) ProtoReflect 

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

func (*DetectStuckTasksResponse) Reset 

func (x *DetectStuckTasksResponse) Reset()

func (*DetectStuckTasksResponse) String 

func (x *DetectStuckTasksResponse) String() string

type FieldEvaluator 

type FieldEvaluator interface {
	EvaluateField(ctx context.Context, input *ActionMessage, value string) string
}

func GetFieldEvaluators 

func GetFieldEvaluators() []FieldEvaluator

GetFieldEvaluators lists all registered evaluators

type FreeStringEvaluator 

type FreeStringEvaluator func(ctx context.Context, query string, node *tree.Node) bool

type GetJobRequest 

type GetJobRequest struct {
	JobID     string     `protobuf:"bytes,1,opt,name=JobID,proto3" json:"JobID,omitempty"`
	LoadTasks TaskStatus `protobuf:"varint,2,opt,name=LoadTasks,proto3,enum=jobs.TaskStatus" json:"LoadTasks,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetJobID 

func (x *GetJobRequest) GetJobID() string

func (*GetJobRequest) GetLoadTasks 

func (x *GetJobRequest) GetLoadTasks() TaskStatus

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

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

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetJobResponse 

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

func (*GetJobResponse) Descriptor deprecated 

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJob 

func (x *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect 

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

func (*GetJobResponse) Reset 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (x *GetJobResponse) String() string

type IAction 

type IAction interface {
	proto.Message
	ActionGetter
	ActionSetter
}

type IJob 

type IJob interface {
	proto.Message
	JobGetter
	JobSetter
}

type IJobHook 

type IJobHook interface {
	proto.Message
	JobHookGetter
	JobHookSetter
}

type IJobParameter 

type IJobParameter interface {
	proto.Message
	JobParameterGetter
	JobParameterSetter
}

type IdmSelector 

type IdmSelector struct {

	// Type of objects to look for
	Type IdmSelectorType `protobuf:"varint,1,opt,name=Type,proto3,enum=jobs.IdmSelectorType" json:"Type,omitempty"`
	// Load all objects
	All bool `protobuf:"varint,2,opt,name=All,proto3" json:"All,omitempty"`
	// Serialized search query
	Query *service.Query `protobuf:"bytes,3,opt,name=Query,proto3" json:"Query,omitempty"`
	// Pass a slice of objects to one action, or trigger all actions in parallel
	Collect bool `protobuf:"varint,4,opt,name=Collect,proto3" json:"Collect,omitempty"`
	// Ignore query and just fan out input.[Type]
	FanOutInput bool `protobuf:"varint,8,opt,name=FanOutInput,proto3" json:"FanOutInput,omitempty"`
	// Selector custom label
	Label string `protobuf:"bytes,5,opt,name=Label,proto3" json:"Label,omitempty"`
	// Selector additional description
	Description string `protobuf:"bytes,6,opt,name=Description,proto3" json:"Description,omitempty"`
	// Optional Timeout for this selector
	Timeout string `protobuf:"bytes,7,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// Clear previous selection
	ClearInput bool `protobuf:"varint,9,opt,name=ClearInput,proto3" json:"ClearInput,omitempty"`
	// Handle ranges
	Range *SelectorRange `protobuf:"bytes,11,opt,name=Range,proto3" json:"Range,omitempty"`
	// contains filtered or unexported fields
}

Generic container for select/filter idm objects

func (*IdmSelector) ApplyClearInput 

func (m *IdmSelector) ApplyClearInput(msg *ActionMessage) *ActionMessage

func (*IdmSelector) Descriptor deprecated 

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

Deprecated: Use IdmSelector.ProtoReflect.Descriptor instead.

func (*IdmSelector) Filter 

func (m *IdmSelector) Filter(ctx context.Context, input *ActionMessage) (*ActionMessage, *ActionMessage, bool)

Filter IDM objects by a query

func (*IdmSelector) FilterID 

func (m *IdmSelector) FilterID() string

func (*IdmSelector) GetAll 

func (x *IdmSelector) GetAll() bool

func (*IdmSelector) GetClearInput 

func (x *IdmSelector) GetClearInput() bool

func (*IdmSelector) GetCollect 

func (x *IdmSelector) GetCollect() bool

func (*IdmSelector) GetDescription 

func (x *IdmSelector) GetDescription() string

func (*IdmSelector) GetFanOutInput 

func (x *IdmSelector) GetFanOutInput() bool

func (*IdmSelector) GetLabel 

func (x *IdmSelector) GetLabel() string

func (*IdmSelector) GetQuery 

func (x *IdmSelector) GetQuery() *service.Query

func (*IdmSelector) GetRange 

func (x *IdmSelector) GetRange() *SelectorRange

func (*IdmSelector) GetTimeout 

func (x *IdmSelector) GetTimeout() string

func (*IdmSelector) GetType 

func (x *IdmSelector) GetType() IdmSelectorType

func (*IdmSelector) MultipleSelection 

func (m *IdmSelector) MultipleSelection() bool

func (*IdmSelector) ProtoMessage 

func (*IdmSelector) ProtoMessage()

func (*IdmSelector) ProtoReflect 

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

func (*IdmSelector) Reset 

func (x *IdmSelector) Reset()

func (*IdmSelector) Select 

func (m *IdmSelector) Select(ctx context.Context, input *ActionMessage, objects chan interface{}, done chan bool) error

Select IDM Objects by a given query

func (*IdmSelector) SelectorID 

func (m *IdmSelector) SelectorID() string

func (*IdmSelector) SelectorLabel 

func (m *IdmSelector) SelectorLabel() string

func (*IdmSelector) String 

func (x *IdmSelector) String() string

func (*IdmSelector) WorkspaceFromEventContext 

func (m *IdmSelector) WorkspaceFromEventContext(ctx context.Context) (*idm.Workspace, bool)

WorkspaceFromEventContext tries to find the CtxWorkspaceUuid key in the context metadata and if it is set, lookup actual workspace by UUID.

type IdmSelectorType 

type IdmSelectorType int32

Possible values for IdmSelector.Type 

const (
	IdmSelectorType_User      IdmSelectorType = 0
	IdmSelectorType_Role      IdmSelectorType = 1
	IdmSelectorType_Workspace IdmSelectorType = 2
	IdmSelectorType_Acl       IdmSelectorType = 3
)

func (IdmSelectorType) Descriptor 

func (IdmSelectorType) Descriptor() protoreflect.EnumDescriptor

func (IdmSelectorType) Enum 

func (x IdmSelectorType) Enum() *IdmSelectorType

func (IdmSelectorType) EnumDescriptor deprecated 

func (IdmSelectorType) EnumDescriptor() ([]byte, []int)

Deprecated: Use IdmSelectorType.Descriptor instead.

func (IdmSelectorType) Number 

func (x IdmSelectorType) Number() protoreflect.EnumNumber

func (IdmSelectorType) String 

func (x IdmSelectorType) String() string

func (IdmSelectorType) Type 

func (IdmSelectorType) Type() protoreflect.EnumType

type InputFilter 

type InputFilter interface {
	Filter(ctx context.Context, input *ActionMessage) (*ActionMessage, *ActionMessage, bool)
	FilterID() string
}

type InputSelector 

type InputSelector interface {
	Select(ctx context.Context, input *ActionMessage, objects chan interface{}, done chan bool) error
	MultipleSelection() bool
	GetTimeout() string
	SelectorID() string
	SelectorLabel() string
	GetClearInput() bool
	ApplyClearInput(msg *ActionMessage) *ActionMessage
}

type JSONPathSelectorFunc 

type JSONPathSelectorFunc func(ctx context.Context, data interface{}, jsonPath string) ([]interface{}, error)
var (
	JSONPathSelector JSONPathSelectorFunc
)

type Job 

type Job struct {

	// Unique ID for this Job
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Human-readable Label
	Label string `protobuf:"bytes,2,opt,name=Label,proto3" json:"Label,omitempty"`
	// Who created this Job
	Owner string `protobuf:"bytes,3,opt,name=Owner,proto3" json:"Owner,omitempty"`
	// Additional user-defined metadata, can be used for icon, documentation, pre-requisites, etc.
	Metadata map[string]string `` /* 158-byte string literal not displayed */
	// Timestamp for creation time
	CreatedAt int32 `protobuf:"varint,25,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	// Timestamp for modification time
	ModifiedAt int32 `protobuf:"varint,26,opt,name=ModifiedAt,proto3" json:"ModifiedAt,omitempty"`
	// Admin can temporarily disable this job
	Inactive bool `protobuf:"varint,4,opt,name=Inactive,proto3" json:"Inactive,omitempty"`
	// Job created by application or by administrator
	Custom bool `protobuf:"varint,20,opt,name=Custom,proto3" json:"Custom,omitempty"`
	// Optional list of languages detected in the context at launch time
	Languages []string `protobuf:"bytes,10,rep,name=Languages,proto3" json:"Languages,omitempty"`
	// How the job will be triggered.
	// One of these must be set (not exclusive)
	// Listen to a given set of events
	EventNames []string `protobuf:"bytes,5,rep,name=EventNames,proto3" json:"EventNames,omitempty"`
	// Schedule a periodic repetition
	Schedule *Schedule `protobuf:"bytes,6,opt,name=Schedule,proto3" json:"Schedule,omitempty"`
	// Start task as soon as job is inserted
	AutoStart bool `protobuf:"varint,7,opt,name=AutoStart,proto3" json:"AutoStart,omitempty"`
	// Start task as soon as server is started
	AutoRestart bool `protobuf:"varint,29,opt,name=AutoRestart,proto3" json:"AutoRestart,omitempty"`
	// Remove job automatically once it is finished (success only)
	AutoClean bool `protobuf:"varint,11,opt,name=AutoClean,proto3" json:"AutoClean,omitempty"`
	// Chain of actions to perform
	Actions []*Action `protobuf:"bytes,8,rep,name=Actions,proto3" json:"Actions,omitempty"`
	// Collect chain of actions into a merged output
	MergeAction *Action `protobuf:"bytes,24,opt,name=MergeAction,proto3" json:"MergeAction,omitempty"`
	// Task properties
	MaxConcurrency int32 `protobuf:"varint,9,opt,name=MaxConcurrency,proto3" json:"MaxConcurrency,omitempty"`
	// Do not send notification on task update
	TasksSilentUpdate bool `protobuf:"varint,12,opt,name=TasksSilentUpdate,proto3" json:"TasksSilentUpdate,omitempty"`
	// Filled with currently running tasks
	Tasks []*Task `protobuf:"bytes,14,rep,name=Tasks,proto3" json:"Tasks,omitempty"`
	// Filter out specific events
	NodeEventFilter *NodesSelector `protobuf:"bytes,15,opt,name=NodeEventFilter,proto3" json:"NodeEventFilter,omitempty"`
	// Deprecated in favor of more generic IdmSelector
	UserEventFilter *UsersSelector `protobuf:"bytes,16,opt,name=UserEventFilter,proto3" json:"UserEventFilter,omitempty"`
	// Idm objects filter
	IdmFilter *IdmSelector `protobuf:"bytes,17,opt,name=IdmFilter,proto3" json:"IdmFilter,omitempty"`
	// Event Context Filter
	ContextMetaFilter *ContextMetaFilter `protobuf:"bytes,18,opt,name=ContextMetaFilter,proto3" json:"ContextMetaFilter,omitempty"`
	// DataSource objects filter
	DataSourceFilter *DataSourceSelector `protobuf:"bytes,21,opt,name=DataSourceFilter,proto3" json:"DataSourceFilter,omitempty"`
	// Job-level parameters that can be passed to underlying actions
	Parameters []*JobParameter `protobuf:"bytes,19,rep,name=Parameters,proto3" json:"Parameters,omitempty"`
	// Additional dependencies that may be required when running the job
	ResourcesDependencies []*anypb.Any `protobuf:"bytes,22,rep,name=ResourcesDependencies,proto3" json:"ResourcesDependencies,omitempty"`
	// Optional Timeout any running job
	Timeout string `protobuf:"bytes,23,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// Additional Versioning Metadata
	VersionMeta map[string]string `` /* 164-byte string literal not displayed */
	// Expose this job through one or more-userspace APIs
	Hooks []*JobHook `protobuf:"bytes,28,rep,name=Hooks,proto3" json:"Hooks,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetActions 

func (x *Job) GetActions() []*Action

func (*Job) GetAutoClean 

func (x *Job) GetAutoClean() bool

func (*Job) GetAutoRestart 

func (x *Job) GetAutoRestart() bool

func (*Job) GetAutoStart 

func (x *Job) GetAutoStart() bool

func (*Job) GetContextMetaFilter 

func (x *Job) GetContextMetaFilter() *ContextMetaFilter

func (*Job) GetCreatedAt 

func (x *Job) GetCreatedAt() int32

func (*Job) GetCustom 

func (x *Job) GetCustom() bool

func (*Job) GetDataSourceFilter 

func (x *Job) GetDataSourceFilter() *DataSourceSelector

func (*Job) GetEventNames 

func (x *Job) GetEventNames() []string

func (*Job) GetHooks 

func (x *Job) GetHooks() []*JobHook

func (*Job) GetID 

func (x *Job) GetID() string

func (*Job) GetIdmFilter 

func (x *Job) GetIdmFilter() *IdmSelector

func (*Job) GetInactive 

func (x *Job) GetInactive() bool

func (*Job) GetLabel 

func (x *Job) GetLabel() string

func (*Job) GetLanguages 

func (x *Job) GetLanguages() []string

func (*Job) GetMaxConcurrency 

func (x *Job) GetMaxConcurrency() int32

func (*Job) GetMergeAction 

func (x *Job) GetMergeAction() *Action

func (*Job) GetMetadata 

func (x *Job) GetMetadata() map[string]string

func (*Job) GetModifiedAt 

func (x *Job) GetModifiedAt() int32

func (*Job) GetNodeEventFilter 

func (x *Job) GetNodeEventFilter() *NodesSelector

func (*Job) GetOwner 

func (x *Job) GetOwner() string

func (*Job) GetParameters 

func (x *Job) GetParameters() []*JobParameter

func (*Job) GetResourcesDependencies 

func (x *Job) GetResourcesDependencies() []*anypb.Any

func (*Job) GetSchedule 

func (x *Job) GetSchedule() *Schedule

func (*Job) GetTasks 

func (x *Job) GetTasks() []*Task

func (*Job) GetTasksSilentUpdate 

func (x *Job) GetTasksSilentUpdate() bool

func (*Job) GetTimeout 

func (x *Job) GetTimeout() string

func (*Job) GetUserEventFilter 

func (x *Job) GetUserEventFilter() *UsersSelector

func (*Job) GetVersionMeta 

func (x *Job) GetVersionMeta() map[string]string

func (*Job) MarshalLogObject 

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

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) SetActions 

func (x *Job) SetActions(v []*Action)

func (*Job) SetAutoClean 

func (x *Job) SetAutoClean(v bool)

func (*Job) SetAutoRestart 

func (x *Job) SetAutoRestart(v bool)

func (*Job) SetAutoStart 

func (x *Job) SetAutoStart(v bool)

func (*Job) SetContextMetaFilter 

func (x *Job) SetContextMetaFilter(v *ContextMetaFilter)

func (*Job) SetCreatedAt 

func (x *Job) SetCreatedAt(v int32)

func (*Job) SetCustom 

func (x *Job) SetCustom(v bool)

func (*Job) SetDataSourceFilter 

func (x *Job) SetDataSourceFilter(v *DataSourceSelector)

func (*Job) SetEventNames 

func (x *Job) SetEventNames(v []string)

func (*Job) SetHooks 

func (x *Job) SetHooks(v []*JobHook)

func (*Job) SetID 

func (x *Job) SetID(v string)

func (*Job) SetIdmFilter 

func (x *Job) SetIdmFilter(v *IdmSelector)

func (*Job) SetInactive 

func (x *Job) SetInactive(v bool)

func (*Job) SetLabel 

func (x *Job) SetLabel(v string)

func (*Job) SetLanguages 

func (x *Job) SetLanguages(v []string)

func (*Job) SetMaxConcurrency 

func (x *Job) SetMaxConcurrency(v int32)

func (*Job) SetMergeAction 

func (x *Job) SetMergeAction(v *Action)

func (*Job) SetMetadata 

func (x *Job) SetMetadata(v map[string]string)

func (*Job) SetModifiedAt 

func (x *Job) SetModifiedAt(v int32)

func (*Job) SetNodeEventFilter 

func (x *Job) SetNodeEventFilter(v *NodesSelector)

func (*Job) SetOwner 

func (x *Job) SetOwner(v string)

func (*Job) SetParameters 

func (x *Job) SetParameters(v []*JobParameter)

func (*Job) SetResourcesDependencies 

func (x *Job) SetResourcesDependencies(v []*anypb.Any)

func (*Job) SetSchedule 

func (x *Job) SetSchedule(v *Schedule)

func (*Job) SetTasks 

func (x *Job) SetTasks(v []*Task)

func (*Job) SetTasksSilentUpdate 

func (x *Job) SetTasksSilentUpdate(v bool)

func (*Job) SetTimeout 

func (x *Job) SetTimeout(v string)

func (*Job) SetUserEventFilter 

func (x *Job) SetUserEventFilter(v *UsersSelector)

func (*Job) SetVersionMeta 

func (x *Job) SetVersionMeta(v map[string]string)

func (*Job) String 

func (x *Job) String() string

func (*Job) Zap 

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

Zap simply returns a zapcore.Field object populated with this Job under a standard key

func (*Job) ZapId 

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

ZapId simply calls zap.String() with JobId standard key and this Job Id

type JobChangeEvent 

type JobChangeEvent struct {
	JobUpdated *Job   `protobuf:"bytes,1,opt,name=JobUpdated,proto3" json:"JobUpdated,omitempty"`
	JobRemoved string `protobuf:"bytes,2,opt,name=JobRemoved,proto3" json:"JobRemoved,omitempty"`
	// contains filtered or unexported fields
}

Events sent by the JobService when CRUD'ing a Job configuration

func (*JobChangeEvent) Descriptor deprecated 

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

Deprecated: Use JobChangeEvent.ProtoReflect.Descriptor instead.

func (*JobChangeEvent) GetJobRemoved 

func (x *JobChangeEvent) GetJobRemoved() string

func (*JobChangeEvent) GetJobUpdated 

func (x *JobChangeEvent) GetJobUpdated() *Job

func (*JobChangeEvent) ProtoMessage 

func (*JobChangeEvent) ProtoMessage()

func (*JobChangeEvent) ProtoReflect 

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

func (*JobChangeEvent) Reset 

func (x *JobChangeEvent) Reset()

func (*JobChangeEvent) String 

func (x *JobChangeEvent) String() string

type JobGetter 

type JobGetter interface {
	GetID() string
	GetLabel() string
	GetOwner() string
	GetMetadata() map[string]string
	GetCreatedAt() int32
	GetModifiedAt() int32
	GetInactive() bool
	GetCustom() bool
	GetLanguages() []string
	GetEventNames() []string
	GetSchedule() *Schedule
	GetAutoStart() bool
	GetAutoRestart() bool
	GetAutoClean() bool
	GetActions() []*Action
	GetMergeAction() *Action
	GetMaxConcurrency() int32
	GetTasksSilentUpdate() bool
	GetTasks() []*Task
	GetNodeEventFilter() *NodesSelector
	GetUserEventFilter() *UsersSelector
	GetIdmFilter() *IdmSelector
	GetContextMetaFilter() *ContextMetaFilter
	GetDataSourceFilter() *DataSourceSelector
	GetParameters() []*JobParameter
	GetResourcesDependencies() []*anypb.Any
	GetTimeout() string
	GetVersionMeta() map[string]string
	GetHooks() []*JobHook
}

type JobHook 

type JobHook struct {

	// Custom ApiSlug, otherwise use the job UUID
	ApiSlug string `protobuf:"bytes,1,opt,name=ApiSlug,proto3" json:"ApiSlug,omitempty"`
	// Preset parameters values when calling this endpoint. May be overriden by a map[string]string in the body
	PresetParameters map[string]string `` /* 173-byte string literal not displayed */
	// Allow trigger parameters to override default presets
	AllowOverridePresets bool `protobuf:"varint,3,opt,name=AllowOverridePresets,proto3" json:"AllowOverridePresets,omitempty"`
	// Additional arbitrary metadata attached to this hook
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Set permissions for accessing this endpoint
	Policies []*service.ResourcePolicy `protobuf:"bytes,5,rep,name=Policies,proto3" json:"Policies,omitempty"`
	// contains filtered or unexported fields
}

Dynamically expose a job trigger via API

func (*JobHook) Descriptor deprecated 

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

Deprecated: Use JobHook.ProtoReflect.Descriptor instead.

func (*JobHook) GetAllowOverridePresets 

func (x *JobHook) GetAllowOverridePresets() bool

func (*JobHook) GetApiSlug 

func (x *JobHook) GetApiSlug() string

func (*JobHook) GetMetadata 

func (x *JobHook) GetMetadata() map[string]string

func (*JobHook) GetPolicies 

func (x *JobHook) GetPolicies() []*service.ResourcePolicy

func (*JobHook) GetPresetParameters 

func (x *JobHook) GetPresetParameters() map[string]string

func (*JobHook) ProtoMessage 

func (*JobHook) ProtoMessage()

func (*JobHook) ProtoReflect 

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

func (*JobHook) Reset 

func (x *JobHook) Reset()

func (*JobHook) SetAllowOverridePresets 

func (x *JobHook) SetAllowOverridePresets(v bool)

func (*JobHook) SetApiSlug 

func (x *JobHook) SetApiSlug(v string)

func (*JobHook) SetMetadata 

func (x *JobHook) SetMetadata(v map[string]string)

func (*JobHook) SetPolicies 

func (x *JobHook) SetPolicies(v []*service.ResourcePolicy)

func (*JobHook) SetPresetParameters 

func (x *JobHook) SetPresetParameters(v map[string]string)

func (*JobHook) String 

func (x *JobHook) String() string

type JobHookGetter 

type JobHookGetter interface {
	GetApiSlug() string
	GetPresetParameters() map[string]string
	GetAllowOverridePresets() bool
	GetMetadata() map[string]string
	GetPolicies() []*service.ResourcePolicy
}

type JobHookSetter 

type JobHookSetter interface {
	SetApiSlug(string)
	SetPresetParameters(map[string]string)
	SetAllowOverridePresets(bool)
	SetMetadata(map[string]string)
	SetPolicies([]*service.ResourcePolicy)
}

type JobParameter 

type JobParameter struct {

	// Parameter name
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Additional description
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	// Value saved for this parameter
	Value string `protobuf:"bytes,4,opt,name=Value,proto3" json:"Value,omitempty"`
	// If mandatory, job cannot start without a value
	Mandatory bool `protobuf:"varint,3,opt,name=Mandatory,proto3" json:"Mandatory,omitempty"`
	// Parameter type used in GUI forms
	Type string `protobuf:"bytes,5,opt,name=Type,proto3" json:"Type,omitempty"`
	// Additional data used by GUI elements
	JsonChoices string `protobuf:"bytes,6,opt,name=JsonChoices,proto3" json:"JsonChoices,omitempty"`
	// contains filtered or unexported fields
}

func (*JobParameter) Descriptor deprecated 

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

Deprecated: Use JobParameter.ProtoReflect.Descriptor instead.

func (*JobParameter) GetDescription 

func (x *JobParameter) GetDescription() string

func (*JobParameter) GetJsonChoices 

func (x *JobParameter) GetJsonChoices() string

func (*JobParameter) GetMandatory 

func (x *JobParameter) GetMandatory() bool

func (*JobParameter) GetName 

func (x *JobParameter) GetName() string

func (*JobParameter) GetType 

func (x *JobParameter) GetType() string

func (*JobParameter) GetValue 

func (x *JobParameter) GetValue() string

func (*JobParameter) ProtoMessage 

func (*JobParameter) ProtoMessage()

func (*JobParameter) ProtoReflect 

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

func (*JobParameter) Reset 

func (x *JobParameter) Reset()

func (*JobParameter) SetDescription 

func (x *JobParameter) SetDescription(v string)

func (*JobParameter) SetJsonChoices 

func (x *JobParameter) SetJsonChoices(v string)

func (*JobParameter) SetMandatory 

func (x *JobParameter) SetMandatory(v bool)

func (*JobParameter) SetName 

func (x *JobParameter) SetName(v string)

func (*JobParameter) SetType 

func (x *JobParameter) SetType(v string)

func (*JobParameter) SetValue 

func (x *JobParameter) SetValue(v string)

func (*JobParameter) String 

func (x *JobParameter) String() string

type JobParameterGetter 

type JobParameterGetter interface {
	GetName() string
	GetDescription() string
	GetValue() string
	GetMandatory() bool
	GetType() string
	GetJsonChoices() string
}

type JobParameterSetter 

type JobParameterSetter interface {
	SetName(string)
	SetDescription(string)
	SetValue(string)
	SetMandatory(bool)
	SetType(string)
	SetJsonChoices(string)
}

type JobServiceClient 

type JobServiceClient interface {
	PutJob(ctx context.Context, in *PutJobRequest, opts ...grpc.CallOption) (*PutJobResponse, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (JobService_ListJobsClient, error)
	PutTask(ctx context.Context, in *PutTaskRequest, opts ...grpc.CallOption) (*PutTaskResponse, error)
	PutTaskStream(ctx context.Context, opts ...grpc.CallOption) (JobService_PutTaskStreamClient, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (JobService_ListTasksClient, error)
	DeleteTasks(ctx context.Context, in *DeleteTasksRequest, opts ...grpc.CallOption) (*DeleteTasksResponse, error)
	DetectStuckTasks(ctx context.Context, in *DetectStuckTasksRequest, opts ...grpc.CallOption) (*DetectStuckTasksResponse, error)
}

JobServiceClient is the client API for JobService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJobServiceClient 

func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient

type JobServiceServer 

type JobServiceServer interface {
	PutJob(context.Context, *PutJobRequest) (*PutJobResponse, error)
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)
	ListJobs(*ListJobsRequest, JobService_ListJobsServer) error
	PutTask(context.Context, *PutTaskRequest) (*PutTaskResponse, error)
	PutTaskStream(JobService_PutTaskStreamServer) error
	ListTasks(*ListTasksRequest, JobService_ListTasksServer) error
	DeleteTasks(context.Context, *DeleteTasksRequest) (*DeleteTasksResponse, error)
	DetectStuckTasks(context.Context, *DetectStuckTasksRequest) (*DetectStuckTasksResponse, error)
	// contains filtered or unexported methods
}

JobServiceServer is the server API for JobService service. All implementations must embed UnimplementedJobServiceServer for forward compatibility

type JobService_ListJobsClient 

type JobService_ListJobsClient interface {
	Recv() (*ListJobsResponse, error)
	grpc.ClientStream
}

type JobService_ListJobsServer 

type JobService_ListJobsServer interface {
	Send(*ListJobsResponse) error
	grpc.ServerStream
}

type JobService_ListTasksClient 

type JobService_ListTasksClient interface {
	Recv() (*ListTasksResponse, error)
	grpc.ClientStream
}

type JobService_ListTasksServer 

type JobService_ListTasksServer interface {
	Send(*ListTasksResponse) error
	grpc.ServerStream
}

type JobService_PutTaskStreamClient 

type JobService_PutTaskStreamClient interface {
	Send(*PutTaskRequest) error
	Recv() (*PutTaskResponse, error)
	grpc.ClientStream
}

type JobService_PutTaskStreamServer 

type JobService_PutTaskStreamServer interface {
	Send(*PutTaskResponse) error
	Recv() (*PutTaskRequest, error)
	grpc.ServerStream
}

type JobSetter 

type JobSetter interface {
	SetID(string)
	SetLabel(string)
	SetOwner(string)
	SetMetadata(map[string]string)
	SetCreatedAt(int32)
	SetModifiedAt(int32)
	SetInactive(bool)
	SetCustom(bool)
	SetLanguages([]string)
	SetEventNames([]string)
	SetSchedule(*Schedule)
	SetAutoStart(bool)
	SetAutoRestart(bool)
	SetAutoClean(bool)
	SetActions([]*Action)
	SetMergeAction(*Action)
	SetMaxConcurrency(int32)
	SetTasksSilentUpdate(bool)
	SetTasks([]*Task)
	SetNodeEventFilter(*NodesSelector)
	SetUserEventFilter(*UsersSelector)
	SetIdmFilter(*IdmSelector)
	SetContextMetaFilter(*ContextMetaFilter)
	SetDataSourceFilter(*DataSourceSelector)
	SetParameters([]*JobParameter)
	SetResourcesDependencies([]*anypb.Any)
	SetTimeout(string)
	SetVersionMeta(map[string]string)
	SetHooks([]*JobHook)
}

type JobTriggerEvent 

type JobTriggerEvent struct {

	// Id of the Job
	JobID string `protobuf:"bytes,1,opt,name=JobID,proto3" json:"JobID,omitempty"`
	// Schedule
	Schedule *Schedule `protobuf:"bytes,2,opt,name=Schedule,proto3" json:"Schedule,omitempty"`
	// Start job now
	RunNow bool `protobuf:"varint,3,opt,name=RunNow,proto3" json:"RunNow,omitempty"`
	// Impose the task unique ID for this run
	RunTaskId string `protobuf:"bytes,4,opt,name=RunTaskId,proto3" json:"RunTaskId,omitempty"`
	// Use specific parameters values for this run
	RunParameters map[string]string `` /* 167-byte string literal not displayed */
	// This was triggered by the hooks API
	HookSlug string `protobuf:"bytes,6,opt,name=HookSlug,proto3" json:"HookSlug,omitempty"`
	// Predefined custom message
	TriggerMessage *ActionMessage `protobuf:"bytes,7,opt,name=TriggerMessage,proto3" json:"TriggerMessage,omitempty"`
	// contains filtered or unexported fields
}

Simple Event sent by the timer service to trigger a JobID at a given time or to trigger a run now, with optional parameters

func (*JobTriggerEvent) Descriptor deprecated 

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

Deprecated: Use JobTriggerEvent.ProtoReflect.Descriptor instead.

func (*JobTriggerEvent) GetHookSlug 

func (x *JobTriggerEvent) GetHookSlug() string

func (*JobTriggerEvent) GetJobID 

func (x *JobTriggerEvent) GetJobID() string

func (*JobTriggerEvent) GetRunNow 

func (x *JobTriggerEvent) GetRunNow() bool

func (*JobTriggerEvent) GetRunParameters 

func (x *JobTriggerEvent) GetRunParameters() map[string]string

func (*JobTriggerEvent) GetRunTaskId 

func (x *JobTriggerEvent) GetRunTaskId() string

func (*JobTriggerEvent) GetSchedule 

func (x *JobTriggerEvent) GetSchedule() *Schedule

func (*JobTriggerEvent) GetTriggerMessage 

func (x *JobTriggerEvent) GetTriggerMessage() *ActionMessage

func (*JobTriggerEvent) ProtoMessage 

func (*JobTriggerEvent) ProtoMessage()

func (*JobTriggerEvent) ProtoReflect 

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

func (*JobTriggerEvent) Reset 

func (x *JobTriggerEvent) Reset()

func (*JobTriggerEvent) String 

func (x *JobTriggerEvent) String() string

type JsonChunk 

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

type ListJobsRequest 

type ListJobsRequest struct {

	// Restrict to a specific owner (current user by default)
	Owner string `protobuf:"bytes,1,opt,name=Owner,proto3" json:"Owner,omitempty"`
	// Filter with only event-based jobs
	EventsOnly bool `protobuf:"varint,2,opt,name=EventsOnly,proto3" json:"EventsOnly,omitempty"`
	// Filter with only timer-based jobs
	TimersOnly bool `protobuf:"varint,3,opt,name=TimersOnly,proto3" json:"TimersOnly,omitempty"`
	// Load tasks that correspond to the given TaskStatus
	LoadTasks TaskStatus `protobuf:"varint,4,opt,name=LoadTasks,proto3,enum=jobs.TaskStatus" json:"LoadTasks,omitempty"`
	// Load jobs by their ID
	JobIDs []string `protobuf:"bytes,5,rep,name=JobIDs,proto3" json:"JobIDs,omitempty"`
	// Start listing at a given position
	TasksOffset int32 `protobuf:"varint,6,opt,name=TasksOffset,proto3" json:"TasksOffset,omitempty"`
	// Lmit the number of results
	TasksLimit int32 `protobuf:"varint,7,opt,name=TasksLimit,proto3" json:"TasksLimit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetEventsOnly 

func (x *ListJobsRequest) GetEventsOnly() bool

func (*ListJobsRequest) GetJobIDs 

func (x *ListJobsRequest) GetJobIDs() []string

func (*ListJobsRequest) GetLoadTasks 

func (x *ListJobsRequest) GetLoadTasks() TaskStatus

func (*ListJobsRequest) GetOwner 

func (x *ListJobsRequest) GetOwner() string

func (*ListJobsRequest) GetTasksLimit 

func (x *ListJobsRequest) GetTasksLimit() int32

func (*ListJobsRequest) GetTasksOffset 

func (x *ListJobsRequest) GetTasksOffset() int32

func (*ListJobsRequest) GetTimersOnly 

func (x *ListJobsRequest) GetTimersOnly() bool

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

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

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

type ListJobsResponse 

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

func (*ListJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetJob 

func (x *ListJobsResponse) GetJob() *Job

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect 

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

func (*ListJobsResponse) Reset 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (x *ListJobsResponse) String() string

type ListTasksRequest 

type ListTasksRequest struct {

	// List tasks for the job with this Id
	JobID string `protobuf:"bytes,1,opt,name=JobID,proto3" json:"JobID,omitempty"`
	// List only tasks with this Status
	Status TaskStatus `protobuf:"varint,2,opt,name=Status,proto3,enum=jobs.TaskStatus" json:"Status,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetJobID 

func (x *ListTasksRequest) GetJobID() string

func (*ListTasksRequest) GetStatus 

func (x *ListTasksRequest) GetStatus() TaskStatus

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

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

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type ListTasksResponse 

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

func (*ListTasksResponse) Descriptor deprecated 

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetTask 

func (x *ListTasksResponse) GetTask() *Task

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect 

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

func (*ListTasksResponse) Reset 

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String 

func (x *ListTasksResponse) String() string

type MessageMatcher 

type MessageMatcher struct {
	*ActionOutputSingleQuery
}

func (*MessageMatcher) Matches 

func (m *MessageMatcher) Matches(object interface{}) bool

type NodeMatcher 

type NodeMatcher struct {
	*tree.Query
}

func (*NodeMatcher) Matches 

func (n *NodeMatcher) Matches(object interface{}) bool

type NodesSelector 

type NodesSelector struct {

	// Select all files - ignore any other condition
	All bool `protobuf:"varint,1,opt,name=All,proto3" json:"All,omitempty"`
	// Preset list of node pathes
	Pathes []string `protobuf:"bytes,2,rep,name=Pathes,proto3" json:"Pathes,omitempty"`
	// Query to apply to select users (or filter a given node passed by event)
	Query *service.Query `protobuf:"bytes,4,opt,name=Query,proto3" json:"Query,omitempty"`
	// Whether to trigger one action per node or one action
	// with all nodes as selection
	Collect bool `protobuf:"varint,5,opt,name=Collect,proto3" json:"Collect,omitempty"`
	// Ignore query and just fan out input.Nodes
	FanOutInput bool `protobuf:"varint,9,opt,name=FanOutInput,proto3" json:"FanOutInput,omitempty"`
	// Selector custom label
	Label string `protobuf:"bytes,6,opt,name=Label,proto3" json:"Label,omitempty"`
	// Selector additional description
	Description string `protobuf:"bytes,7,opt,name=Description,proto3" json:"Description,omitempty"`
	// Optional Timeout for this selector
	Timeout string `protobuf:"bytes,8,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// Clear previous selection
	ClearInput bool `protobuf:"varint,10,opt,name=ClearInput,proto3" json:"ClearInput,omitempty"`
	// Handle ranges
	Range *SelectorRange `protobuf:"bytes,11,opt,name=Range,proto3" json:"Range,omitempty"`
	// contains filtered or unexported fields
}

///////////////// JOB SERVICE // /////////////////

func (*NodesSelector) ApplyClearInput 

func (n *NodesSelector) ApplyClearInput(msg *ActionMessage) *ActionMessage

func (*NodesSelector) Descriptor deprecated 

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

Deprecated: Use NodesSelector.ProtoReflect.Descriptor instead.

func (*NodesSelector) Filter 

func (n *NodesSelector) Filter(ctx context.Context, input *ActionMessage) (*ActionMessage, *ActionMessage, bool)

func (*NodesSelector) FilterID 

func (n *NodesSelector) FilterID() string

func (*NodesSelector) GetAll 

func (x *NodesSelector) GetAll() bool

func (*NodesSelector) GetClearInput 

func (x *NodesSelector) GetClearInput() bool

func (*NodesSelector) GetCollect 

func (x *NodesSelector) GetCollect() bool

func (*NodesSelector) GetDescription 

func (x *NodesSelector) GetDescription() string

func (*NodesSelector) GetFanOutInput 

func (x *NodesSelector) GetFanOutInput() bool

func (*NodesSelector) GetLabel 

func (x *NodesSelector) GetLabel() string

func (*NodesSelector) GetPathes 

func (x *NodesSelector) GetPathes() []string

func (*NodesSelector) GetQuery 

func (x *NodesSelector) GetQuery() *service.Query

func (*NodesSelector) GetRange 

func (x *NodesSelector) GetRange() *SelectorRange

func (*NodesSelector) GetTimeout 

func (x *NodesSelector) GetTimeout() string

func (*NodesSelector) MultipleSelection 

func (n *NodesSelector) MultipleSelection() bool

func (*NodesSelector) ProtoMessage 

func (*NodesSelector) ProtoMessage()

func (*NodesSelector) ProtoReflect 

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

func (*NodesSelector) Reset 

func (x *NodesSelector) Reset()

func (*NodesSelector) Select 

func (n *NodesSelector) Select(ctx context.Context, input *ActionMessage, objects chan interface{}, done chan bool) error

func (*NodesSelector) SelectorID 

func (n *NodesSelector) SelectorID() string

func (*NodesSelector) SelectorLabel 

func (n *NodesSelector) SelectorLabel() string

func (*NodesSelector) String 

func (x *NodesSelector) String() string

type PutJobRequest 

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

func (*PutJobRequest) Descriptor deprecated 

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

Deprecated: Use PutJobRequest.ProtoReflect.Descriptor instead.

func (*PutJobRequest) GetJob 

func (x *PutJobRequest) GetJob() *Job

func (*PutJobRequest) ProtoMessage 

func (*PutJobRequest) ProtoMessage()

func (*PutJobRequest) ProtoReflect 

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

func (*PutJobRequest) Reset 

func (x *PutJobRequest) Reset()

func (*PutJobRequest) String 

func (x *PutJobRequest) String() string

type PutJobResponse 

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

func (*PutJobResponse) Descriptor deprecated 

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

Deprecated: Use PutJobResponse.ProtoReflect.Descriptor instead.

func (*PutJobResponse) GetJob 

func (x *PutJobResponse) GetJob() *Job

func (*PutJobResponse) ProtoMessage 

func (*PutJobResponse) ProtoMessage()

func (*PutJobResponse) ProtoReflect 

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

func (*PutJobResponse) Reset 

func (x *PutJobResponse) Reset()

func (*PutJobResponse) String 

func (x *PutJobResponse) String() string

type PutTaskRequest 

type PutTaskRequest struct {
	Task       *Task             `protobuf:"bytes,1,opt,name=Task,proto3" json:"Task,omitempty"`
	StatusMeta map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PutTaskRequest) Descriptor deprecated 

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

Deprecated: Use PutTaskRequest.ProtoReflect.Descriptor instead.

func (*PutTaskRequest) GetStatusMeta 

func (x *PutTaskRequest) GetStatusMeta() map[string]string

func (*PutTaskRequest) GetTask 

func (x *PutTaskRequest) GetTask() *Task

func (*PutTaskRequest) ProtoMessage 

func (*PutTaskRequest) ProtoMessage()

func (*PutTaskRequest) ProtoReflect 

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

func (*PutTaskRequest) Reset 

func (x *PutTaskRequest) Reset()

func (*PutTaskRequest) String 

func (x *PutTaskRequest) String() string

type PutTaskResponse 

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

func (*PutTaskResponse) Descriptor deprecated 

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

Deprecated: Use PutTaskResponse.ProtoReflect.Descriptor instead.

func (*PutTaskResponse) GetTask 

func (x *PutTaskResponse) GetTask() *Task

func (*PutTaskResponse) ProtoMessage 

func (*PutTaskResponse) ProtoMessage()

func (*PutTaskResponse) ProtoReflect 

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

func (*PutTaskResponse) Reset 

func (x *PutTaskResponse) Reset()

func (*PutTaskResponse) String 

func (x *PutTaskResponse) String() string

type RunParametersComputerFunc 

type RunParametersComputerFunc func(ctx context.Context, input *ActionMessage, job *Job, event interface{}) map[string]string
var (
	RunParametersComputer RunParametersComputerFunc
)

type Schedule 

type Schedule struct {

	// ISO 8601 Description of the scheduling for instance "R2/2015-06-04T19:25:16.828696-07:00/PT4S"
	// where first part is the number of repetitions (if 0, infinite repetition),
	// second part the starting date and last part, the duration between 2 occurrences.
	Iso8601Schedule string `protobuf:"bytes,1,opt,name=Iso8601Schedule,proto3" json:"Iso8601Schedule,omitempty"`
	// Minimum time between two runs
	Iso8601MinDelta string `protobuf:"bytes,3,opt,name=Iso8601MinDelta,proto3" json:"Iso8601MinDelta,omitempty"`
	// contains filtered or unexported fields
}

func (*Schedule) Descriptor deprecated 

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

Deprecated: Use Schedule.ProtoReflect.Descriptor instead.

func (*Schedule) GetIso8601MinDelta 

func (x *Schedule) GetIso8601MinDelta() string

func (*Schedule) GetIso8601Schedule 

func (x *Schedule) GetIso8601Schedule() string

func (*Schedule) ProtoMessage 

func (*Schedule) ProtoMessage()

func (*Schedule) ProtoReflect 

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

func (*Schedule) Reset 

func (x *Schedule) Reset()

func (*Schedule) String 

func (x *Schedule) String() string

type SelectorRange 

type SelectorRange struct {

	// Limit number of results - use string to allow templating
	Limit string `protobuf:"bytes,10,opt,name=Limit,proto3" json:"Limit,omitempty"`
	// Start offset - use string to allow templating
	Offset string `protobuf:"bytes,11,opt,name=Offset,proto3" json:"Offset,omitempty"`
	// OrderBy a given field of the object
	OrderBy string `protobuf:"bytes,12,opt,name=OrderBy,proto3" json:"OrderBy,omitempty"`
	// Order direction (asc/desc)
	OrderDir string `protobuf:"bytes,13,opt,name=OrderDir,proto3" json:"OrderDir,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectorRange) Descriptor deprecated 

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

Deprecated: Use SelectorRange.ProtoReflect.Descriptor instead.

func (*SelectorRange) GetLimit 

func (x *SelectorRange) GetLimit() string

func (*SelectorRange) GetOffset 

func (x *SelectorRange) GetOffset() string

func (*SelectorRange) GetOrderBy 

func (x *SelectorRange) GetOrderBy() string

func (*SelectorRange) GetOrderDir 

func (x *SelectorRange) GetOrderDir() string

func (*SelectorRange) ProtoMessage 

func (*SelectorRange) ProtoMessage()

func (*SelectorRange) ProtoReflect 

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

func (*SelectorRange) Reset 

func (x *SelectorRange) Reset()

func (*SelectorRange) String 

func (x *SelectorRange) String() string

type Task 

type Task struct {
	ID            string     `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	JobID         string     `protobuf:"bytes,2,opt,name=JobID,proto3" json:"JobID,omitempty"`
	Status        TaskStatus `protobuf:"varint,3,opt,name=Status,proto3,enum=jobs.TaskStatus" json:"Status,omitempty"`
	StatusMessage string     `protobuf:"bytes,4,opt,name=StatusMessage,proto3" json:"StatusMessage,omitempty"`
	TriggerOwner  string     `protobuf:"bytes,5,opt,name=TriggerOwner,proto3" json:"TriggerOwner,omitempty"`
	StartTime     int32      `protobuf:"varint,6,opt,name=StartTime,proto3" json:"StartTime,omitempty"`
	EndTime       int32      `protobuf:"varint,7,opt,name=EndTime,proto3" json:"EndTime,omitempty"`
	// Can be interrupted
	CanStop bool `protobuf:"varint,8,opt,name=CanStop,proto3" json:"CanStop,omitempty"`
	// Can be paused/resumed
	CanPause bool `protobuf:"varint,9,opt,name=CanPause,proto3" json:"CanPause,omitempty"`
	// Tasks publish a progress
	HasProgress bool `protobuf:"varint,10,opt,name=HasProgress,proto3" json:"HasProgress,omitempty"`
	// Float value of the progress between 0 and 1
	Progress float32 `protobuf:"fixed32,11,opt,name=Progress,proto3" json:"Progress,omitempty"`
	// Logs of all the actions performed
	ActionsLogs []*ActionLog `protobuf:"bytes,12,rep,name=ActionsLogs,proto3" json:"ActionsLogs,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetActionsLogs 

func (x *Task) GetActionsLogs() []*ActionLog

func (*Task) GetCanPause 

func (x *Task) GetCanPause() bool

func (*Task) GetCanStop 

func (x *Task) GetCanStop() bool

func (*Task) GetCtxOperationID 

func (task *Task) GetCtxOperationID() string

func (*Task) GetEndTime 

func (x *Task) GetEndTime() int32

func (*Task) GetHasProgress 

func (x *Task) GetHasProgress() bool

func (*Task) GetID 

func (x *Task) GetID() string

func (*Task) GetJobID 

func (x *Task) GetJobID() string

func (*Task) GetProgress 

func (x *Task) GetProgress() float32

func (*Task) GetStartTime 

func (x *Task) GetStartTime() int32

func (*Task) GetStatus 

func (x *Task) GetStatus() TaskStatus

func (*Task) GetStatusMessage 

func (x *Task) GetStatusMessage() string

func (*Task) GetTriggerOwner 

func (x *Task) GetTriggerOwner() string

func (*Task) MarshalLogObject 

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

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

func (*Task) Zap 

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

Zap simply returns a zapcore.Field object populated with this Task under a standard key

func (*Task) ZapId 

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

ZapId simply calls zap.String() with TaskId standard key and this Task Id

type TaskChangeEvent 

type TaskChangeEvent struct {
	TaskUpdated *Task             `protobuf:"bytes,1,opt,name=TaskUpdated,proto3" json:"TaskUpdated,omitempty"`
	Job         *Job              `protobuf:"bytes,2,opt,name=Job,proto3" json:"Job,omitempty"`
	NanoStamp   int64             `protobuf:"varint,3,opt,name=NanoStamp,proto3" json:"NanoStamp,omitempty"`
	StatusMeta  map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskChangeEvent) Descriptor deprecated 

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

Deprecated: Use TaskChangeEvent.ProtoReflect.Descriptor instead.

func (*TaskChangeEvent) GetJob 

func (x *TaskChangeEvent) GetJob() *Job

func (*TaskChangeEvent) GetNanoStamp 

func (x *TaskChangeEvent) GetNanoStamp() int64

func (*TaskChangeEvent) GetStatusMeta 

func (x *TaskChangeEvent) GetStatusMeta() map[string]string

func (*TaskChangeEvent) GetTaskUpdated 

func (x *TaskChangeEvent) GetTaskUpdated() *Task

func (*TaskChangeEvent) ProtoMessage 

func (*TaskChangeEvent) ProtoMessage()

func (*TaskChangeEvent) ProtoReflect 

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

func (*TaskChangeEvent) Reset 

func (x *TaskChangeEvent) Reset()

func (*TaskChangeEvent) String 

func (x *TaskChangeEvent) String() string

type TaskServiceClient 

type TaskServiceClient interface {
	Control(ctx context.Context, in *CtrlCommand, opts ...grpc.CallOption) (*CtrlCommandResponse, error)
}

TaskServiceClient is the client API for TaskService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	Control(context.Context, *CtrlCommand) (*CtrlCommandResponse, error)
	// contains filtered or unexported methods
}

TaskServiceServer is the server API for TaskService service. All implementations must embed UnimplementedTaskServiceServer for forward compatibility

type TaskStatus 

type TaskStatus int32

///////////////// TASK SERVICE // ///////////////// 

const (
	TaskStatus_Unknown     TaskStatus = 0
	TaskStatus_Idle        TaskStatus = 1
	TaskStatus_Running     TaskStatus = 2
	TaskStatus_Finished    TaskStatus = 3
	TaskStatus_Interrupted TaskStatus = 4
	TaskStatus_Paused      TaskStatus = 5
	TaskStatus_Any         TaskStatus = 6
	TaskStatus_Error       TaskStatus = 7
	TaskStatus_Queued      TaskStatus = 8
)

func (TaskStatus) Descriptor 

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum 

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor deprecated 

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

Deprecated: Use TaskStatus.Descriptor instead.

func (TaskStatus) Number 

func (x TaskStatus) Number() protoreflect.EnumNumber

func (TaskStatus) String 

func (x TaskStatus) String() string

func (TaskStatus) Type 

func (TaskStatus) Type() protoreflect.EnumType

type TriggerFilter 

type TriggerFilter struct {

	// Filter custom label
	Label string `protobuf:"bytes,1,opt,name=Label,proto3" json:"Label,omitempty"`
	// Filter additional description
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	// Filter type
	Query *service.Query `protobuf:"bytes,3,opt,name=Query,proto3" json:"Query,omitempty"`
	// contains filtered or unexported fields
}

Filter for events, can be applied on action branches

func (*TriggerFilter) Descriptor deprecated 

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

Deprecated: Use TriggerFilter.ProtoReflect.Descriptor instead.

func (*TriggerFilter) Filter 

func (m *TriggerFilter) Filter(ctx context.Context, input *ActionMessage) (*ActionMessage, *ActionMessage, bool)

func (*TriggerFilter) FilterID 

func (m *TriggerFilter) FilterID() string

func (*TriggerFilter) GetDescription 

func (x *TriggerFilter) GetDescription() string

func (*TriggerFilter) GetLabel 

func (x *TriggerFilter) GetLabel() string

func (*TriggerFilter) GetQuery 

func (x *TriggerFilter) GetQuery() *service.Query

func (*TriggerFilter) ProtoMessage 

func (*TriggerFilter) ProtoMessage()

func (*TriggerFilter) ProtoReflect 

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

func (*TriggerFilter) Reset 

func (x *TriggerFilter) Reset()

func (*TriggerFilter) String 

func (x *TriggerFilter) String() string

type TriggerFilterQuery 

type TriggerFilterQuery struct {

	// Event was triggered by a programed schedule
	IsSchedule bool `protobuf:"varint,1,opt,name=IsSchedule,proto3" json:"IsSchedule,omitempty"`
	// Event was triggered manually in the CellsFlows/Scheduler console
	IsManual bool `protobuf:"varint,2,opt,name=IsManual,proto3" json:"IsManual,omitempty"`
	// Event was triggered by a WebHook (can be in the user space)
	IsApiHook bool `protobuf:"varint,4,opt,name=IsApiHook,proto3" json:"IsApiHook,omitempty"`
	// Event was triggered by a specific WebHook (by its unique slug)
	ApiHookSlug string `protobuf:"bytes,5,opt,name=ApiHookSlug,proto3" json:"ApiHookSlug,omitempty"`
	// Filter by a name/value on a runtime defined parameter
	RunParameterName string `protobuf:"bytes,6,opt,name=RunParameterName,proto3" json:"RunParameterName,omitempty"`
	// Combined with RunParameterName, value used for comparison
	RunParameterValue string `protobuf:"bytes,7,opt,name=RunParameterValue,proto3" json:"RunParameterValue,omitempty"`
	// Event was trigger by one of these Events
	EventNames []string `protobuf:"bytes,3,rep,name=EventNames,proto3" json:"EventNames,omitempty"`
	// contains filtered or unexported fields
}

Atomic query for TriggerFilter

func (*TriggerFilterQuery) Descriptor deprecated 

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

Deprecated: Use TriggerFilterQuery.ProtoReflect.Descriptor instead.

func (*TriggerFilterQuery) GetApiHookSlug 

func (x *TriggerFilterQuery) GetApiHookSlug() string

func (*TriggerFilterQuery) GetEventNames 

func (x *TriggerFilterQuery) GetEventNames() []string

func (*TriggerFilterQuery) GetIsApiHook 

func (x *TriggerFilterQuery) GetIsApiHook() bool

func (*TriggerFilterQuery) GetIsManual 

func (x *TriggerFilterQuery) GetIsManual() bool

func (*TriggerFilterQuery) GetIsSchedule 

func (x *TriggerFilterQuery) GetIsSchedule() bool

func (*TriggerFilterQuery) GetRunParameterName 

func (x *TriggerFilterQuery) GetRunParameterName() string

func (*TriggerFilterQuery) GetRunParameterValue 

func (x *TriggerFilterQuery) GetRunParameterValue() string

func (*TriggerFilterQuery) ProtoMessage 

func (*TriggerFilterQuery) ProtoMessage()

func (*TriggerFilterQuery) ProtoReflect 

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

func (*TriggerFilterQuery) Reset 

func (x *TriggerFilterQuery) Reset()

func (*TriggerFilterQuery) String 

func (x *TriggerFilterQuery) String() string

type UnimplementedJobServiceServer 

type UnimplementedJobServiceServer struct {
}

UnimplementedJobServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedJobServiceServer) DeleteJob 

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

func (UnimplementedJobServiceServer) DeleteTasks 

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

func (UnimplementedJobServiceServer) DetectStuckTasks 

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

func (UnimplementedJobServiceServer) GetJob 

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

func (UnimplementedJobServiceServer) ListJobs 

func (UnimplementedJobServiceServer) ListJobs(*ListJobsRequest, JobService_ListJobsServer) error

func (UnimplementedJobServiceServer) ListTasks 

func (UnimplementedJobServiceServer) ListTasks(*ListTasksRequest, JobService_ListTasksServer) error

func (UnimplementedJobServiceServer) PutJob 

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

func (UnimplementedJobServiceServer) PutTask 

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

func (UnimplementedJobServiceServer) PutTaskStream 

func (UnimplementedJobServiceServer) PutTaskStream(JobService_PutTaskStreamServer) error

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) Control 

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

type UnsafeJobServiceServer 

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

UnsafeJobServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobServiceServer will result in compilation errors.

type UnsafeTaskServiceServer 

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

UnsafeTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskServiceServer will result in compilation errors.

type UsersSelector 

type UsersSelector struct {

	// Select all users
	All bool `protobuf:"varint,1,opt,name=All,proto3" json:"All,omitempty"`
	// Preset set of Users
	Users []*idm.User `protobuf:"bytes,2,rep,name=Users,proto3" json:"Users,omitempty"`
	// Filter users using this query
	Query *service.Query `protobuf:"bytes,3,opt,name=Query,proto3" json:"Query,omitempty"`
	// Wether to trigger one action per user or one action
	// with all user as a selection
	Collect bool `protobuf:"varint,5,opt,name=Collect,proto3" json:"Collect,omitempty"`
	// Selector custom label
	Label string `protobuf:"bytes,6,opt,name=Label,proto3" json:"Label,omitempty"`
	// Selector additional description
	Description string `protobuf:"bytes,7,opt,name=Description,proto3" json:"Description,omitempty"`
	// Optional Timeout for this selector
	Timeout string `protobuf:"bytes,8,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// Clear previous selection
	ClearInput bool `protobuf:"varint,9,opt,name=ClearInput,proto3" json:"ClearInput,omitempty"`
	// contains filtered or unexported fields
}

Select or filter users - should be replaced by more generic IdmSelector

func (*UsersSelector) ApplyClearInput 

func (m *UsersSelector) ApplyClearInput(msg *ActionMessage) *ActionMessage

func (*UsersSelector) Descriptor deprecated 

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

Deprecated: Use UsersSelector.ProtoReflect.Descriptor instead.

func (*UsersSelector) Filter 

func (n *UsersSelector) Filter(ctx context.Context, input *ActionMessage) (*ActionMessage, bool)

Filter is not implemented. Use IdmSelector object instead

func (*UsersSelector) GetAll 

func (x *UsersSelector) GetAll() bool

func (*UsersSelector) GetClearInput 

func (x *UsersSelector) GetClearInput() bool

func (*UsersSelector) GetCollect 

func (x *UsersSelector) GetCollect() bool

func (*UsersSelector) GetDescription 

func (x *UsersSelector) GetDescription() string

func (*UsersSelector) GetLabel 

func (x *UsersSelector) GetLabel() string

func (*UsersSelector) GetQuery 

func (x *UsersSelector) GetQuery() *service.Query

func (*UsersSelector) GetTimeout 

func (x *UsersSelector) GetTimeout() string

func (*UsersSelector) GetUsers 

func (x *UsersSelector) GetUsers() []*idm.User

func (*UsersSelector) MultipleSelection 

func (m *UsersSelector) MultipleSelection() bool

func (*UsersSelector) ProtoMessage 

func (*UsersSelector) ProtoMessage()

func (*UsersSelector) ProtoReflect 

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

func (*UsersSelector) Reset 

func (x *UsersSelector) Reset()

func (*UsersSelector) Select 

func (m *UsersSelector) Select(ctx context.Context, input *ActionMessage, objects chan interface{}, done chan bool) error

Select performs a query on the User Service to load a list of users. The more generic IdmSelector should be used instead.

func (*UsersSelector) SelectorID 

func (m *UsersSelector) SelectorID() string

func (*UsersSelector) SelectorLabel 

func (m *UsersSelector) SelectorLabel() string

func (*UsersSelector) String 

func (x *UsersSelector) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.