pb

package
v0.0.0-...-e3dca73 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Partition_PartitionBrokerRole_name = map[int32]string{
	0: "LEADER",
	1: "FOLLOWER",
}
View Source 
var Partition_PartitionBrokerRole_value = map[string]int32{
	"LEADER":   0,
	"FOLLOWER": 1,
}
View Source 
var WorkflowRequestObject_ResourceType_name = map[int32]string{
	0: "FILE",
	1: "BPMN",
	2: "YAML",
}
View Source 
var WorkflowRequestObject_ResourceType_value = map[string]int32{
	"FILE": 0,
	"BPMN": 1,
	"YAML": 2,
}

Functions

func RegisterGatewayServer 

func RegisterGatewayServer(s *grpc.Server, srv GatewayServer)

Types

type ActivateJobsRequest 

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 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.
	// 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActivateJobsRequest) Descriptor 

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

func (*ActivateJobsRequest) GetFetchVariable 

func (m *ActivateJobsRequest) GetFetchVariable() []string

func (*ActivateJobsRequest) GetMaxJobsToActivate 

func (m *ActivateJobsRequest) GetMaxJobsToActivate() int32

func (*ActivateJobsRequest) GetRequestTimeout 

func (m *ActivateJobsRequest) GetRequestTimeout() int64

func (*ActivateJobsRequest) GetTimeout 

func (m *ActivateJobsRequest) GetTimeout() int64

func (*ActivateJobsRequest) GetType 

func (m *ActivateJobsRequest) GetType() string

func (*ActivateJobsRequest) GetWorker 

func (m *ActivateJobsRequest) GetWorker() string

func (*ActivateJobsRequest) ProtoMessage 

func (*ActivateJobsRequest) ProtoMessage()

func (*ActivateJobsRequest) Reset 

func (m *ActivateJobsRequest) Reset()

func (*ActivateJobsRequest) String 

func (m *ActivateJobsRequest) String() string

func (*ActivateJobsRequest) XXX_DiscardUnknown 

func (m *ActivateJobsRequest) XXX_DiscardUnknown()

func (*ActivateJobsRequest) XXX_Marshal 

func (m *ActivateJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivateJobsRequest) XXX_Merge 

func (m *ActivateJobsRequest) XXX_Merge(src proto.Message)

func (*ActivateJobsRequest) XXX_Size 

func (m *ActivateJobsRequest) XXX_Size() int

func (*ActivateJobsRequest) XXX_Unmarshal 

func (m *ActivateJobsRequest) XXX_Unmarshal(b []byte) error

type ActivateJobsResponse 

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

func (*ActivateJobsResponse) Descriptor 

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

func (*ActivateJobsResponse) GetJobs 

func (m *ActivateJobsResponse) GetJobs() []*ActivatedJob

func (*ActivateJobsResponse) ProtoMessage 

func (*ActivateJobsResponse) ProtoMessage()

func (*ActivateJobsResponse) Reset 

func (m *ActivateJobsResponse) Reset()

func (*ActivateJobsResponse) String 

func (m *ActivateJobsResponse) String() string

func (*ActivateJobsResponse) XXX_DiscardUnknown 

func (m *ActivateJobsResponse) XXX_DiscardUnknown()

func (*ActivateJobsResponse) XXX_Marshal 

func (m *ActivateJobsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivateJobsResponse) XXX_Merge 

func (m *ActivateJobsResponse) XXX_Merge(src proto.Message)

func (*ActivateJobsResponse) XXX_Size 

func (m *ActivateJobsResponse) XXX_Size() int

func (*ActivateJobsResponse) XXX_Unmarshal 

func (m *ActivateJobsResponse) XXX_Unmarshal(b []byte) error

type ActivatedJob 

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 workflow instance key
	WorkflowInstanceKey int64 `protobuf:"varint,3,opt,name=workflowInstanceKey,proto3" json:"workflowInstanceKey,omitempty"`
	// the bpmn process ID of the job workflow definition
	BpmnProcessId string `protobuf:"bytes,4,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	// the version of the job workflow definition
	WorkflowDefinitionVersion int32 `protobuf:"varint,5,opt,name=workflowDefinitionVersion,proto3" json:"workflowDefinitionVersion,omitempty"`
	// the key of the job workflow definition
	WorkflowKey int64 `protobuf:"varint,6,opt,name=workflowKey,proto3" json:"workflowKey,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
	// workflow 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActivatedJob) Descriptor 

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

func (*ActivatedJob) GetBpmnProcessId 

func (m *ActivatedJob) GetBpmnProcessId() string

func (*ActivatedJob) GetCustomHeaders 

func (m *ActivatedJob) GetCustomHeaders() string

func (*ActivatedJob) GetDeadline 

func (m *ActivatedJob) GetDeadline() int64

func (*ActivatedJob) GetElementId 

func (m *ActivatedJob) GetElementId() string

func (*ActivatedJob) GetElementInstanceKey 

func (m *ActivatedJob) GetElementInstanceKey() int64

func (*ActivatedJob) GetKey 

func (m *ActivatedJob) GetKey() int64

func (*ActivatedJob) GetRetries 

func (m *ActivatedJob) GetRetries() int32

func (*ActivatedJob) GetType 

func (m *ActivatedJob) GetType() string

func (*ActivatedJob) GetVariables 

func (m *ActivatedJob) GetVariables() string

func (*ActivatedJob) GetWorker 

func (m *ActivatedJob) GetWorker() string

func (*ActivatedJob) GetWorkflowDefinitionVersion 

func (m *ActivatedJob) GetWorkflowDefinitionVersion() int32

func (*ActivatedJob) GetWorkflowInstanceKey 

func (m *ActivatedJob) GetWorkflowInstanceKey() int64

func (*ActivatedJob) GetWorkflowKey 

func (m *ActivatedJob) GetWorkflowKey() int64

func (*ActivatedJob) ProtoMessage 

func (*ActivatedJob) ProtoMessage()

func (*ActivatedJob) Reset 

func (m *ActivatedJob) Reset()

func (*ActivatedJob) String 

func (m *ActivatedJob) String() string

func (*ActivatedJob) XXX_DiscardUnknown 

func (m *ActivatedJob) XXX_DiscardUnknown()

func (*ActivatedJob) XXX_Marshal 

func (m *ActivatedJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivatedJob) XXX_Merge 

func (m *ActivatedJob) XXX_Merge(src proto.Message)

func (*ActivatedJob) XXX_Size 

func (m *ActivatedJob) XXX_Size() int

func (*ActivatedJob) XXX_Unmarshal 

func (m *ActivatedJob) XXX_Unmarshal(b []byte) error

type BrokerInfo 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BrokerInfo) Descriptor 

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

func (*BrokerInfo) GetHost 

func (m *BrokerInfo) GetHost() string

func (*BrokerInfo) GetNodeId 

func (m *BrokerInfo) GetNodeId() int32

func (*BrokerInfo) GetPartitions 

func (m *BrokerInfo) GetPartitions() []*Partition

func (*BrokerInfo) GetPort 

func (m *BrokerInfo) GetPort() int32

func (*BrokerInfo) GetVersion 

func (m *BrokerInfo) GetVersion() string

func (*BrokerInfo) ProtoMessage 

func (*BrokerInfo) ProtoMessage()

