pb

type ActivateJobsRequest struct {

	// the job type, as defined in the BPMN process (e.g. <zeebe:taskDefinition
	// type="payment-service" />)
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// the name of the worker activating the jobs, mostly used for logging purposes
	Worker string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	// a job returned after this call will not be activated by another call until the
	// timeout (in ms) has been reached
	Timeout int64 `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// the maximum jobs to activate by this request
	MaxJobsToActivate int32 `protobuf:"varint,4,opt,name=maxJobsToActivate,proto3" json:"maxJobsToActivate,omitempty"`
	// a list of variables to fetch as the job variables; if empty, all visible variables at
	// the time of activation for the scope of the job will be returned
	FetchVariable []string `protobuf:"bytes,5,rep,name=fetchVariable,proto3" json:"fetchVariable,omitempty"`
	// The request will be completed when at least one job is activated or after the requestTimeout (in ms).
	// if the requestTimeout = 0, a default timeout is used.
	// if the requestTimeout < 0, long polling is disabled and the request is completed immediately, even when no job is activated.
	RequestTimeout int64 `protobuf:"varint,6,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
	// a list of IDs of tenants for which to activate jobs
	TenantIds []string `protobuf:"bytes,7,rep,name=tenantIds,proto3" json:"tenantIds,omitempty"`
	// contains filtered or unexported fields
}

