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"`
}

type ActivateJobsResponse struct {
	// list of activated jobs
	Jobs []*ActivatedJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
}

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"`
}

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"`
}

type BroadcastSignalResponse struct {
	// the unique ID of the signal that was broadcasted.
	Key int64 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
}

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"`
}

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"`
}

type CancelProcessInstanceResponse struct {
}

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"`
}

type CompleteJobResponse struct {
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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

type DeleteResourceResponse struct {
}

type DeployResourceRequest struct {
	// list of resources to deploy
	Resources []*Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
}

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"`
}

type Deployment struct {
	// each deployment has only one metadata
	//
	// Types that are valid to be assigned to Metadata:
	//
	//	*Deployment_Process
	//	*Deployment_Decision
	//	*Deployment_DecisionRequirements
	Metadata isDeployment_Metadata `protobuf_oneof:"Metadata"`
}

type Deployment_Decision struct {
	Decision *DecisionMetadata `protobuf:"bytes,2,opt,name=decision,proto3,oneof" json:"decision,omitempty"`
}

type Deployment_DecisionRequirements struct {
	DecisionRequirements *DecisionRequirementsMetadata `protobuf:"bytes,3,opt,name=decisionRequirements,proto3,oneof" json:"decisionRequirements,omitempty"`
}

type Deployment_Process struct {
	Process *ProcessMetadata `protobuf:"bytes,1,opt,name=process,proto3,oneof" json:"process,omitempty"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

type FailJobResponse struct {
}

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)
	//
	//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)
	//
	//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:
	//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)
	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)
	//
	//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
	//
	//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)
	//
	//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:
	//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)
	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)
	//
	//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 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"`
}