func (*BrokerInfo) Reset 

func (m *BrokerInfo) Reset()

func (*BrokerInfo) String 

func (m *BrokerInfo) String() string

func (*BrokerInfo) XXX_DiscardUnknown 

func (m *BrokerInfo) XXX_DiscardUnknown()

func (*BrokerInfo) XXX_Marshal 

func (m *BrokerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BrokerInfo) XXX_Merge 

func (m *BrokerInfo) XXX_Merge(src proto.Message)

func (*BrokerInfo) XXX_Size 

func (m *BrokerInfo) XXX_Size() int

func (*BrokerInfo) XXX_Unmarshal 

func (m *BrokerInfo) XXX_Unmarshal(b []byte) error

type CancelWorkflowInstanceRequest 

type CancelWorkflowInstanceRequest struct {
	// the workflow instance key (as, for example, obtained from
	// CreateWorkflowInstanceResponse)
	WorkflowInstanceKey  int64    `protobuf:"varint,1,opt,name=workflowInstanceKey,proto3" json:"workflowInstanceKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelWorkflowInstanceRequest) Descriptor 

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

func (*CancelWorkflowInstanceRequest) GetWorkflowInstanceKey 

func (m *CancelWorkflowInstanceRequest) GetWorkflowInstanceKey() int64

func (*CancelWorkflowInstanceRequest) ProtoMessage 

func (*CancelWorkflowInstanceRequest) ProtoMessage()

func (*CancelWorkflowInstanceRequest) Reset 

func (m *CancelWorkflowInstanceRequest) Reset()

func (*CancelWorkflowInstanceRequest) String 

func (m *CancelWorkflowInstanceRequest) String() string

func (*CancelWorkflowInstanceRequest) XXX_DiscardUnknown 

func (m *CancelWorkflowInstanceRequest) XXX_DiscardUnknown()

func (*CancelWorkflowInstanceRequest) XXX_Marshal 

func (m *CancelWorkflowInstanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelWorkflowInstanceRequest) XXX_Merge 

func (m *CancelWorkflowInstanceRequest) XXX_Merge(src proto.Message)

func (*CancelWorkflowInstanceRequest) XXX_Size 

func (m *CancelWorkflowInstanceRequest) XXX_Size() int

func (*CancelWorkflowInstanceRequest) XXX_Unmarshal 

func (m *CancelWorkflowInstanceRequest) XXX_Unmarshal(b []byte) error

type CancelWorkflowInstanceResponse 

type CancelWorkflowInstanceResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelWorkflowInstanceResponse) Descriptor 

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

func (*CancelWorkflowInstanceResponse) ProtoMessage 

func (*CancelWorkflowInstanceResponse) ProtoMessage()

func (*CancelWorkflowInstanceResponse) Reset 

func (m *CancelWorkflowInstanceResponse) Reset()

func (*CancelWorkflowInstanceResponse) String 

func (m *CancelWorkflowInstanceResponse) String() string

func (*CancelWorkflowInstanceResponse) XXX_DiscardUnknown 

func (m *CancelWorkflowInstanceResponse) XXX_DiscardUnknown()

func (*CancelWorkflowInstanceResponse) XXX_Marshal 

func (m *CancelWorkflowInstanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelWorkflowInstanceResponse) XXX_Merge 

func (m *CancelWorkflowInstanceResponse) XXX_Merge(src proto.Message)

func (*CancelWorkflowInstanceResponse) XXX_Size 

func (m *CancelWorkflowInstanceResponse) XXX_Size() int

func (*CancelWorkflowInstanceResponse) XXX_Unmarshal 

func (m *CancelWorkflowInstanceResponse) XXX_Unmarshal(b []byte) error

type CompleteJobRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompleteJobRequest) Descriptor 

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

func (*CompleteJobRequest) GetJobKey 

func (m *CompleteJobRequest) GetJobKey() int64

func (*CompleteJobRequest) GetVariables 

func (m *CompleteJobRequest) GetVariables() string

func (*CompleteJobRequest) ProtoMessage 

func (*CompleteJobRequest) ProtoMessage()

func (*CompleteJobRequest) Reset 

func (m *CompleteJobRequest) Reset()

func (*CompleteJobRequest) String 

func (m *CompleteJobRequest) String() string

func (*CompleteJobRequest) XXX_DiscardUnknown 

func (m *CompleteJobRequest) XXX_DiscardUnknown()

func (*CompleteJobRequest) XXX_Marshal 

func (m *CompleteJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompleteJobRequest) XXX_Merge 

func (m *CompleteJobRequest) XXX_Merge(src proto.Message)

func (*CompleteJobRequest) XXX_Size 

func (m *CompleteJobRequest) XXX_Size() int

func (*CompleteJobRequest) XXX_Unmarshal 

func (m *CompleteJobRequest) XXX_Unmarshal(b []byte) error

type CompleteJobResponse 

type CompleteJobResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompleteJobResponse) Descriptor 

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

func (*CompleteJobResponse) ProtoMessage 

func (*CompleteJobResponse) ProtoMessage()

func (*CompleteJobResponse) Reset 

func (m *CompleteJobResponse) Reset()

func (*CompleteJobResponse) String 

func (m *CompleteJobResponse) String() string

func (*CompleteJobResponse) XXX_DiscardUnknown 

func (m *CompleteJobResponse) XXX_DiscardUnknown()

func (*CompleteJobResponse) XXX_Marshal 

func (m *CompleteJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompleteJobResponse) XXX_Merge 

func (m *CompleteJobResponse) XXX_Merge(src proto.Message)

func (*CompleteJobResponse) XXX_Size 

func (m *CompleteJobResponse) XXX_Size() int

func (*CompleteJobResponse) XXX_Unmarshal 

func (m *CompleteJobResponse) XXX_Unmarshal(b []byte) error

type CreateWorkflowInstanceRequest 

type CreateWorkflowInstanceRequest struct {
	// the unique key identifying the workflow definition (e.g. returned from a workflow
	// in the DeployWorkflowResponse message)
	WorkflowKey int64 `protobuf:"varint,1,opt,name=workflowKey,proto3" json:"workflowKey,omitempty"`
	// the BPMN process ID of the workflow 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
	// workflow 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateWorkflowInstanceRequest) Descriptor 

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

func (*CreateWorkflowInstanceRequest) GetBpmnProcessId 

func (m *CreateWorkflowInstanceRequest) GetBpmnProcessId() string

func (*CreateWorkflowInstanceRequest) GetVariables 

func (m *CreateWorkflowInstanceRequest) GetVariables() string

func (*CreateWorkflowInstanceRequest) GetVersion 

func (m *CreateWorkflowInstanceRequest) GetVersion() int32

func (*CreateWorkflowInstanceRequest) GetWorkflowKey 

func (m *CreateWorkflowInstanceRequest) GetWorkflowKey() int64

func (*CreateWorkflowInstanceRequest) ProtoMessage 

func (*CreateWorkflowInstanceRequest) ProtoMessage()

func (*CreateWorkflowInstanceRequest) Reset 

func (m *CreateWorkflowInstanceRequest) Reset()

func (*CreateWorkflowInstanceRequest) String 

func (m *CreateWorkflowInstanceRequest) String() string

func (*CreateWorkflowInstanceRequest) XXX_DiscardUnknown 

func (m *CreateWorkflowInstanceRequest) XXX_DiscardUnknown()

func (*CreateWorkflowInstanceRequest) XXX_Marshal 

func (m *CreateWorkflowInstanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateWorkflowInstanceRequest) XXX_Merge 

func (m *CreateWorkflowInstanceRequest) XXX_Merge(src proto.Message)

func (*CreateWorkflowInstanceRequest) XXX_Size 

func (m *CreateWorkflowInstanceRequest) XXX_Size() int

func (*CreateWorkflowInstanceRequest) XXX_Unmarshal 

func (m *CreateWorkflowInstanceRequest) XXX_Unmarshal(b []byte) error

type CreateWorkflowInstanceResponse 

type CreateWorkflowInstanceResponse struct {
	// the key of the workflow definition which was used to create the workflow instance
	WorkflowKey int64 `protobuf:"varint,1,opt,name=workflowKey,proto3" json:"workflowKey,omitempty"`
	// the BPMN process ID of the workflow definition which was used to create the workflow
	// instance
	BpmnProcessId string `protobuf:"bytes,2,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	// the version of the workflow definition which was used to create the workflow instance
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// the unique identifier of the created workflow instance; to be used wherever a request
	// needs a workflow instance key (e.g. CancelWorkflowInstanceRequest)
	WorkflowInstanceKey  int64    `protobuf:"varint,4,opt,name=workflowInstanceKey,proto3" json:"workflowInstanceKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateWorkflowInstanceResponse) Descriptor 

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

func (*CreateWorkflowInstanceResponse) GetBpmnProcessId 

func (m *CreateWorkflowInstanceResponse) GetBpmnProcessId() string

func (*CreateWorkflowInstanceResponse) GetVersion 

func (m *CreateWorkflowInstanceResponse) GetVersion() int32

func (*CreateWorkflowInstanceResponse) GetWorkflowInstanceKey 

func (m *CreateWorkflowInstanceResponse) GetWorkflowInstanceKey() int64

func (*CreateWorkflowInstanceResponse) GetWorkflowKey 

func (m *CreateWorkflowInstanceResponse) GetWorkflowKey() int64

func (*CreateWorkflowInstanceResponse) ProtoMessage 

func (*CreateWorkflowInstanceResponse) ProtoMessage()

func (*CreateWorkflowInstanceResponse) Reset 

func (m *CreateWorkflowInstanceResponse) Reset()

func (*CreateWorkflowInstanceResponse) String 

func (m *CreateWorkflowInstanceResponse) String() string

func (*CreateWorkflowInstanceResponse) XXX_DiscardUnknown 

func (m *CreateWorkflowInstanceResponse) XXX_DiscardUnknown()

func (*CreateWorkflowInstanceResponse) XXX_Marshal 

func (m *CreateWorkflowInstanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateWorkflowInstanceResponse) XXX_Merge 

func (m *CreateWorkflowInstanceResponse) XXX_Merge(src proto.Message)

func (*CreateWorkflowInstanceResponse) XXX_Size 

func (m *CreateWorkflowInstanceResponse) XXX_Size() int

func (*CreateWorkflowInstanceResponse) XXX_Unmarshal 

func (m *CreateWorkflowInstanceResponse) XXX_Unmarshal(b []byte) error

type CreateWorkflowInstanceWithResultRequest 

type CreateWorkflowInstanceWithResultRequest struct {
	Request *CreateWorkflowInstanceRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// timeout in milliseconds. the request will be closed if the workflow 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 `CreateWorkflowInstanceWithResultResponse.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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateWorkflowInstanceWithResultRequest) Descriptor 

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