type ActivateJobsResponse struct {

	// list of activated jobs
	Jobs []*ActivatedJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

type ActivatedJob struct {

	// the key, a unique identifier for the job
	Key int64 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	// the type of the job (should match what was requested)
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// the job's process instance key
	ProcessInstanceKey int64 `protobuf:"varint,3,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	// the bpmn process ID of the job process definition
	BpmnProcessId string `protobuf:"bytes,4,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	// the version of the job process definition
	ProcessDefinitionVersion int32 `protobuf:"varint,5,opt,name=processDefinitionVersion,proto3" json:"processDefinitionVersion,omitempty"`
	// the key of the job process definition
	ProcessDefinitionKey int64 `protobuf:"varint,6,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	// the associated task element ID
	ElementId string `protobuf:"bytes,7,opt,name=elementId,proto3" json:"elementId,omitempty"`
	// the unique key identifying the associated task, unique within the scope of the
	// process instance
	ElementInstanceKey int64 `protobuf:"varint,8,opt,name=elementInstanceKey,proto3" json:"elementInstanceKey,omitempty"`
	// a set of custom headers defined during modelling; returned as a serialized
	// JSON document
	CustomHeaders string `protobuf:"bytes,9,opt,name=customHeaders,proto3" json:"customHeaders,omitempty"`
	// the name of the worker which activated this job
	Worker string `protobuf:"bytes,10,opt,name=worker,proto3" json:"worker,omitempty"`
	// the amount of retries left to this job (should always be positive)
	Retries int32 `protobuf:"varint,11,opt,name=retries,proto3" json:"retries,omitempty"`
	// when the job can be activated again, sent as a UNIX epoch timestamp
	Deadline int64 `protobuf:"varint,12,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// JSON document, computed at activation time, consisting of all visible variables to
	// the task scope
	Variables string `protobuf:"bytes,13,opt,name=variables,proto3" json:"variables,omitempty"`
	// the id of the tenant that owns the job
	TenantId string `protobuf:"bytes,14,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type BroadcastSignalRequest struct {

	// The name of the signal
	SignalName string `protobuf:"bytes,1,opt,name=signalName,proto3" json:"signalName,omitempty"`
	// the signal variables as a JSON document; to be valid, the root of the document must be an
	// object, e.g. { "a": "foo" }. [ "foo" ] would not be valid.
	Variables string `protobuf:"bytes,2,opt,name=variables,proto3" json:"variables,omitempty"`
	// the id of the tenant that owns the signal.
	TenantId string `protobuf:"bytes,3,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type BroadcastSignalResponse struct {

	// the unique ID of the signal that was broadcasted.
	Key int64 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	// the tenant id of the signal that was broadcasted.
	TenantId string `protobuf:"bytes,2,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type BrokerInfo struct {

	// unique (within a cluster) node ID for the broker
	NodeId int32 `protobuf:"varint,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// hostname of the broker
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// port for the broker
	Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// list of partitions managed or replicated on this broker
	Partitions []*Partition `protobuf:"bytes,4,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// broker version
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type CancelProcessInstanceRequest struct {

	// the process instance key (as, for example, obtained from
	// CreateProcessInstanceResponse)
	ProcessInstanceKey int64 `protobuf:"varint,1,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	// contains filtered or unexported fields
}

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

type CompleteJobRequest struct {

	// the unique job identifier, as obtained from ActivateJobsResponse
	JobKey int64 `protobuf:"varint,1,opt,name=jobKey,proto3" json:"jobKey,omitempty"`
	// a JSON document representing the variables in the current task scope
	Variables string `protobuf:"bytes,2,opt,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

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

type CreateProcessInstanceRequest struct {

	// the unique key identifying the process definition (e.g. returned from a process
	// in the DeployProcessResponse message)
	ProcessDefinitionKey int64 `protobuf:"varint,1,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	// the BPMN process ID of the process definition
	BpmnProcessId string `protobuf:"bytes,2,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	// the version of the process; set to -1 to use the latest version
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// JSON document that will instantiate the variables for the root variable scope of the
	// process instance; it must be a JSON object, as variables will be mapped in a
	// key-value fashion. e.g. { "a": 1, "b": 2 } will create two variables, named "a" and
	// "b" respectively, with their associated values. [{ "a": 1, "b": 2 }] would not be a
	// valid argument, as the root of the JSON document is an array and not an object.
	Variables string `protobuf:"bytes,4,opt,name=variables,proto3" json:"variables,omitempty"`
	// List of start instructions. If empty (default) the process instance
	// will start at the start event. If non-empty the process instance will apply start
	// instructions after it has been created
	StartInstructions []*ProcessInstanceCreationStartInstruction `protobuf:"bytes,5,rep,name=startInstructions,proto3" json:"startInstructions,omitempty"`
	// the tenant id of the process definition
	TenantId string `protobuf:"bytes,6,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type CreateProcessInstanceResponse struct {

	// the key of the process definition which was used to create the process instance
	ProcessDefinitionKey int64 `protobuf:"varint,1,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	// the BPMN process ID of the process definition which was used to create the process
	// instance
	BpmnProcessId string `protobuf:"bytes,2,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	// the version of the process definition which was used to create the process instance
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// the unique identifier of the created process instance; to be used wherever a request
	// needs a process instance key (e.g. CancelProcessInstanceRequest)
	ProcessInstanceKey int64 `protobuf:"varint,4,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	// the tenant identifier of the created process instance
	TenantId string `protobuf:"bytes,5,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type CreateProcessInstanceWithResultRequest struct {
	Request *CreateProcessInstanceRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// timeout (in ms). the request will be closed if the process is not completed
	// before the requestTimeout.
	// if requestTimeout = 0, uses the generic requestTimeout configured in the gateway.
	RequestTimeout int64 `protobuf:"varint,2,opt,name=requestTimeout,proto3" json:"requestTimeout,omitempty"`
	// list of names of variables to be included in `CreateProcessInstanceWithResultResponse.variables`
	// if empty, all visible variables in the root scope will be returned.
	FetchVariables []string `protobuf:"bytes,3,rep,name=fetchVariables,proto3" json:"fetchVariables,omitempty"`
	// contains filtered or unexported fields
}

type CreateProcessInstanceWithResultResponse struct {

	// the key of the process definition which was used to create the process instance
	ProcessDefinitionKey int64 `protobuf:"varint,1,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	// the BPMN process ID of the process definition which was used to create the process
	// instance
	BpmnProcessId string `protobuf:"bytes,2,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	// the version of the process definition which was used to create the process instance
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// the unique identifier of the created process instance; to be used wherever a request
	// needs a process instance key (e.g. CancelProcessInstanceRequest)
	ProcessInstanceKey int64 `protobuf:"varint,4,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	// JSON document
	// consists of visible variables in the root scope
	Variables string `protobuf:"bytes,5,opt,name=variables,proto3" json:"variables,omitempty"`
	// the tenant identifier of the process definition
	TenantId string `protobuf:"bytes,6,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type DecisionMetadata struct {

	// the dmn decision ID, as parsed during deployment; together with the
	// versions forms a unique identifier for a specific decision
	DmnDecisionId string `protobuf:"bytes,1,opt,name=dmnDecisionId,proto3" json:"dmnDecisionId,omitempty"`
	// the dmn name of the decision, as parsed during deployment
	DmnDecisionName string `protobuf:"bytes,2,opt,name=dmnDecisionName,proto3" json:"dmnDecisionName,omitempty"`
	// the assigned decision version
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// the assigned decision key, which acts as a unique identifier for this
	// decision
	DecisionKey int64 `protobuf:"varint,4,opt,name=decisionKey,proto3" json:"decisionKey,omitempty"`
	// the dmn ID of the decision requirements graph that this decision is part
	// of, as parsed during deployment
	DmnDecisionRequirementsId string `protobuf:"bytes,5,opt,name=dmnDecisionRequirementsId,proto3" json:"dmnDecisionRequirementsId,omitempty"`
	// the assigned key of the decision requirements graph that this decision is
	// part of
	DecisionRequirementsKey int64 `protobuf:"varint,6,opt,name=decisionRequirementsKey,proto3" json:"decisionRequirementsKey,omitempty"`
	// the tenant id of the deployed decision
	TenantId string `protobuf:"bytes,7,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type DecisionRequirementsMetadata struct {

	// the dmn decision requirements ID, as parsed during deployment; together
	// with the versions forms a unique identifier for a specific decision
	DmnDecisionRequirementsId string `protobuf:"bytes,1,opt,name=dmnDecisionRequirementsId,proto3" json:"dmnDecisionRequirementsId,omitempty"`
	// the dmn name of the decision requirements, as parsed during deployment
	DmnDecisionRequirementsName string `protobuf:"bytes,2,opt,name=dmnDecisionRequirementsName,proto3" json:"dmnDecisionRequirementsName,omitempty"`
	// the assigned decision requirements version
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// the assigned decision requirements key, which acts as a unique identifier
	// for this decision requirements
	DecisionRequirementsKey int64 `protobuf:"varint,4,opt,name=decisionRequirementsKey,proto3" json:"decisionRequirementsKey,omitempty"`
	// the resource name (see: Resource.name) from which this decision
	// requirements was parsed
	ResourceName string `protobuf:"bytes,5,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	// the tenant id of the deployed decision requirements
	TenantId string `protobuf:"bytes,6,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type DeleteResourceRequest struct {

	// The key of the resource that should be deleted. This can either be the key
	// of a process definition, the key of a decision requirements definition or the key of a form.
	ResourceKey int64 `protobuf:"varint,1,opt,name=resourceKey,proto3" json:"resourceKey,omitempty"`
	// contains filtered or unexported fields
}

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

type DeployResourceRequest struct {

	// list of resources to deploy
	Resources []*Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// the tenant id of the resources to deploy
	TenantId string `protobuf:"bytes,2,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type DeployResourceResponse struct {

	// the unique key identifying the deployment
	Key int64 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	// a list of deployed resources, e.g. processes
	Deployments []*Deployment `protobuf:"bytes,2,rep,name=deployments,proto3" json:"deployments,omitempty"`
	// the tenant id of the deployed resources
	TenantId string `protobuf:"bytes,3,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type Deployment struct {

	// each deployment has only one metadata
	//
	// Types that are assignable to Metadata:
	//
	//	*Deployment_Process
	//	*Deployment_Decision
	//	*Deployment_DecisionRequirements
	//	*Deployment_Form
	Metadata isDeployment_Metadata `protobuf_oneof:"Metadata"`
	// contains filtered or unexported fields
}

type Deployment_Decision struct {
	// metadata of a deployed decision
	Decision *DecisionMetadata `protobuf:"bytes,2,opt,name=decision,proto3,oneof"`
}

type Deployment_DecisionRequirements struct {
	// metadata of a deployed decision requirements
	DecisionRequirements *DecisionRequirementsMetadata `protobuf:"bytes,3,opt,name=decisionRequirements,proto3,oneof"`
}

type Deployment_Form struct {
	// metadata of a deployed form
	Form *FormMetadata `protobuf:"bytes,4,opt,name=form,proto3,oneof"`
}

type Deployment_Process struct {
	// metadata of a deployed process
	Process *ProcessMetadata `protobuf:"bytes,1,opt,name=process,proto3,oneof"`
}

type EvaluateDecisionRequest struct {

	// the unique key identifying the decision to be evaluated (e.g. returned
	// from a decision in the DeployResourceResponse message)
	DecisionKey int64 `protobuf:"varint,1,opt,name=decisionKey,proto3" json:"decisionKey,omitempty"`
	// the ID of the decision to be evaluated
	DecisionId string `protobuf:"bytes,2,opt,name=decisionId,proto3" json:"decisionId,omitempty"`
	// JSON document that will instantiate the variables for the decision to be
	// evaluated; it must be a JSON object, as variables will be mapped in a
	// key-value fashion, e.g. { "a": 1, "b": 2 } will create two variables,
	// named "a" and "b" respectively, with their associated values.
	// [{ "a": 1, "b": 2 }] would not be a valid argument, as the root of the
	// JSON document is an array and not an object.
	Variables string `protobuf:"bytes,3,opt,name=variables,proto3" json:"variables,omitempty"`
	// the tenant identifier of the decision
	TenantId string `protobuf:"bytes,4,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type EvaluateDecisionResponse struct {

	// the unique key identifying the decision which was evaluated (e.g. returned
	// from a decision in the DeployResourceResponse message)
	DecisionKey int64 `protobuf:"varint,1,opt,name=decisionKey,proto3" json:"decisionKey,omitempty"`
	// the ID of the decision which was evaluated
	DecisionId string `protobuf:"bytes,2,opt,name=decisionId,proto3" json:"decisionId,omitempty"`
	// the name of the decision which was evaluated
	DecisionName string `protobuf:"bytes,3,opt,name=decisionName,proto3" json:"decisionName,omitempty"`
	// the version of the decision which was evaluated
	DecisionVersion int32 `protobuf:"varint,4,opt,name=decisionVersion,proto3" json:"decisionVersion,omitempty"`
	// the ID of the decision requirements graph that the decision which was
	// evaluated is part of.
	DecisionRequirementsId string `protobuf:"bytes,5,opt,name=decisionRequirementsId,proto3" json:"decisionRequirementsId,omitempty"`
	// the unique key identifying the decision requirements graph that the
	// decision which was evaluated is part of.
	DecisionRequirementsKey int64 `protobuf:"varint,6,opt,name=decisionRequirementsKey,proto3" json:"decisionRequirementsKey,omitempty"`
	// JSON document that will instantiate the result of the decision which was
	// evaluated; it will be a JSON object, as the result output will be mapped
	// in a key-value fashion, e.g. { "a": 1 }.
	DecisionOutput string `protobuf:"bytes,7,opt,name=decisionOutput,proto3" json:"decisionOutput,omitempty"`
	// a list of decisions that were evaluated within the requested decision evaluation
	EvaluatedDecisions []*EvaluatedDecision `protobuf:"bytes,8,rep,name=evaluatedDecisions,proto3" json:"evaluatedDecisions,omitempty"`
	// an optional string indicating the ID of the decision which
	// failed during evaluation
	FailedDecisionId string `protobuf:"bytes,9,opt,name=failedDecisionId,proto3" json:"failedDecisionId,omitempty"`
	// an optional message describing why the decision which was evaluated failed
	FailureMessage string `protobuf:"bytes,10,opt,name=failureMessage,proto3" json:"failureMessage,omitempty"`
	// the tenant identifier of the evaluated decision
	TenantId string `protobuf:"bytes,11,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type EvaluatedDecision struct {

	// the unique key identifying the decision which was evaluated (e.g. returned
	// from a decision in the DeployResourceResponse message)
	DecisionKey int64 `protobuf:"varint,1,opt,name=decisionKey,proto3" json:"decisionKey,omitempty"`
	// the ID of the decision which was evaluated
	DecisionId string `protobuf:"bytes,2,opt,name=decisionId,proto3" json:"decisionId,omitempty"`
	// the name of the decision which was evaluated
	DecisionName string `protobuf:"bytes,3,opt,name=decisionName,proto3" json:"decisionName,omitempty"`
	// the version of the decision which was evaluated
	DecisionVersion int32 `protobuf:"varint,4,opt,name=decisionVersion,proto3" json:"decisionVersion,omitempty"`
	// the type of the decision which was evaluated
	DecisionType string `protobuf:"bytes,5,opt,name=decisionType,proto3" json:"decisionType,omitempty"`
	// JSON document that will instantiate the result of the decision which was
	// evaluated; it will be a JSON object, as the result output will be mapped
	// in a key-value fashion, e.g. { "a": 1 }.
	DecisionOutput string `protobuf:"bytes,6,opt,name=decisionOutput,proto3" json:"decisionOutput,omitempty"`
	// the decision rules that matched within this decision evaluation
	MatchedRules []*MatchedDecisionRule `protobuf:"bytes,7,rep,name=matchedRules,proto3" json:"matchedRules,omitempty"`
	// the decision inputs that were evaluated within this decision evaluation
	EvaluatedInputs []*EvaluatedDecisionInput `protobuf:"bytes,8,rep,name=evaluatedInputs,proto3" json:"evaluatedInputs,omitempty"`
	// the tenant identifier of the evaluated decision
	TenantId string `protobuf:"bytes,9,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type EvaluatedDecisionInput struct {

	// the id of the evaluated decision input
	InputId string `protobuf:"bytes,1,opt,name=inputId,proto3" json:"inputId,omitempty"`
	// the name of the evaluated decision input
	InputName string `protobuf:"bytes,2,opt,name=inputName,proto3" json:"inputName,omitempty"`
	// the value of the evaluated decision input
	InputValue string `protobuf:"bytes,3,opt,name=inputValue,proto3" json:"inputValue,omitempty"`
	// contains filtered or unexported fields
}

type EvaluatedDecisionOutput struct {

	// the id of the evaluated decision output
	OutputId string `protobuf:"bytes,1,opt,name=outputId,proto3" json:"outputId,omitempty"`
	// the name of the evaluated decision output
	OutputName string `protobuf:"bytes,2,opt,name=outputName,proto3" json:"outputName,omitempty"`
	// the value of the evaluated decision output
	OutputValue string `protobuf:"bytes,3,opt,name=outputValue,proto3" json:"outputValue,omitempty"`
	// contains filtered or unexported fields
}

type FailJobRequest struct {

	// the unique job identifier, as obtained when activating the job
	JobKey int64 `protobuf:"varint,1,opt,name=jobKey,proto3" json:"jobKey,omitempty"`
	// the amount of retries the job should have left
	Retries int32 `protobuf:"varint,2,opt,name=retries,proto3" json:"retries,omitempty"`
	// an optional message describing why the job failed
	// this is particularly useful if a job runs out of retries and an incident is raised,
	// as it this message can help explain why an incident was raised
	ErrorMessage string `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// the backoff timeout (in ms) for the next retry
	RetryBackOff int64 `protobuf:"varint,4,opt,name=retryBackOff,proto3" json:"retryBackOff,omitempty"`
	// JSON document that will instantiate the variables at the local scope of the
	// job's associated task; it must be a JSON object, as variables will be mapped in a
	// key-value fashion. e.g. { "a": 1, "b": 2 } will create two variables, named "a" and
	// "b" respectively, with their associated values. [{ "a": 1, "b": 2 }] would not be a
	// valid argument, as the root of the JSON document is an array and not an object.
	Variables string `protobuf:"bytes,5,opt,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

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

type FormMetadata struct {

	// the form ID, as parsed during deployment; together with the
	// versions forms a unique identifier for a specific form
	FormId string `protobuf:"bytes,1,opt,name=formId,proto3" json:"formId,omitempty"`
	// the assigned form version
	Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// the assigned key, which acts as a unique identifier for this form
	FormKey int64 `protobuf:"varint,3,opt,name=formKey,proto3" json:"formKey,omitempty"`
	// the resource name
	ResourceName string `protobuf:"bytes,4,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	// the tenant id of the deployed form
	TenantId string `protobuf:"bytes,5,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type GatewayClient interface {
	// Iterates through all known partitions round-robin and activates up to the requested
	// maximum and streams them back to the client as they are activated.
	//
	// Errors:
	// INVALID_ARGUMENT:
	// - type is blank (empty string, null)
	// - worker is blank (empty string, null)
	// - timeout less than 1
	// - maxJobsToActivate is less than 1
	ActivateJobs(ctx context.Context, in *ActivateJobsRequest, opts ...grpc.CallOption) (Gateway_ActivateJobsClient, error)
	// Registers client to a job stream that will stream jobs back to the client as
	// they become activatable.
	//
	// Errors:
	// INVALID_ARGUMENT:
	// - type is blank (empty string, null)
	// - timeout less than 1
	StreamActivatedJobs(ctx context.Context, in *StreamActivatedJobsRequest, opts ...grpc.CallOption) (Gateway_StreamActivatedJobsClient, error)
	// Cancels a running process instance
	//
	// Errors:
	// NOT_FOUND:
	// - no process instance exists with the given key
	CancelProcessInstance(ctx context.Context, in *CancelProcessInstanceRequest, opts ...grpc.CallOption) (*CancelProcessInstanceResponse, error)
	// Completes a job with the given variables, which allows completing the associated service task.
	//
	// Errors:
	// NOT_FOUND:
	// - no job exists with the given job key. Note that since jobs are removed once completed,
	// it could be that this job did exist at some point.
	//
	// FAILED_PRECONDITION:
	// - the job was marked as failed. In that case, the related incident must be resolved before
	// the job can be activated again and completed.
	CompleteJob(ctx context.Context, in *CompleteJobRequest, opts ...grpc.CallOption) (*CompleteJobResponse, error)
	// Creates and starts an instance of the specified process. The process definition to use to
	// create the instance can be specified either using its unique key (as returned by
	// DeployProcess), or using the BPMN process ID and a version. Pass -1 as the version to use the
	// latest deployed version. Note that only processes with none start events can be started through
	// this command.
	//
	// Errors:
	// NOT_FOUND:
	// - no process with the given key exists (if processDefinitionKey was given)
	// - no process with the given process ID exists (if bpmnProcessId was given but version was -1)
	// - no process with the given process ID and version exists (if both bpmnProcessId and version were given)
	//
	// FAILED_PRECONDITION:
	// - the process definition does not contain a none start event; only processes with none
	// start event can be started manually.
	//
	// INVALID_ARGUMENT:
	// - the given variables argument is not a valid JSON document; it is expected to be a valid
	// JSON document where the root node is an object.
	CreateProcessInstance(ctx context.Context, in *CreateProcessInstanceRequest, opts ...grpc.CallOption) (*CreateProcessInstanceResponse, error)
	// Behaves similarly to `rpc CreateProcessInstance`, except that a successful response is received when the process completes successfully.
	CreateProcessInstanceWithResult(ctx context.Context, in *CreateProcessInstanceWithResultRequest, opts ...grpc.CallOption) (*CreateProcessInstanceWithResultResponse, error)
	// Evaluates a decision. The decision to evaluate can be specified either by
	// using its unique key (as returned by DeployResource), or using the decision
	// ID. When using the decision ID, the latest deployed version of the decision
	// is used.
	//
	// Errors:
	// INVALID_ARGUMENT:
	// - no decision with the given key exists (if decisionKey was given)
	// - no decision with the given decision ID exists (if decisionId was given)
	// - both decision ID and decision KEY were provided, or are missing
	EvaluateDecision(ctx context.Context, in *EvaluateDecisionRequest, opts ...grpc.CallOption) (*EvaluateDecisionResponse, error)
	// Deprecated: Do not use.
	//
	// Deploys one or more processes to Zeebe. Note that this is an atomic call,
	// i.e. either all processes are deployed, or none of them are.
	//
	// Errors:
	// INVALID_ARGUMENT:
	// - no resources given.
	// - if at least one resource is invalid. A resource is considered invalid if:
	// - the resource data is not deserializable (e.g. detected as BPMN, but it's broken XML)
	// - the process is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
	DeployProcess(ctx context.Context, in *DeployProcessRequest, opts ...grpc.CallOption) (*DeployProcessResponse, error)
	// Deploys one or more resources (e.g. processes or decision models) to Zeebe.
	// Note that this is an atomic call, i.e. either all resources are deployed, or none of them are.
	//
	// Errors:
	// PERMISSION_DENIED:
	// - if a deployment to an unauthorized tenant is performed
	// INVALID_ARGUMENT:
	// - no resources given.
	// - if at least one resource is invalid. A resource is considered invalid if:
	// - the content is not deserializable (e.g. detected as BPMN, but it's broken XML)
	// - the content is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
	// - if multi-tenancy is enabled, and:
	// - a tenant id is not provided
	// - a tenant id with an invalid format is provided
	// - if multi-tenancy is disabled and a tenant id is provided
	DeployResource(ctx context.Context, in *DeployResourceRequest, opts ...grpc.CallOption) (*DeployResourceResponse, error)
	// Marks the job as failed; if the retries argument is positive, then the job will be immediately
	// activatable again, and a worker could try again to process it. If it is zero or negative however,
	// an incident will be raised, tagged with the given errorMessage, and the job will not be
	// activatable until the incident is resolved.
	//
	// Errors:
	// NOT_FOUND:
	// - no job was found with the given key
	//
	// FAILED_PRECONDITION:
	// - the job was not activated
	// - the job is already in a failed state, i.e. ran out of retries
	FailJob(ctx context.Context, in *FailJobRequest, opts ...grpc.CallOption) (*FailJobResponse, error)
	// Reports a business error (i.e. non-technical) that occurs while processing a job. The error is handled in the process by an error catch event. If there is no error catch event with the specified errorCode then an incident will be raised instead.
	//
	// Errors:
	// NOT_FOUND:
	// - no job was found with the given key
	//
	// FAILED_PRECONDITION:
	// - the job is not in an activated state
	ThrowError(ctx context.Context, in *ThrowErrorRequest, opts ...grpc.CallOption) (*ThrowErrorResponse, error)
	// Publishes a single message. Messages are published to specific partitions computed from their
	// correlation keys.
	//
	// Errors:
	// ALREADY_EXISTS:
	// - a message with the same ID was previously published (and is still alive)
	PublishMessage(ctx context.Context, in *PublishMessageRequest, opts ...grpc.CallOption) (*PublishMessageResponse, error)
	// Resolves a given incident. This simply marks the incident as resolved; most likely a call to
	// UpdateJobRetries or SetVariables will be necessary to actually resolve the
	// problem, following by this call.
	//
	// Errors:
	// NOT_FOUND:
	// - no incident with the given key exists
	ResolveIncident(ctx context.Context, in *ResolveIncidentRequest, opts ...grpc.CallOption) (*ResolveIncidentResponse, error)
	// Updates all the variables of a particular scope (e.g. process instance, flow element instance)
	// from the given JSON document.
	//
	// Errors:
	// NOT_FOUND:
	// - no element with the given elementInstanceKey exists
	// INVALID_ARGUMENT:
	// - the given variables document is not a valid JSON document; valid documents are expected to
	// be JSON documents where the root node is an object.
	SetVariables(ctx context.Context, in *SetVariablesRequest, opts ...grpc.CallOption) (*SetVariablesResponse, error)
	// Obtains the current topology of the cluster the gateway is part of.
	Topology(ctx context.Context, in *TopologyRequest, opts ...grpc.CallOption) (*TopologyResponse, error)
	// Updates the number of retries a job has left. This is mostly useful for jobs that have run out of
	// retries, should the underlying problem be solved.
	//
	// Errors:
	// NOT_FOUND:
	// - no job exists with the given key
	//
	// INVALID_ARGUMENT:
	// - retries is not greater than 0
	UpdateJobRetries(ctx context.Context, in *UpdateJobRetriesRequest, opts ...grpc.CallOption) (*UpdateJobRetriesResponse, error)
	// Modifies the process instance. This is done by activating and/or terminating specific elements of the instance.
	//
	// Errors:
	// NOT_FOUND:
	// - no process instance exists with the given key
	//
	// FAILED_PRECONDITION:
	// - trying to activate element inside of a multi-instance
	//
	// INVALID_ARGUMENT:
	// - activating or terminating unknown element
	// - ancestor of element for activation doesn't exist
	// - scope of variable is unknown
	ModifyProcessInstance(ctx context.Context, in *ModifyProcessInstanceRequest, opts ...grpc.CallOption) (*ModifyProcessInstanceResponse, error)
	// Migrates the process instance to the specified process definition.
	// In simple terms, this is handled by updating the active element's process.
	//
	// Errors:
	// NOT_FOUND:
	// - the process instance referenced by `processInstanceKey` is not active
	//
	// FAILED_PRECONDITION:
	// - not all active elements in the source process instance are mapped to the elements in the target process
	// - a mapping instruction changes the type of an element or event
	// - a mapping instruction refers to an unsupported element (i.e. some elements will be supported later on)
	// - a mapping instruction refers to element in unsupported scenarios.
	// (i.e. migrating active elements with event subscriptions will be supported later on)
	//
	// INVALID_ARGUMENT:
	// - the source element id does not refer to an element in the source process definition
	// - a source element id is mapped by multiple mapping instructions.
	// For example, the engine cannot determine how to migrate a process instance when the instructions are: [A->B, A->C].
	MigrateProcessInstance(ctx context.Context, in *MigrateProcessInstanceRequest, opts ...grpc.CallOption) (*MigrateProcessInstanceResponse, error)
	// Updates the deadline of a job using the timeout (in ms) provided. This can be used
	// for extending or shortening the job deadline.
	//
	// Errors:
	// NOT_FOUND:
	// - no job exists with the given key
	//
	// INVALID_STATE:
	// - no deadline exists for the given job key
	UpdateJobTimeout(ctx context.Context, in *UpdateJobTimeoutRequest, opts ...grpc.CallOption) (*UpdateJobTimeoutResponse, error)
	// Deletes a resource from the state. Once a resource has been deleted it cannot
	// be recovered. If the resource needs to be available again, a new deployment
	// of the resource is required.
	//
	// Deleting a process will cancel any running instances of this process
	// definition. New instances of a deleted process are created using
	// the lastest version that hasn't been deleted. Creating a new
	// process instance is impossible when all versions have been
	// deleted.
	//
	// Deleting a decision requirement definitions could cause incidents in process
	// instances referencing these decisions in a business rule task. A decision
	// will be evaluated with the latest version that hasn't been deleted. If all
	// versions of a decision have been deleted the evaluation is rejected.
	//
	// Errors:
	// NOT_FOUND:
	// - No resource exists with the given key
	DeleteResource(ctx context.Context, in *DeleteResourceRequest, opts ...grpc.CallOption) (*DeleteResourceResponse, error)
	// Broadcasts a signal.
	BroadcastSignal(ctx context.Context, in *BroadcastSignalRequest, opts ...grpc.CallOption) (*BroadcastSignalResponse, error)
}

type GatewayServer interface {
	// Iterates through all known partitions round-robin and activates up to the requested
	// maximum and streams them back to the client as they are activated.
	//
	// Errors:
	// INVALID_ARGUMENT:
	// - type is blank (empty string, null)
	// - worker is blank (empty string, null)
	// - timeout less than 1
	// - maxJobsToActivate is less than 1
	ActivateJobs(*ActivateJobsRequest, Gateway_ActivateJobsServer) error
	// Registers client to a job stream that will stream jobs back to the client as
	// they become activatable.
	//
	// Errors:
	// INVALID_ARGUMENT:
	// - type is blank (empty string, null)
	// - timeout less than 1
	StreamActivatedJobs(*StreamActivatedJobsRequest, Gateway_StreamActivatedJobsServer) error
	// Cancels a running process instance
	//
	// Errors:
	// NOT_FOUND:
	// - no process instance exists with the given key
	CancelProcessInstance(context.Context, *CancelProcessInstanceRequest) (*CancelProcessInstanceResponse, error)
	// Completes a job with the given variables, which allows completing the associated service task.
	//
	// Errors:
	// NOT_FOUND:
	// - no job exists with the given job key. Note that since jobs are removed once completed,
	// it could be that this job did exist at some point.
	//
	// FAILED_PRECONDITION:
	// - the job was marked as failed. In that case, the related incident must be resolved before
	// the job can be activated again and completed.
	CompleteJob(context.Context, *CompleteJobRequest) (*CompleteJobResponse, error)
	// Creates and starts an instance of the specified process. The process definition to use to
	// create the instance can be specified either using its unique key (as returned by
	// DeployProcess), or using the BPMN process ID and a version. Pass -1 as the version to use the
	// latest deployed version. Note that only processes with none start events can be started through
	// this command.
	//
	// Errors:
	// NOT_FOUND:
	// - no process with the given key exists (if processDefinitionKey was given)
	// - no process with the given process ID exists (if bpmnProcessId was given but version was -1)
	// - no process with the given process ID and version exists (if both bpmnProcessId and version were given)
	//
	// FAILED_PRECONDITION:
	// - the process definition does not contain a none start event; only processes with none
	// start event can be started manually.
	//
	// INVALID_ARGUMENT:
	// - the given variables argument is not a valid JSON document; it is expected to be a valid
	// JSON document where the root node is an object.
	CreateProcessInstance(context.Context, *CreateProcessInstanceRequest) (*CreateProcessInstanceResponse, error)
	// Behaves similarly to `rpc CreateProcessInstance`, except that a successful response is received when the process completes successfully.
	CreateProcessInstanceWithResult(context.Context, *CreateProcessInstanceWithResultRequest) (*CreateProcessInstanceWithResultResponse, error)
	// Evaluates a decision. The decision to evaluate can be specified either by
	// using its unique key (as returned by DeployResource), or using the decision
	// ID. When using the decision ID, the latest deployed version of the decision
	// is used.
	//
	// Errors:
	// INVALID_ARGUMENT:
	// - no decision with the given key exists (if decisionKey was given)
	// - no decision with the given decision ID exists (if decisionId was given)
	// - both decision ID and decision KEY were provided, or are missing
	EvaluateDecision(context.Context, *EvaluateDecisionRequest) (*EvaluateDecisionResponse, error)
	// Deprecated: Do not use.
	//
	// Deploys one or more processes to Zeebe. Note that this is an atomic call,
	// i.e. either all processes are deployed, or none of them are.
	//
	// Errors:
	// INVALID_ARGUMENT:
	// - no resources given.
	// - if at least one resource is invalid. A resource is considered invalid if:
	// - the resource data is not deserializable (e.g. detected as BPMN, but it's broken XML)
	// - the process is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
	DeployProcess(context.Context, *DeployProcessRequest) (*DeployProcessResponse, error)
	// Deploys one or more resources (e.g. processes or decision models) to Zeebe.
	// Note that this is an atomic call, i.e. either all resources are deployed, or none of them are.
	//
	// Errors:
	// PERMISSION_DENIED:
	// - if a deployment to an unauthorized tenant is performed
	// INVALID_ARGUMENT:
	// - no resources given.
	// - if at least one resource is invalid. A resource is considered invalid if:
	// - the content is not deserializable (e.g. detected as BPMN, but it's broken XML)
	// - the content is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
	// - if multi-tenancy is enabled, and:
	// - a tenant id is not provided
	// - a tenant id with an invalid format is provided
	// - if multi-tenancy is disabled and a tenant id is provided
	DeployResource(context.Context, *DeployResourceRequest) (*DeployResourceResponse, error)
	// Marks the job as failed; if the retries argument is positive, then the job will be immediately
	// activatable again, and a worker could try again to process it. If it is zero or negative however,
	// an incident will be raised, tagged with the given errorMessage, and the job will not be
	// activatable until the incident is resolved.
	//
	// Errors:
	// NOT_FOUND:
	// - no job was found with the given key
	//
	// FAILED_PRECONDITION:
	// - the job was not activated
	// - the job is already in a failed state, i.e. ran out of retries
	FailJob(context.Context, *FailJobRequest) (*FailJobResponse, error)
	// Reports a business error (i.e. non-technical) that occurs while processing a job. The error is handled in the process by an error catch event. If there is no error catch event with the specified errorCode then an incident will be raised instead.
	//
	// Errors:
	// NOT_FOUND:
	// - no job was found with the given key
	//
	// FAILED_PRECONDITION:
	// - the job is not in an activated state
	ThrowError(context.Context, *ThrowErrorRequest) (*ThrowErrorResponse, error)
	// Publishes a single message. Messages are published to specific partitions computed from their
	// correlation keys.
	//
	// Errors:
	// ALREADY_EXISTS:
	// - a message with the same ID was previously published (and is still alive)
	PublishMessage(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error)
	// Resolves a given incident. This simply marks the incident as resolved; most likely a call to
	// UpdateJobRetries or SetVariables will be necessary to actually resolve the
	// problem, following by this call.
	//
	// Errors:
	// NOT_FOUND:
	// - no incident with the given key exists
	ResolveIncident(context.Context, *ResolveIncidentRequest) (*ResolveIncidentResponse, error)
	// Updates all the variables of a particular scope (e.g. process instance, flow element instance)
	// from the given JSON document.
	//
	// Errors:
	// NOT_FOUND:
	// - no element with the given elementInstanceKey exists
	// INVALID_ARGUMENT:
	// - the given variables document is not a valid JSON document; valid documents are expected to
	// be JSON documents where the root node is an object.
	SetVariables(context.Context, *SetVariablesRequest) (*SetVariablesResponse, error)
	// Obtains the current topology of the cluster the gateway is part of.
	Topology(context.Context, *TopologyRequest) (*TopologyResponse, error)
	// Updates the number of retries a job has left. This is mostly useful for jobs that have run out of
	// retries, should the underlying problem be solved.
	//
	// Errors:
	// NOT_FOUND:
	// - no job exists with the given key
	//
	// INVALID_ARGUMENT:
	// - retries is not greater than 0
	UpdateJobRetries(context.Context, *UpdateJobRetriesRequest) (*UpdateJobRetriesResponse, error)
	// Modifies the process instance. This is done by activating and/or terminating specific elements of the instance.
	//
	// Errors:
	// NOT_FOUND:
	// - no process instance exists with the given key
	//
	// FAILED_PRECONDITION:
	// - trying to activate element inside of a multi-instance
	//
	// INVALID_ARGUMENT:
	// - activating or terminating unknown element
	// - ancestor of element for activation doesn't exist
	// - scope of variable is unknown
	ModifyProcessInstance(context.Context, *ModifyProcessInstanceRequest) (*ModifyProcessInstanceResponse, error)
	// Migrates the process instance to the specified process definition.
	// In simple terms, this is handled by updating the active element's process.
	//
	// Errors:
	// NOT_FOUND:
	// - the process instance referenced by `processInstanceKey` is not active
	//
	// FAILED_PRECONDITION:
	// - not all active elements in the source process instance are mapped to the elements in the target process
	// - a mapping instruction changes the type of an element or event
	// - a mapping instruction refers to an unsupported element (i.e. some elements will be supported later on)
	// - a mapping instruction refers to element in unsupported scenarios.
	// (i.e. migrating active elements with event subscriptions will be supported later on)
	//
	// INVALID_ARGUMENT:
	// - the source element id does not refer to an element in the source process definition
	// - a source element id is mapped by multiple mapping instructions.
	// For example, the engine cannot determine how to migrate a process instance when the instructions are: [A->B, A->C].
	MigrateProcessInstance(context.Context, *MigrateProcessInstanceRequest) (*MigrateProcessInstanceResponse, error)
	// Updates the deadline of a job using the timeout (in ms) provided. This can be used
	// for extending or shortening the job deadline.
	//
	// Errors:
	// NOT_FOUND:
	// - no job exists with the given key
	//
	// INVALID_STATE:
	// - no deadline exists for the given job key
	UpdateJobTimeout(context.Context, *UpdateJobTimeoutRequest) (*UpdateJobTimeoutResponse, error)
	// Deletes a resource from the state. Once a resource has been deleted it cannot
	// be recovered. If the resource needs to be available again, a new deployment
	// of the resource is required.
	//
	// Deleting a process will cancel any running instances of this process
	// definition. New instances of a deleted process are created using
	// the lastest version that hasn't been deleted. Creating a new
	// process instance is impossible when all versions have been
	// deleted.
	//
	// Deleting a decision requirement definitions could cause incidents in process
	// instances referencing these decisions in a business rule task. A decision
	// will be evaluated with the latest version that hasn't been deleted. If all
	// versions of a decision have been deleted the evaluation is rejected.
	//
	// Errors:
	// NOT_FOUND:
	// - No resource exists with the given key
	DeleteResource(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error)
	// Broadcasts a signal.
	BroadcastSignal(context.Context, *BroadcastSignalRequest) (*BroadcastSignalResponse, error)
}

type Gateway_ActivateJobsClient interface {
	Recv() (*ActivateJobsResponse, error)
	grpc.ClientStream
}

type Gateway_ActivateJobsServer interface {
	Send(*ActivateJobsResponse) error
	grpc.ServerStream
}

type Gateway_StreamActivatedJobsClient interface {
	Recv() (*ActivatedJob, error)
	grpc.ClientStream
}

type Gateway_StreamActivatedJobsServer interface {
	Send(*ActivatedJob) error
	grpc.ServerStream
}

type MatchedDecisionRule struct {

	// the id of the matched rule
	RuleId string `protobuf:"bytes,1,opt,name=ruleId,proto3" json:"ruleId,omitempty"`
	// the index of the matched rule
	RuleIndex int32 `protobuf:"varint,2,opt,name=ruleIndex,proto3" json:"ruleIndex,omitempty"`
	// the evaluated decision outputs
	EvaluatedOutputs []*EvaluatedDecisionOutput `protobuf:"bytes,3,rep,name=evaluatedOutputs,proto3" json:"evaluatedOutputs,omitempty"`
	// contains filtered or unexported fields
}

type MigrateProcessInstanceRequest struct {

	// key of the process instance to migrate
	ProcessInstanceKey int64 `protobuf:"varint,1,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	// the migration plan that defines target process and element mappings
	MigrationPlan *MigrateProcessInstanceRequest_MigrationPlan `protobuf:"bytes,2,opt,name=migrationPlan,proto3" json:"migrationPlan,omitempty"`
	// contains filtered or unexported fields
}

type MigrateProcessInstanceRequest_MappingInstruction struct {

	// the element id to migrate from
	SourceElementId string `protobuf:"bytes,1,opt,name=sourceElementId,proto3" json:"sourceElementId,omitempty"`
	// the element id to migrate into
	TargetElementId string `protobuf:"bytes,2,opt,name=targetElementId,proto3" json:"targetElementId,omitempty"`
	// contains filtered or unexported fields
}

type MigrateProcessInstanceRequest_MigrationPlan struct {

	// the key of process definition to migrate the process instance to
	TargetProcessDefinitionKey int64 `protobuf:"varint,1,opt,name=targetProcessDefinitionKey,proto3" json:"targetProcessDefinitionKey,omitempty"`
	// the mapping instructions describe how to map elements from the source process definition to the target process definition
	MappingInstructions []*MigrateProcessInstanceRequest_MappingInstruction `protobuf:"bytes,2,rep,name=mappingInstructions,proto3" json:"mappingInstructions,omitempty"`
	// contains filtered or unexported fields
}

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

type ModifyProcessInstanceRequest struct {

	// the key of the process instance that should be modified
	ProcessInstanceKey int64 `protobuf:"varint,1,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	// instructions describing which elements should be activated in which scopes,
	// and which variables should be created
	ActivateInstructions []*ModifyProcessInstanceRequest_ActivateInstruction `protobuf:"bytes,2,rep,name=activateInstructions,proto3" json:"activateInstructions,omitempty"`
	// instructions describing which elements should be terminated
	TerminateInstructions []*ModifyProcessInstanceRequest_TerminateInstruction `protobuf:"bytes,3,rep,name=terminateInstructions,proto3" json:"terminateInstructions,omitempty"`
	// contains filtered or unexported fields
}

type ModifyProcessInstanceRequest_ActivateInstruction struct {

	// the id of the element that should be activated
	ElementId string `protobuf:"bytes,1,opt,name=elementId,proto3" json:"elementId,omitempty"`
	// the key of the ancestor scope the element instance should be created in;
	// set to -1 to create the new element instance within an existing element
	// instance of the flow scope
	AncestorElementInstanceKey int64 `protobuf:"varint,2,opt,name=ancestorElementInstanceKey,proto3" json:"ancestorElementInstanceKey,omitempty"`
	// instructions describing which variables should be created
	VariableInstructions []*ModifyProcessInstanceRequest_VariableInstruction `protobuf:"bytes,3,rep,name=variableInstructions,proto3" json:"variableInstructions,omitempty"`
	// contains filtered or unexported fields
}

type ModifyProcessInstanceRequest_TerminateInstruction struct {

	// the id of the element that should be terminated
	ElementInstanceKey int64 `protobuf:"varint,1,opt,name=elementInstanceKey,proto3" json:"elementInstanceKey,omitempty"`
	// contains filtered or unexported fields
}

type ModifyProcessInstanceRequest_VariableInstruction struct {

	// JSON document that will instantiate the variables for the root variable scope of the
	// process instance; it must be a JSON object, as variables will be mapped in a
	// key-value fashion. e.g. { "a": 1, "b": 2 } will create two variables, named "a" and
	// "b" respectively, with their associated values. [{ "a": 1, "b": 2 }] would not be a
	// valid argument, as the root of the JSON document is an array and not an object.
	Variables string `protobuf:"bytes,1,opt,name=variables,proto3" json:"variables,omitempty"`
	// the id of the element in which scope the variables should be created;
	// leave empty to create the variables in the global scope of the process instance
	ScopeId string `protobuf:"bytes,2,opt,name=scopeId,proto3" json:"scopeId,omitempty"`
	// contains filtered or unexported fields
}

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

type Partition struct {

	// the unique ID of this partition
	PartitionId int32 `protobuf:"varint,1,opt,name=partitionId,proto3" json:"partitionId,omitempty"`
	// the role of the broker for this partition
	Role Partition_PartitionBrokerRole `protobuf:"varint,2,opt,name=role,proto3,enum=gateway_protocol.Partition_PartitionBrokerRole" json:"role,omitempty"`
	// the health of this partition
	Health Partition_PartitionBrokerHealth `protobuf:"varint,3,opt,name=health,proto3,enum=gateway_protocol.Partition_PartitionBrokerHealth" json:"health,omitempty"`
	// contains filtered or unexported fields
}

type Partition_PartitionBrokerHealth int32

type Partition_PartitionBrokerRole int32

type ProcessInstanceCreationStartInstruction struct {

	// element ID
	ElementId string `protobuf:"bytes,1,opt,name=elementId,proto3" json:"elementId,omitempty"`
	// contains filtered or unexported fields
}

type ProcessMetadata struct {

	// the bpmn process ID, as parsed during deployment; together with the version forms a
	// unique identifier for a specific process definition
	BpmnProcessId string `protobuf:"bytes,1,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	// the assigned process version
	Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// the assigned key, which acts as a unique identifier for this process
	ProcessDefinitionKey int64 `protobuf:"varint,3,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	// the resource name (see: ProcessRequestObject.name) from which this process was
	// parsed
	ResourceName string `protobuf:"bytes,4,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	// the tenant id of the deployed process
	TenantId string `protobuf:"bytes,5,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type PublishMessageRequest struct {

	// the name of the message
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the correlation key of the message
	CorrelationKey string `protobuf:"bytes,2,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"`
	// how long the message should be buffered on the broker, in milliseconds
	TimeToLive int64 `protobuf:"varint,3,opt,name=timeToLive,proto3" json:"timeToLive,omitempty"`
	// the unique ID of the message; can be omitted. only useful to ensure only one message
	// with the given ID will ever be published (during its lifetime)
	MessageId string `protobuf:"bytes,4,opt,name=messageId,proto3" json:"messageId,omitempty"`
	// the message variables as a JSON document; to be valid, the root of the document must be an
	// object, e.g. { "a": "foo" }. [ "foo" ] would not be valid.
	Variables string `protobuf:"bytes,5,opt,name=variables,proto3" json:"variables,omitempty"`
	// the tenant id of the message
	TenantId string `protobuf:"bytes,6,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}

type PublishMessageResponse struct {

	// the unique ID of the message that was published
	Key int64 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	// the tenant id of the message
	TenantId string `protobuf:"bytes,2,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// contains filtered or unexported fields
}