func (*CreateWorkflowInstanceWithResultRequest) GetFetchVariables 

func (m *CreateWorkflowInstanceWithResultRequest) GetFetchVariables() []string

func (*CreateWorkflowInstanceWithResultRequest) GetRequest 

func (m *CreateWorkflowInstanceWithResultRequest) GetRequest() *CreateWorkflowInstanceRequest

func (*CreateWorkflowInstanceWithResultRequest) GetRequestTimeout 

func (m *CreateWorkflowInstanceWithResultRequest) GetRequestTimeout() int64

func (*CreateWorkflowInstanceWithResultRequest) ProtoMessage 

func (*CreateWorkflowInstanceWithResultRequest) ProtoMessage()

func (*CreateWorkflowInstanceWithResultRequest) Reset 

func (m *CreateWorkflowInstanceWithResultRequest) Reset()

func (*CreateWorkflowInstanceWithResultRequest) String 

func (m *CreateWorkflowInstanceWithResultRequest) String() string

func (*CreateWorkflowInstanceWithResultRequest) XXX_DiscardUnknown 

func (m *CreateWorkflowInstanceWithResultRequest) XXX_DiscardUnknown()

func (*CreateWorkflowInstanceWithResultRequest) XXX_Marshal 

func (m *CreateWorkflowInstanceWithResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateWorkflowInstanceWithResultRequest) XXX_Merge 

func (m *CreateWorkflowInstanceWithResultRequest) XXX_Merge(src proto.Message)

func (*CreateWorkflowInstanceWithResultRequest) XXX_Size 

func (m *CreateWorkflowInstanceWithResultRequest) XXX_Size() int

func (*CreateWorkflowInstanceWithResultRequest) XXX_Unmarshal 

func (m *CreateWorkflowInstanceWithResultRequest) XXX_Unmarshal(b []byte) error

type CreateWorkflowInstanceWithResultResponse 

type CreateWorkflowInstanceWithResultResponse struct {
	// the key of the workflow definition which was used to create the workflow instance
	WorkflowKey int64 `protobuf:"varint,1,opt,name=workflowKey,proto3" json:"workflowKey,omitempty"`
	// the BPMN process ID of the workflow definition which was used to create the workflow
	// instance
	BpmnProcessId string `protobuf:"bytes,2,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	// the version of the workflow definition which was used to create the workflow instance
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// the unique identifier of the created workflow instance; to be used wherever a request
	// needs a workflow instance key (e.g. CancelWorkflowInstanceRequest)
	WorkflowInstanceKey int64 `protobuf:"varint,4,opt,name=workflowInstanceKey,proto3" json:"workflowInstanceKey,omitempty"`
	// JSON document
	// consists of visible variables in the root scope
	Variables            string   `protobuf:"bytes,5,opt,name=variables,proto3" json:"variables,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateWorkflowInstanceWithResultResponse) Descriptor 

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

func (*CreateWorkflowInstanceWithResultResponse) GetBpmnProcessId 

func (m *CreateWorkflowInstanceWithResultResponse) GetBpmnProcessId() string

func (*CreateWorkflowInstanceWithResultResponse) GetVariables 

func (m *CreateWorkflowInstanceWithResultResponse) GetVariables() string

func (*CreateWorkflowInstanceWithResultResponse) GetVersion 

func (m *CreateWorkflowInstanceWithResultResponse) GetVersion() int32

func (*CreateWorkflowInstanceWithResultResponse) GetWorkflowInstanceKey 

func (m *CreateWorkflowInstanceWithResultResponse) GetWorkflowInstanceKey() int64

func (*CreateWorkflowInstanceWithResultResponse) GetWorkflowKey 

func (m *CreateWorkflowInstanceWithResultResponse) GetWorkflowKey() int64

func (*CreateWorkflowInstanceWithResultResponse) ProtoMessage 

func (*CreateWorkflowInstanceWithResultResponse) ProtoMessage()

func (*CreateWorkflowInstanceWithResultResponse) Reset 

func (m *CreateWorkflowInstanceWithResultResponse) Reset()

func (*CreateWorkflowInstanceWithResultResponse) String 

func (m *CreateWorkflowInstanceWithResultResponse) String() string

func (*CreateWorkflowInstanceWithResultResponse) XXX_DiscardUnknown 

func (m *CreateWorkflowInstanceWithResultResponse) XXX_DiscardUnknown()

func (*CreateWorkflowInstanceWithResultResponse) XXX_Marshal 

func (m *CreateWorkflowInstanceWithResultResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateWorkflowInstanceWithResultResponse) XXX_Merge 

func (m *CreateWorkflowInstanceWithResultResponse) XXX_Merge(src proto.Message)

func (*CreateWorkflowInstanceWithResultResponse) XXX_Size 

func (m *CreateWorkflowInstanceWithResultResponse) XXX_Size() int

func (*CreateWorkflowInstanceWithResultResponse) XXX_Unmarshal 

func (m *CreateWorkflowInstanceWithResultResponse) XXX_Unmarshal(b []byte) error

type DeployWorkflowRequest 

type DeployWorkflowRequest struct {
	// List of workflow resources to deploy
	Workflows            []*WorkflowRequestObject `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*DeployWorkflowRequest) Descriptor 

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

func (*DeployWorkflowRequest) GetWorkflows 

func (m *DeployWorkflowRequest) GetWorkflows() []*WorkflowRequestObject

func (*DeployWorkflowRequest) ProtoMessage 

func (*DeployWorkflowRequest) ProtoMessage()

func (*DeployWorkflowRequest) Reset 

func (m *DeployWorkflowRequest) Reset()

func (*DeployWorkflowRequest) String 

func (m *DeployWorkflowRequest) String() string

func (*DeployWorkflowRequest) XXX_DiscardUnknown 

func (m *DeployWorkflowRequest) XXX_DiscardUnknown()

func (*DeployWorkflowRequest) XXX_Marshal 

func (m *DeployWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeployWorkflowRequest) XXX_Merge 

func (m *DeployWorkflowRequest) XXX_Merge(src proto.Message)

func (*DeployWorkflowRequest) XXX_Size 

func (m *DeployWorkflowRequest) XXX_Size() int

func (*DeployWorkflowRequest) XXX_Unmarshal 

func (m *DeployWorkflowRequest) XXX_Unmarshal(b []byte) error

type DeployWorkflowResponse 

type DeployWorkflowResponse struct {
	// the unique key identifying the deployment
	Key int64 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	// a list of deployed workflows
	Workflows            []*WorkflowMetadata `protobuf:"bytes,2,rep,name=workflows,proto3" json:"workflows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*DeployWorkflowResponse) Descriptor 

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

func (*DeployWorkflowResponse) GetKey 

func (m *DeployWorkflowResponse) GetKey() int64

func (*DeployWorkflowResponse) GetWorkflows 

func (m *DeployWorkflowResponse) GetWorkflows() []*WorkflowMetadata

func (*DeployWorkflowResponse) ProtoMessage 

func (*DeployWorkflowResponse) ProtoMessage()

func (*DeployWorkflowResponse) Reset 

func (m *DeployWorkflowResponse) Reset()

func (*DeployWorkflowResponse) String 

func (m *DeployWorkflowResponse) String() string

func (*DeployWorkflowResponse) XXX_DiscardUnknown 

func (m *DeployWorkflowResponse) XXX_DiscardUnknown()

func (*DeployWorkflowResponse) XXX_Marshal 

func (m *DeployWorkflowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeployWorkflowResponse) XXX_Merge 

func (m *DeployWorkflowResponse) XXX_Merge(src proto.Message)

func (*DeployWorkflowResponse) XXX_Size 

func (m *DeployWorkflowResponse) XXX_Size() int

func (*DeployWorkflowResponse) XXX_Unmarshal 

func (m *DeployWorkflowResponse) XXX_Unmarshal(b []byte) error

type FailJobRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FailJobRequest) Descriptor 

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

func (*FailJobRequest) GetErrorMessage 

func (m *FailJobRequest) GetErrorMessage() string

func (*FailJobRequest) GetJobKey 

func (m *FailJobRequest) GetJobKey() int64

func (*FailJobRequest) GetRetries 

func (m *FailJobRequest) GetRetries() int32

func (*FailJobRequest) ProtoMessage 

func (*FailJobRequest) ProtoMessage()

func (*FailJobRequest) Reset 

func (m *FailJobRequest) Reset()

func (*FailJobRequest) String 

func (m *FailJobRequest) String() string

func (*FailJobRequest) XXX_DiscardUnknown 

func (m *FailJobRequest) XXX_DiscardUnknown()

func (*FailJobRequest) XXX_Marshal 

func (m *FailJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FailJobRequest) XXX_Merge 

func (m *FailJobRequest) XXX_Merge(src proto.Message)

func (*FailJobRequest) XXX_Size 

func (m *FailJobRequest) XXX_Size() int

func (*FailJobRequest) XXX_Unmarshal 

func (m *FailJobRequest) XXX_Unmarshal(b []byte) error

type FailJobResponse 

type FailJobResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FailJobResponse) Descriptor 

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

func (*FailJobResponse) ProtoMessage 

func (*FailJobResponse) ProtoMessage()

func (*FailJobResponse) Reset 

func (m *FailJobResponse) Reset()

func (*FailJobResponse) String 

func (m *FailJobResponse) String() string

func (*FailJobResponse) XXX_DiscardUnknown 

func (m *FailJobResponse) XXX_DiscardUnknown()

func (*FailJobResponse) XXX_Marshal 

func (m *FailJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FailJobResponse) XXX_Merge 

func (m *FailJobResponse) XXX_Merge(src proto.Message)

func (*FailJobResponse) XXX_Size 

func (m *FailJobResponse) XXX_Size() int

func (*FailJobResponse) XXX_Unmarshal 

func (m *FailJobResponse) XXX_Unmarshal(b []byte) error

type GatewayClient 

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 workflow instance
	//
	//Errors:
	//NOT_FOUND:
	//- no workflow instance exists with the given key
	CancelWorkflowInstance(ctx context.Context, in *CancelWorkflowInstanceRequest, opts ...grpc.CallOption) (*CancelWorkflowInstanceResponse, 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 workflow. The workflow definition to use to
	//create the instance can be specified either using its unique key (as returned by
	//DeployWorkflow), or using the BPMN process ID and a version. Pass -1 as the version to use the
	//latest deployed version. Note that only workflows with none start events can be started through
	//this command.
	//
	//Errors:
	//NOT_FOUND:
	//- no workflow with the given key exists (if workflowKey was given)
	//- no workflow with the given process ID exists (if bpmnProcessId was given but version was -1)
	//- no workflow with the given process ID and version exists (if both bpmnProcessId and version were given)
	//
	//FAILED_PRECONDITION:
	//- the workflow definition does not contain a none start event; only workflows 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.
	CreateWorkflowInstance(ctx context.Context, in *CreateWorkflowInstanceRequest, opts ...grpc.CallOption) (*CreateWorkflowInstanceResponse, error)
	//
	//Behaves similarly to `rpc CreateWorkflowInstance`, except that a successful response is received when the workflow completes successfully.
	CreateWorkflowInstanceWithResult(ctx context.Context, in *CreateWorkflowInstanceWithResultRequest, opts ...grpc.CallOption) (*CreateWorkflowInstanceWithResultResponse, error)
	//
	//Deploys one or more workflows to Zeebe. Note that this is an atomic call,
	//i.e. either all workflows 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:
	//- it is not a BPMN or YAML file (currently detected through the file extension)
	//- the resource data is not deserializable (e.g. detected as BPMN, but it's broken XML)
	//- the workflow is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
	DeployWorkflow(ctx context.Context, in *DeployWorkflowRequest, opts ...grpc.CallOption) (*DeployWorkflowResponse, 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 workflow 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. workflow 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)
}

GatewayClient is the client API for Gateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGatewayClient 

func NewGatewayClient(cc *grpc.ClientConn) GatewayClient

type GatewayServer 

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 workflow instance
	//
	//Errors:
	//NOT_FOUND:
	//- no workflow instance exists with the given key
	CancelWorkflowInstance(context.Context, *CancelWorkflowInstanceRequest) (*CancelWorkflowInstanceResponse, 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 workflow. The workflow definition to use to
	//create the instance can be specified either using its unique key (as returned by
	//DeployWorkflow), or using the BPMN process ID and a version. Pass -1 as the version to use the
	//latest deployed version. Note that only workflows with none start events can be started through
	//this command.
	//
	//Errors:
	//NOT_FOUND:
	//- no workflow with the given key exists (if workflowKey was given)
	//- no workflow with the given process ID exists (if bpmnProcessId was given but version was -1)
	//- no workflow with the given process ID and version exists (if both bpmnProcessId and version were given)
	//
	//FAILED_PRECONDITION:
	//- the workflow definition does not contain a none start event; only workflows 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.
	CreateWorkflowInstance(context.Context, *CreateWorkflowInstanceRequest) (*CreateWorkflowInstanceResponse, error)
	//
	//Behaves similarly to `rpc CreateWorkflowInstance`, except that a successful response is received when the workflow completes successfully.
	CreateWorkflowInstanceWithResult(context.Context, *CreateWorkflowInstanceWithResultRequest) (*CreateWorkflowInstanceWithResultResponse, error)
	//
	//Deploys one or more workflows to Zeebe. Note that this is an atomic call,
	//i.e. either all workflows 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:
	//- it is not a BPMN or YAML file (currently detected through the file extension)
	//- the resource data is not deserializable (e.g. detected as BPMN, but it's broken XML)
	//- the workflow is invalid (e.g. an event-based gateway has an outgoing sequence flow to a task)
	DeployWorkflow(context.Context, *DeployWorkflowRequest) (*DeployWorkflowResponse, 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 workflow 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. workflow 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)
}

GatewayServer is the server API for Gateway service.

type Gateway_ActivateJobsClient 

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

type Gateway_ActivateJobsServer 

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

type Partition 

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"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*Partition) Descriptor 

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

func (*Partition) GetPartitionId 

func (m *Partition) GetPartitionId() int32

func (*Partition) GetRole 

func (m *Partition) GetRole() Partition_PartitionBrokerRole

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) Reset 

func (m *Partition) Reset()

func (*Partition) String 

func (m *Partition) String() string

func (*Partition) XXX_DiscardUnknown 

func (m *Partition) XXX_DiscardUnknown()

func (*Partition) XXX_Marshal 

func (m *Partition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Partition) XXX_Merge 

func (m *Partition) XXX_Merge(src proto.Message)

func (*Partition) XXX_Size 

func (m *Partition) XXX_Size() int

func (*Partition) XXX_Unmarshal 

func (m *Partition) XXX_Unmarshal(b []byte) error

type Partition_PartitionBrokerRole 

type Partition_PartitionBrokerRole int32

Describes the Raft role of the broker for a given partition 

const (
	Partition_LEADER   Partition_PartitionBrokerRole = 0
	Partition_FOLLOWER Partition_PartitionBrokerRole = 1
)

func (Partition_PartitionBrokerRole) EnumDescriptor 

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

func (Partition_PartitionBrokerRole) String 

func (x Partition_PartitionBrokerRole) String() string

type PublishMessageRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishMessageRequest) Descriptor 

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

func (*PublishMessageRequest) GetCorrelationKey 

func (m *PublishMessageRequest) GetCorrelationKey() string

func (*PublishMessageRequest) GetMessageId 

func (m *PublishMessageRequest) GetMessageId() string

func (*PublishMessageRequest) GetName 

func (m *PublishMessageRequest) GetName() string

func (*PublishMessageRequest) GetTimeToLive 

func (m *PublishMessageRequest) GetTimeToLive() int64

func (*PublishMessageRequest) GetVariables 

func (m *PublishMessageRequest) GetVariables() string

func (*PublishMessageRequest) ProtoMessage 

func (*PublishMessageRequest) ProtoMessage()

func (*PublishMessageRequest) Reset 

func (m *PublishMessageRequest) Reset()

func (*PublishMessageRequest) String 

func (m *PublishMessageRequest) String() string

func (*PublishMessageRequest) XXX_DiscardUnknown 

func (m *PublishMessageRequest) XXX_DiscardUnknown()

func (*PublishMessageRequest) XXX_Marshal 

func (m *PublishMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishMessageRequest) XXX_Merge 

func (m *PublishMessageRequest) XXX_Merge(src proto.Message)

func (*PublishMessageRequest) XXX_Size 

func (m *PublishMessageRequest) XXX_Size() int

func (*PublishMessageRequest) XXX_Unmarshal 

func (m *PublishMessageRequest) XXX_Unmarshal(b []byte) error

type PublishMessageResponse 

type PublishMessageResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishMessageResponse) Descriptor 

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

func (*PublishMessageResponse) ProtoMessage 

func (*PublishMessageResponse) ProtoMessage()

func (*PublishMessageResponse) Reset 

func (m *PublishMessageResponse) Reset()

func (*PublishMessageResponse) String 

func (m *PublishMessageResponse) String() string

func (*PublishMessageResponse) XXX_DiscardUnknown 

func (m *PublishMessageResponse) XXX_DiscardUnknown()

func (*PublishMessageResponse) XXX_Marshal 

func (m *PublishMessageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishMessageResponse) XXX_Merge 

func (m *PublishMessageResponse) XXX_Merge(src proto.Message)

func (*PublishMessageResponse) XXX_Size 

func (m *PublishMessageResponse) XXX_Size() int

func (*PublishMessageResponse) XXX_Unmarshal 

func (m *PublishMessageResponse) XXX_Unmarshal(b []byte) error

type ResolveIncidentRequest 

type ResolveIncidentRequest struct {
	// the unique ID of the incident to resolve
	IncidentKey          int64    `protobuf:"varint,1,opt,name=incidentKey,proto3" json:"incidentKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResolveIncidentRequest) Descriptor 

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

func (*ResolveIncidentRequest) GetIncidentKey 

func (m *ResolveIncidentRequest) GetIncidentKey() int64

func (*ResolveIncidentRequest) ProtoMessage 

func (*ResolveIncidentRequest) ProtoMessage()

func (*ResolveIncidentRequest) Reset 

func (m *ResolveIncidentRequest) Reset()

func (*ResolveIncidentRequest) String 

func (m *ResolveIncidentRequest) String() string

func (*ResolveIncidentRequest) XXX_DiscardUnknown 

func (m *ResolveIncidentRequest) XXX_DiscardUnknown()

func (*ResolveIncidentRequest) XXX_Marshal 

func (m *ResolveIncidentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResolveIncidentRequest) XXX_Merge 

func (m *ResolveIncidentRequest) XXX_Merge(src proto.Message)

func (*ResolveIncidentRequest) XXX_Size 

func (m *ResolveIncidentRequest) XXX_Size() int

func (*ResolveIncidentRequest) XXX_Unmarshal 

func (m *ResolveIncidentRequest) XXX_Unmarshal(b []byte) error

type ResolveIncidentResponse 

type ResolveIncidentResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResolveIncidentResponse) Descriptor 

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

func (*ResolveIncidentResponse) ProtoMessage 

func (*ResolveIncidentResponse) ProtoMessage()

func (*ResolveIncidentResponse) Reset 

func (m *ResolveIncidentResponse) Reset()

func (*ResolveIncidentResponse) String 

func (m *ResolveIncidentResponse) String() string

func (*ResolveIncidentResponse) XXX_DiscardUnknown 

func (m *ResolveIncidentResponse) XXX_DiscardUnknown()

func (*ResolveIncidentResponse) XXX_Marshal 

func (m *ResolveIncidentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResolveIncidentResponse) XXX_Merge 

func (m *ResolveIncidentResponse) XXX_Merge(src proto.Message)

func (*ResolveIncidentResponse) XXX_Size 

func (m *ResolveIncidentResponse) XXX_Size() int

func (*ResolveIncidentResponse) XXX_Unmarshal 

func (m *ResolveIncidentResponse) XXX_Unmarshal(b []byte) error

type SetVariablesRequest 

type SetVariablesRequest struct {
	// the unique identifier of a particular element; can be the workflow instance key (as
	// obtained during instance creation), or a given element, such as a service task (see
	// elementInstanceKey on the job message)
	ElementInstanceKey int64 `protobuf:"varint,1,opt,name=elementInstanceKey,proto3" json:"elementInstanceKey,omitempty"`
	// a JSON serialized document describing variables as key value pairs; the root of the document
	// must be an object
	Variables string `protobuf:"bytes,2,opt,name=variables,proto3" json:"variables,omitempty"`
	// if true, the variables will be merged strictly into the local scope (as indicated by
	// elementInstanceKey); this means the variables is not propagated to upper scopes.
	// for example, let's say we have two scopes, '1' and '2', with each having effective variables as:
	// 1 => `{ "foo" : 2 }`, and 2 => `{ "bar" : 1 }`. if we send an update request with
	// elementInstanceKey = 2, variables `{ "foo" : 5 }`, and local is true, then scope 1 will
	// be unchanged, and scope 2 will now be `{ "bar" : 1, "foo" 5 }`. if local was false, however,
	// then scope 1 would be `{ "foo": 5 }`, and scope 2 would be `{ "bar" : 1 }`.
	Local                bool     `protobuf:"varint,3,opt,name=local,proto3" json:"local,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetVariablesRequest) Descriptor 

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

func (*SetVariablesRequest) GetElementInstanceKey 

func (m *SetVariablesRequest) GetElementInstanceKey() int64

func (*SetVariablesRequest) GetLocal 

func (m *SetVariablesRequest) GetLocal() bool

func (*SetVariablesRequest) GetVariables 

func (m *SetVariablesRequest) GetVariables() string

func (*SetVariablesRequest) ProtoMessage 

func (*SetVariablesRequest) ProtoMessage()

func (*SetVariablesRequest) Reset 

func (m *SetVariablesRequest) Reset()

func (*SetVariablesRequest) String 

func (m *SetVariablesRequest) String() string

func (*SetVariablesRequest) XXX_DiscardUnknown 

func (m *SetVariablesRequest) XXX_DiscardUnknown()

func (*SetVariablesRequest) XXX_Marshal 

func (m *SetVariablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetVariablesRequest) XXX_Merge 

func (m *SetVariablesRequest) XXX_Merge(src proto.Message)

func (*SetVariablesRequest) XXX_Size 

func (m *SetVariablesRequest) XXX_Size() int

func (*SetVariablesRequest) XXX_Unmarshal 

func (m *SetVariablesRequest) XXX_Unmarshal(b []byte) error

type SetVariablesResponse 

type SetVariablesResponse struct {
	// the unique key of the set variables command
	Key                  int64    `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetVariablesResponse) Descriptor 

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

func (*SetVariablesResponse) GetKey 

func (m *SetVariablesResponse) GetKey() int64

func (*SetVariablesResponse) ProtoMessage 

func (*SetVariablesResponse) ProtoMessage()

func (*SetVariablesResponse) Reset 

func (m *SetVariablesResponse) Reset()

func (*SetVariablesResponse) String 

func (m *SetVariablesResponse) String() string

func (*SetVariablesResponse) XXX_DiscardUnknown 

func (m *SetVariablesResponse) XXX_DiscardUnknown()

func (*SetVariablesResponse) XXX_Marshal 

func (m *SetVariablesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetVariablesResponse) XXX_Merge 

func (m *SetVariablesResponse) XXX_Merge(src proto.Message)

func (*SetVariablesResponse) XXX_Size 

func (m *SetVariablesResponse) XXX_Size() int

func (*SetVariablesResponse) XXX_Unmarshal 

func (m *SetVariablesResponse) XXX_Unmarshal(b []byte) error

type ThrowErrorRequest 

type ThrowErrorRequest struct {
	// the unique job identifier, as obtained when activating the job
	JobKey int64 `protobuf:"varint,1,opt,name=jobKey,proto3" json:"jobKey,omitempty"`
	// the error code that will be matched with an error catch event
	ErrorCode string `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	// an optional error message that provides additional context
	ErrorMessage         string   `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ThrowErrorRequest) Descriptor 

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

func (*ThrowErrorRequest) GetErrorCode 

func (m *ThrowErrorRequest) GetErrorCode() string

func (*ThrowErrorRequest) GetErrorMessage 

func (m *ThrowErrorRequest) GetErrorMessage() string

func (*ThrowErrorRequest) GetJobKey 

func (m *ThrowErrorRequest) GetJobKey() int64

func (*ThrowErrorRequest) ProtoMessage 

func (*ThrowErrorRequest) ProtoMessage()

func (*ThrowErrorRequest) Reset 

func (m *ThrowErrorRequest) Reset()

func (*ThrowErrorRequest) String 

func (m *ThrowErrorRequest) String() string

func (*ThrowErrorRequest) XXX_DiscardUnknown 

func (m *ThrowErrorRequest) XXX_DiscardUnknown()

func (*ThrowErrorRequest) XXX_Marshal 

func (m *ThrowErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ThrowErrorRequest) XXX_Merge 

func (m *ThrowErrorRequest) XXX_Merge(src proto.Message)

func (*ThrowErrorRequest) XXX_Size 

func (m *ThrowErrorRequest) XXX_Size() int

func (*ThrowErrorRequest) XXX_Unmarshal 

func (m *ThrowErrorRequest) XXX_Unmarshal(b []byte) error

type ThrowErrorResponse 

type ThrowErrorResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ThrowErrorResponse) Descriptor 

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

func (*ThrowErrorResponse) ProtoMessage 

func (*ThrowErrorResponse) ProtoMessage()

func (*ThrowErrorResponse) Reset 

func (m *ThrowErrorResponse) Reset()

func (*ThrowErrorResponse) String 

func (m *ThrowErrorResponse) String() string

func (*ThrowErrorResponse) XXX_DiscardUnknown 

func (m *ThrowErrorResponse) XXX_DiscardUnknown()

func (*ThrowErrorResponse) XXX_Marshal 

func (m *ThrowErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ThrowErrorResponse) XXX_Merge 

func (m *ThrowErrorResponse) XXX_Merge(src proto.Message)

func (*ThrowErrorResponse) XXX_Size 

func (m *ThrowErrorResponse) XXX_Size() int

func (*ThrowErrorResponse) XXX_Unmarshal 

func (m *ThrowErrorResponse) XXX_Unmarshal(b []byte) error

type TopologyRequest 

type TopologyRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TopologyRequest) Descriptor 

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

func (*TopologyRequest) ProtoMessage 

func (*TopologyRequest) ProtoMessage()

func (*TopologyRequest) Reset 

func (m *TopologyRequest) Reset()

func (*TopologyRequest) String 

func (m *TopologyRequest) String() string

func (*TopologyRequest) XXX_DiscardUnknown 

func (m *TopologyRequest) XXX_DiscardUnknown()

func (*TopologyRequest) XXX_Marshal 

func (m *TopologyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopologyRequest) XXX_Merge 

func (m *TopologyRequest) XXX_Merge(src proto.Message)

func (*TopologyRequest) XXX_Size 

func (m *TopologyRequest) XXX_Size() int

func (*TopologyRequest) XXX_Unmarshal 

func (m *TopologyRequest) XXX_Unmarshal(b []byte) error

type TopologyResponse 

type TopologyResponse struct {
	// list of brokers part of this cluster
	Brokers []*BrokerInfo `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`
	// how many nodes are in the cluster
	ClusterSize int32 `protobuf:"varint,2,opt,name=clusterSize,proto3" json:"clusterSize,omitempty"`
	// how many partitions are spread across the cluster
	PartitionsCount int32 `protobuf:"varint,3,opt,name=partitionsCount,proto3" json:"partitionsCount,omitempty"`
	// configured replication factor for this cluster
	ReplicationFactor int32 `protobuf:"varint,4,opt,name=replicationFactor,proto3" json:"replicationFactor,omitempty"`
	// gateway version
	GatewayVersion       string   `protobuf:"bytes,5,opt,name=gatewayVersion,proto3" json:"gatewayVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TopologyResponse) Descriptor 

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

func (*TopologyResponse) GetBrokers 

func (m *TopologyResponse) GetBrokers() []*BrokerInfo

func (*TopologyResponse) GetClusterSize 

func (m *TopologyResponse) GetClusterSize() int32

func (*TopologyResponse) GetGatewayVersion 

func (m *TopologyResponse) GetGatewayVersion() string

func (*TopologyResponse) GetPartitionsCount 

func (m *TopologyResponse) GetPartitionsCount() int32

func (*TopologyResponse) GetReplicationFactor 

func (m *TopologyResponse) GetReplicationFactor() int32

func (*TopologyResponse) ProtoMessage 

func (*TopologyResponse) ProtoMessage()

func (*TopologyResponse) Reset 

func (m *TopologyResponse) Reset()

func (*TopologyResponse) String 

func (m *TopologyResponse) String() string

func (*TopologyResponse) XXX_DiscardUnknown 

func (m *TopologyResponse) XXX_DiscardUnknown()

func (*TopologyResponse) XXX_Marshal 

func (m *TopologyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopologyResponse) XXX_Merge 

func (m *TopologyResponse) XXX_Merge(src proto.Message)

func (*TopologyResponse) XXX_Size 

func (m *TopologyResponse) XXX_Size() int

func (*TopologyResponse) XXX_Unmarshal 

func (m *TopologyResponse) XXX_Unmarshal(b []byte) error

type UnimplementedGatewayServer 

type UnimplementedGatewayServer struct {
}

UnimplementedGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedGatewayServer) ActivateJobs 

func (*UnimplementedGatewayServer) ActivateJobs(req *ActivateJobsRequest, srv Gateway_ActivateJobsServer) error

func (*UnimplementedGatewayServer) CancelWorkflowInstance 

func (*UnimplementedGatewayServer) CancelWorkflowInstance(ctx context.Context, req *CancelWorkflowInstanceRequest) (*CancelWorkflowInstanceResponse, error)

func (*UnimplementedGatewayServer) CompleteJob 

func (*UnimplementedGatewayServer) CompleteJob(ctx context.Context, req *CompleteJobRequest) (*CompleteJobResponse, error)

func (*UnimplementedGatewayServer) CreateWorkflowInstance 

func (*UnimplementedGatewayServer) CreateWorkflowInstance(ctx context.Context, req *CreateWorkflowInstanceRequest) (*CreateWorkflowInstanceResponse, error)

func (*UnimplementedGatewayServer) CreateWorkflowInstanceWithResult 

func (*UnimplementedGatewayServer) CreateWorkflowInstanceWithResult(ctx context.Context, req *CreateWorkflowInstanceWithResultRequest) (*CreateWorkflowInstanceWithResultResponse, error)

func (*UnimplementedGatewayServer) DeployWorkflow 

func (*UnimplementedGatewayServer) DeployWorkflow(ctx context.Context, req *DeployWorkflowRequest) (*DeployWorkflowResponse, error)

func (*UnimplementedGatewayServer) FailJob 

func (*UnimplementedGatewayServer) FailJob(ctx context.Context, req *FailJobRequest) (*FailJobResponse, error)

func (*UnimplementedGatewayServer) PublishMessage 

func (*UnimplementedGatewayServer) PublishMessage(ctx context.Context, req *PublishMessageRequest) (*PublishMessageResponse, error)

func (*UnimplementedGatewayServer) ResolveIncident 

func (*UnimplementedGatewayServer) ResolveIncident(ctx context.Context, req *ResolveIncidentRequest) (*ResolveIncidentResponse, error)

func (*UnimplementedGatewayServer) SetVariables 

func (*UnimplementedGatewayServer) SetVariables(ctx context.Context, req *SetVariablesRequest) (*SetVariablesResponse, error)

func (*UnimplementedGatewayServer) ThrowError 

func (*UnimplementedGatewayServer) ThrowError(ctx context.Context, req *ThrowErrorRequest) (*ThrowErrorResponse, error)

func (*UnimplementedGatewayServer) Topology 

func (*UnimplementedGatewayServer) Topology(ctx context.Context, req *TopologyRequest) (*TopologyResponse, error)

func (*UnimplementedGatewayServer) UpdateJobRetries 

func (*UnimplementedGatewayServer) UpdateJobRetries(ctx context.Context, req *UpdateJobRetriesRequest) (*UpdateJobRetriesResponse, error)

type UpdateJobRetriesRequest 

type UpdateJobRetriesRequest struct {
	// the unique job identifier, as obtained through ActivateJobs
	JobKey int64 `protobuf:"varint,1,opt,name=jobKey,proto3" json:"jobKey,omitempty"`
	// the new amount of retries for the job; must be positive
	Retries              int32    `protobuf:"varint,2,opt,name=retries,proto3" json:"retries,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateJobRetriesRequest) Descriptor 

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

func (*UpdateJobRetriesRequest) GetJobKey 

func (m *UpdateJobRetriesRequest) GetJobKey() int64

func (*UpdateJobRetriesRequest) GetRetries 

func (m *UpdateJobRetriesRequest) GetRetries() int32

func (*UpdateJobRetriesRequest) ProtoMessage 

func (*UpdateJobRetriesRequest) ProtoMessage()

func (*UpdateJobRetriesRequest) Reset 

func (m *UpdateJobRetriesRequest) Reset()

func (*UpdateJobRetriesRequest) String 

func (m *UpdateJobRetriesRequest) String() string

func (*UpdateJobRetriesRequest) XXX_DiscardUnknown 

func (m *UpdateJobRetriesRequest) XXX_DiscardUnknown()

func (*UpdateJobRetriesRequest) XXX_Marshal 

func (m *UpdateJobRetriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateJobRetriesRequest) XXX_Merge 

func (m *UpdateJobRetriesRequest) XXX_Merge(src proto.Message)

func (*UpdateJobRetriesRequest) XXX_Size 

func (m *UpdateJobRetriesRequest) XXX_Size() int

func (*UpdateJobRetriesRequest) XXX_Unmarshal 

func (m *UpdateJobRetriesRequest) XXX_Unmarshal(b []byte) error

type UpdateJobRetriesResponse 

type UpdateJobRetriesResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateJobRetriesResponse) Descriptor 

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

func (*UpdateJobRetriesResponse) ProtoMessage 

func (*UpdateJobRetriesResponse) ProtoMessage()

func (*UpdateJobRetriesResponse) Reset 

func (m *UpdateJobRetriesResponse) Reset()

func (*UpdateJobRetriesResponse) String 

func (m *UpdateJobRetriesResponse) String() string

func (*UpdateJobRetriesResponse) XXX_DiscardUnknown 

func (m *UpdateJobRetriesResponse) XXX_DiscardUnknown()

func (*UpdateJobRetriesResponse) XXX_Marshal 

func (m *UpdateJobRetriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateJobRetriesResponse) XXX_Merge 

func (m *UpdateJobRetriesResponse) XXX_Merge(src proto.Message)

func (*UpdateJobRetriesResponse) XXX_Size 

func (m *UpdateJobRetriesResponse) XXX_Size() int

func (*UpdateJobRetriesResponse) XXX_Unmarshal 

func (m *UpdateJobRetriesResponse) XXX_Unmarshal(b []byte) error

type WorkflowMetadata 

type WorkflowMetadata struct {
	// the bpmn process ID, as parsed during deployment; together with the version forms a
	// unique identifier for a specific workflow 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 workflow
	WorkflowKey int64 `protobuf:"varint,3,opt,name=workflowKey,proto3" json:"workflowKey,omitempty"`
	// the resource name (see: WorkflowRequestObject.name) from which this workflow was
	// parsed
	ResourceName         string   `protobuf:"bytes,4,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowMetadata) Descriptor 

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

func (*WorkflowMetadata) GetBpmnProcessId 

func (m *WorkflowMetadata) GetBpmnProcessId() string

func (*WorkflowMetadata) GetResourceName 

func (m *WorkflowMetadata) GetResourceName() string

func (*WorkflowMetadata) GetVersion 

func (m *WorkflowMetadata) GetVersion() int32

func (*WorkflowMetadata) GetWorkflowKey 

func (m *WorkflowMetadata) GetWorkflowKey() int64

func (*WorkflowMetadata) ProtoMessage 

func (*WorkflowMetadata) ProtoMessage()

func (*WorkflowMetadata) Reset 

func (m *WorkflowMetadata) Reset()

func (*WorkflowMetadata) String 

func (m *WorkflowMetadata) String() string

func (*WorkflowMetadata) XXX_DiscardUnknown 

func (m *WorkflowMetadata) XXX_DiscardUnknown()

func (*WorkflowMetadata) XXX_Marshal 

func (m *WorkflowMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowMetadata) XXX_Merge 

func (m *WorkflowMetadata) XXX_Merge(src proto.Message)

func (*WorkflowMetadata) XXX_Size 

func (m *WorkflowMetadata) XXX_Size() int

func (*WorkflowMetadata) XXX_Unmarshal 

func (m *WorkflowMetadata) XXX_Unmarshal(b []byte) error

type WorkflowRequestObject 

type WorkflowRequestObject struct {
	// the resource basename, e.g. myProcess.bpmn
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the resource type; if set to BPMN or YAML then the file extension
	// is ignored
	Type WorkflowRequestObject_ResourceType `protobuf:"varint,2,opt,name=type,proto3,enum=gateway_protocol.WorkflowRequestObject_ResourceType" json:"type,omitempty"`
	// the process definition as a UTF8-encoded string
	Definition           []byte   `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowRequestObject) Descriptor 

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

func (*WorkflowRequestObject) GetDefinition 

func (m *WorkflowRequestObject) GetDefinition() []byte

func (*WorkflowRequestObject) GetName 

func (m *WorkflowRequestObject) GetName() string

func (*WorkflowRequestObject) GetType 

func (m *WorkflowRequestObject) GetType() WorkflowRequestObject_ResourceType

func (*WorkflowRequestObject) ProtoMessage 

func (*WorkflowRequestObject) ProtoMessage()

func (*WorkflowRequestObject) Reset 

func (m *WorkflowRequestObject) Reset()

func (*WorkflowRequestObject) String 

func (m *WorkflowRequestObject) String() string

func (*WorkflowRequestObject) XXX_DiscardUnknown 

func (m *WorkflowRequestObject) XXX_DiscardUnknown()

func (*WorkflowRequestObject) XXX_Marshal 

func (m *WorkflowRequestObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowRequestObject) XXX_Merge 

func (m *WorkflowRequestObject) XXX_Merge(src proto.Message)

func (*WorkflowRequestObject) XXX_Size 

func (m *WorkflowRequestObject) XXX_Size() int

func (*WorkflowRequestObject) XXX_Unmarshal 

func (m *WorkflowRequestObject) XXX_Unmarshal(b []byte) error

type WorkflowRequestObject_ResourceType 

type WorkflowRequestObject_ResourceType int32
const (
	// FILE type means the gateway will try to detect the resource type
	// using the file extension of the name field
	WorkflowRequestObject_FILE WorkflowRequestObject_ResourceType = 0
	WorkflowRequestObject_BPMN WorkflowRequestObject_ResourceType = 1
	WorkflowRequestObject_YAML WorkflowRequestObject_ResourceType = 2
)

func (WorkflowRequestObject_ResourceType) EnumDescriptor 

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

func (WorkflowRequestObject_ResourceType) String 

func (x WorkflowRequestObject_ResourceType) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.