zeebe

package
v0.2.4 Latest Latest
Warning

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

Go to latest
Published: Sep 20, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	RecordMetadata_ValueType_name = map[int32]string{
		0:  "UNKNOWN_VALUE_TYPE",
		1:  "JOB",
		2:  "DEPLOYMENT",
		3:  "PROCESS_INSTANCE",
		4:  "INCIDENT",
		5:  "MESSAGE",
		6:  "MESSAGE_SUBSCRIPTION",
		7:  "PROCESS_MESSAGE_SUBSCRIPTION",
		8:  "JOB_BATCH",
		9:  "TIMER",
		10: "MESSAGE_START_EVENT_SUBSCRIPTION",
		11: "VARIABLE",
		12: "VARIABLE_DOCUMENT",
		13: "PROCESS_INSTANCE_CREATION",
		14: "ERROR",
		15: "PROCESS",
		16: "DEPLOYMENT_DISTRIBUTION",
		17: "PROCESS_EVENT",
		18: "DECISION",
		19: "DECISION_REQUIREMENTS",
		20: "DECISION_EVALUATION",
	}
	RecordMetadata_ValueType_value = map[string]int32{
		"UNKNOWN_VALUE_TYPE":               0,
		"JOB":                              1,
		"DEPLOYMENT":                       2,
		"PROCESS_INSTANCE":                 3,
		"INCIDENT":                         4,
		"MESSAGE":                          5,
		"MESSAGE_SUBSCRIPTION":             6,
		"PROCESS_MESSAGE_SUBSCRIPTION":     7,
		"JOB_BATCH":                        8,
		"TIMER":                            9,
		"MESSAGE_START_EVENT_SUBSCRIPTION": 10,
		"VARIABLE":                         11,
		"VARIABLE_DOCUMENT":                12,
		"PROCESS_INSTANCE_CREATION":        13,
		"ERROR":                            14,
		"PROCESS":                          15,
		"DEPLOYMENT_DISTRIBUTION":          16,
		"PROCESS_EVENT":                    17,
		"DECISION":                         18,
		"DECISION_REQUIREMENTS":            19,
		"DECISION_EVALUATION":              20,
	}
)

Enum value maps for RecordMetadata_ValueType.

View Source
var (
	RecordMetadata_RecordType_name = map[int32]string{
		0: "UNKNOWN_RECORD_TYPE",
		1: "EVENT",
		2: "COMMAND",
		3: "COMMAND_REJECTION",
	}
	RecordMetadata_RecordType_value = map[string]int32{
		"UNKNOWN_RECORD_TYPE": 0,
		"EVENT":               1,
		"COMMAND":             2,
		"COMMAND_REJECTION":   3,
	}
)

Enum value maps for RecordMetadata_RecordType.

View Source
var (
	VariableDocumentRecord_UpdateSemantics_name = map[int32]string{
		0: "UNKNOWN_UPDATE_SEMANTICS",
		1: "LOCAL",
		2: "PROPAGATE",
	}
	VariableDocumentRecord_UpdateSemantics_value = map[string]int32{
		"UNKNOWN_UPDATE_SEMANTICS": 0,
		"LOCAL":                    1,
		"PROPAGATE":                2,
	}
)

Enum value maps for VariableDocumentRecord_UpdateSemantics.

View Source
var File_schema_proto protoreflect.FileDescriptor

Functions

func NewExporter

func NewExporter() (exporter, error)

NewExporter creates an exporter with a default Hazelcast client. The default settings of a Hazelcast client are using localhost:5701 as target for the Hazelcast server it will return an error, when the connection can't be established to the Hazelcast server

func NewExporterWithHazelcastClient

func NewExporterWithHazelcastClient(client *hazelcast.Client) (exporter, error)

NewExporterWithHazelcastClient creates an exporter with the given Hazelcast client. it will return any connection or RingBuffer error

Types

type DecisionEvaluationRecord

type DecisionEvaluationRecord struct {
	Metadata                 *RecordMetadata                               `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	DecisionKey              int64                                         `protobuf:"varint,2,opt,name=decisionKey,proto3" json:"decisionKey,omitempty"`
	DecisionId               string                                        `protobuf:"bytes,3,opt,name=decisionId,proto3" json:"decisionId,omitempty"`
	DecisionName             string                                        `protobuf:"bytes,4,opt,name=decisionName,proto3" json:"decisionName,omitempty"`
	DecisionVersion          int32                                         `protobuf:"varint,5,opt,name=decisionVersion,proto3" json:"decisionVersion,omitempty"`
	DecisionRequirementsId   string                                        `protobuf:"bytes,6,opt,name=decisionRequirementsId,proto3" json:"decisionRequirementsId,omitempty"`
	DecisionRequirementsKey  int64                                         `protobuf:"varint,7,opt,name=decisionRequirementsKey,proto3" json:"decisionRequirementsKey,omitempty"`
	DecisionOutput           string                                        `protobuf:"bytes,8,opt,name=decisionOutput,proto3" json:"decisionOutput,omitempty"`
	BpmnProcessId            string                                        `protobuf:"bytes,9,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	ProcessDefinitionKey     int64                                         `protobuf:"varint,10,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	ProcessInstanceKey       int64                                         `protobuf:"varint,11,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	ElementId                string                                        `protobuf:"bytes,12,opt,name=elementId,proto3" json:"elementId,omitempty"`
	ElementInstanceKey       int64                                         `protobuf:"varint,13,opt,name=elementInstanceKey,proto3" json:"elementInstanceKey,omitempty"`
	EvaluationFailureMessage string                                        `protobuf:"bytes,14,opt,name=evaluationFailureMessage,proto3" json:"evaluationFailureMessage,omitempty"`
	FailedDecisionId         string                                        `protobuf:"bytes,15,opt,name=failedDecisionId,proto3" json:"failedDecisionId,omitempty"`
	EvaluatedDecisions       []*DecisionEvaluationRecord_EvaluatedDecision `protobuf:"bytes,16,rep,name=evaluatedDecisions,proto3" json:"evaluatedDecisions,omitempty"`
	// contains filtered or unexported fields
}

func (*DecisionEvaluationRecord) Descriptor deprecated

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

Deprecated: Use DecisionEvaluationRecord.ProtoReflect.Descriptor instead.

func (*DecisionEvaluationRecord) GetBpmnProcessId

func (x *DecisionEvaluationRecord) GetBpmnProcessId() string

func (*DecisionEvaluationRecord) GetDecisionId

func (x *DecisionEvaluationRecord) GetDecisionId() string

func (*DecisionEvaluationRecord) GetDecisionKey

func (x *DecisionEvaluationRecord) GetDecisionKey() int64

func (*DecisionEvaluationRecord) GetDecisionName

func (x *DecisionEvaluationRecord) GetDecisionName() string

func (*DecisionEvaluationRecord) GetDecisionOutput

func (x *DecisionEvaluationRecord) GetDecisionOutput() string

func (*DecisionEvaluationRecord) GetDecisionRequirementsId

func (x *DecisionEvaluationRecord) GetDecisionRequirementsId() string

func (*DecisionEvaluationRecord) GetDecisionRequirementsKey

func (x *DecisionEvaluationRecord) GetDecisionRequirementsKey() int64

func (*DecisionEvaluationRecord) GetDecisionVersion

func (x *DecisionEvaluationRecord) GetDecisionVersion() int32

func (*DecisionEvaluationRecord) GetElementId

func (x *DecisionEvaluationRecord) GetElementId() string

func (*DecisionEvaluationRecord) GetElementInstanceKey

func (x *DecisionEvaluationRecord) GetElementInstanceKey() int64

func (*DecisionEvaluationRecord) GetEvaluatedDecisions

func (*DecisionEvaluationRecord) GetEvaluationFailureMessage

func (x *DecisionEvaluationRecord) GetEvaluationFailureMessage() string

func (*DecisionEvaluationRecord) GetFailedDecisionId

func (x *DecisionEvaluationRecord) GetFailedDecisionId() string

func (*DecisionEvaluationRecord) GetMetadata

func (x *DecisionEvaluationRecord) GetMetadata() *RecordMetadata

func (*DecisionEvaluationRecord) GetProcessDefinitionKey

func (x *DecisionEvaluationRecord) GetProcessDefinitionKey() int64

func (*DecisionEvaluationRecord) GetProcessInstanceKey

func (x *DecisionEvaluationRecord) GetProcessInstanceKey() int64

func (*DecisionEvaluationRecord) ProtoMessage

func (*DecisionEvaluationRecord) ProtoMessage()

func (*DecisionEvaluationRecord) ProtoReflect

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

func (*DecisionEvaluationRecord) Reset

func (x *DecisionEvaluationRecord) Reset()

func (*DecisionEvaluationRecord) String

func (x *DecisionEvaluationRecord) String() string

type DecisionEvaluationRecord_EvaluatedDecision

type DecisionEvaluationRecord_EvaluatedDecision struct {
	DecisionId      string                                     `protobuf:"bytes,1,opt,name=decisionId,proto3" json:"decisionId,omitempty"`
	DecisionName    string                                     `protobuf:"bytes,2,opt,name=decisionName,proto3" json:"decisionName,omitempty"`
	DecisionKey     int64                                      `protobuf:"varint,3,opt,name=decisionKey,proto3" json:"decisionKey,omitempty"`
	DecisionVersion int64                                      `protobuf:"varint,4,opt,name=decisionVersion,proto3" json:"decisionVersion,omitempty"`
	DecisionType    string                                     `protobuf:"bytes,5,opt,name=decisionType,proto3" json:"decisionType,omitempty"`
	DecisionOutput  string                                     `protobuf:"bytes,6,opt,name=decisionOutput,proto3" json:"decisionOutput,omitempty"`
	EvaluatedInputs []*DecisionEvaluationRecord_EvaluatedInput `protobuf:"bytes,7,rep,name=evaluatedInputs,proto3" json:"evaluatedInputs,omitempty"`
	MatchedRules    []*DecisionEvaluationRecord_MatchedRule    `protobuf:"bytes,8,rep,name=matchedRules,proto3" json:"matchedRules,omitempty"`
	// contains filtered or unexported fields
}

func (*DecisionEvaluationRecord_EvaluatedDecision) Descriptor deprecated

Deprecated: Use DecisionEvaluationRecord_EvaluatedDecision.ProtoReflect.Descriptor instead.

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionId

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionKey

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionName

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionOutput

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetDecisionOutput() string

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionType

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionVersion

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetDecisionVersion() int64

func (*DecisionEvaluationRecord_EvaluatedDecision) GetEvaluatedInputs

func (*DecisionEvaluationRecord_EvaluatedDecision) GetMatchedRules

func (*DecisionEvaluationRecord_EvaluatedDecision) ProtoMessage

func (*DecisionEvaluationRecord_EvaluatedDecision) ProtoReflect

func (*DecisionEvaluationRecord_EvaluatedDecision) Reset

func (*DecisionEvaluationRecord_EvaluatedDecision) String

type DecisionEvaluationRecord_EvaluatedInput

type DecisionEvaluationRecord_EvaluatedInput struct {
	InputId    string `protobuf:"bytes,1,opt,name=inputId,proto3" json:"inputId,omitempty"`
	InputName  string `protobuf:"bytes,2,opt,name=inputName,proto3" json:"inputName,omitempty"`
	InputValue string `protobuf:"bytes,3,opt,name=inputValue,proto3" json:"inputValue,omitempty"`
	// contains filtered or unexported fields
}

func (*DecisionEvaluationRecord_EvaluatedInput) Descriptor deprecated

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

Deprecated: Use DecisionEvaluationRecord_EvaluatedInput.ProtoReflect.Descriptor instead.

func (*DecisionEvaluationRecord_EvaluatedInput) GetInputId

func (*DecisionEvaluationRecord_EvaluatedInput) GetInputName

func (*DecisionEvaluationRecord_EvaluatedInput) GetInputValue

func (*DecisionEvaluationRecord_EvaluatedInput) ProtoMessage

func (*DecisionEvaluationRecord_EvaluatedInput) ProtoReflect

func (*DecisionEvaluationRecord_EvaluatedInput) Reset

func (*DecisionEvaluationRecord_EvaluatedInput) String

type DecisionEvaluationRecord_EvaluatedOutput

type DecisionEvaluationRecord_EvaluatedOutput struct {
	OutputId    string `protobuf:"bytes,1,opt,name=outputId,proto3" json:"outputId,omitempty"`
	OutputName  string `protobuf:"bytes,2,opt,name=outputName,proto3" json:"outputName,omitempty"`
	OutputValue string `protobuf:"bytes,3,opt,name=outputValue,proto3" json:"outputValue,omitempty"`
	// contains filtered or unexported fields
}

func (*DecisionEvaluationRecord_EvaluatedOutput) Descriptor deprecated

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

Deprecated: Use DecisionEvaluationRecord_EvaluatedOutput.ProtoReflect.Descriptor instead.

func (*DecisionEvaluationRecord_EvaluatedOutput) GetOutputId

func (*DecisionEvaluationRecord_EvaluatedOutput) GetOutputName

func (*DecisionEvaluationRecord_EvaluatedOutput) GetOutputValue

func (*DecisionEvaluationRecord_EvaluatedOutput) ProtoMessage

func (*DecisionEvaluationRecord_EvaluatedOutput) ProtoReflect

func (*DecisionEvaluationRecord_EvaluatedOutput) Reset

func (*DecisionEvaluationRecord_EvaluatedOutput) String

type DecisionEvaluationRecord_MatchedRule

type DecisionEvaluationRecord_MatchedRule struct {
	RuleId           string                                      `protobuf:"bytes,1,opt,name=ruleId,proto3" json:"ruleId,omitempty"`
	RuleIndex        int32                                       `protobuf:"varint,2,opt,name=ruleIndex,proto3" json:"ruleIndex,omitempty"`
	EvaluatedOutputs []*DecisionEvaluationRecord_EvaluatedOutput `protobuf:"bytes,3,rep,name=evaluatedOutputs,proto3" json:"evaluatedOutputs,omitempty"`
	// contains filtered or unexported fields
}

func (*DecisionEvaluationRecord_MatchedRule) Descriptor deprecated

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

Deprecated: Use DecisionEvaluationRecord_MatchedRule.ProtoReflect.Descriptor instead.

func (*DecisionEvaluationRecord_MatchedRule) GetEvaluatedOutputs

func (*DecisionEvaluationRecord_MatchedRule) GetRuleId

func (*DecisionEvaluationRecord_MatchedRule) GetRuleIndex

func (x *DecisionEvaluationRecord_MatchedRule) GetRuleIndex() int32

func (*DecisionEvaluationRecord_MatchedRule) ProtoMessage

func (*DecisionEvaluationRecord_MatchedRule) ProtoMessage()

func (*DecisionEvaluationRecord_MatchedRule) ProtoReflect

func (*DecisionEvaluationRecord_MatchedRule) Reset

func (*DecisionEvaluationRecord_MatchedRule) String

type DecisionRecord

type DecisionRecord struct {
	Metadata                *RecordMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	DecisionId              string          `protobuf:"bytes,2,opt,name=decisionId,proto3" json:"decisionId,omitempty"`
	Version                 int32           `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	DecisionKey             int64           `protobuf:"varint,4,opt,name=decisionKey,proto3" json:"decisionKey,omitempty"`
	DecisionName            string          `protobuf:"bytes,5,opt,name=decisionName,proto3" json:"decisionName,omitempty"`
	DecisionRequirementsId  string          `protobuf:"bytes,6,opt,name=decisionRequirementsId,proto3" json:"decisionRequirementsId,omitempty"`
	DecisionRequirementsKey int64           `protobuf:"varint,7,opt,name=decisionRequirementsKey,proto3" json:"decisionRequirementsKey,omitempty"`
	IsDuplicate             bool            `protobuf:"varint,8,opt,name=isDuplicate,proto3" json:"isDuplicate,omitempty"`
	// contains filtered or unexported fields
}

func (*DecisionRecord) Descriptor deprecated

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

Deprecated: Use DecisionRecord.ProtoReflect.Descriptor instead.

func (*DecisionRecord) GetDecisionId

func (x *DecisionRecord) GetDecisionId() string

func (*DecisionRecord) GetDecisionKey

func (x *DecisionRecord) GetDecisionKey() int64

func (*DecisionRecord) GetDecisionName

func (x *DecisionRecord) GetDecisionName() string

func (*DecisionRecord) GetDecisionRequirementsId

func (x *DecisionRecord) GetDecisionRequirementsId() string

func (*DecisionRecord) GetDecisionRequirementsKey

func (x *DecisionRecord) GetDecisionRequirementsKey() int64

func (*DecisionRecord) GetIsDuplicate

func (x *DecisionRecord) GetIsDuplicate() bool

func (*DecisionRecord) GetMetadata

func (x *DecisionRecord) GetMetadata() *RecordMetadata

func (*DecisionRecord) GetVersion

func (x *DecisionRecord) GetVersion() int32

func (*DecisionRecord) ProtoMessage

func (*DecisionRecord) ProtoMessage()

func (*DecisionRecord) ProtoReflect

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

func (*DecisionRecord) Reset

func (x *DecisionRecord) Reset()

func (*DecisionRecord) String

func (x *DecisionRecord) String() string

type DecisionRequirementsMetadata

type DecisionRequirementsMetadata struct {
	DecisionRequirementsId      string `protobuf:"bytes,1,opt,name=decisionRequirementsId,proto3" json:"decisionRequirementsId,omitempty"`
	DecisionRequirementsName    string `protobuf:"bytes,2,opt,name=decisionRequirementsName,proto3" json:"decisionRequirementsName,omitempty"`
	DecisionRequirementsVersion int32  `protobuf:"varint,3,opt,name=decisionRequirementsVersion,proto3" json:"decisionRequirementsVersion,omitempty"`
	DecisionRequirementsKey     int64  `protobuf:"varint,4,opt,name=decisionRequirementsKey,proto3" json:"decisionRequirementsKey,omitempty"`
	Namespace                   string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ResourceName                string `protobuf:"bytes,6,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	Checksum                    []byte `protobuf:"bytes,7,opt,name=checksum,proto3" json:"checksum,omitempty"`
	IsDuplicate                 bool   `protobuf:"varint,8,opt,name=isDuplicate,proto3" json:"isDuplicate,omitempty"`
	// contains filtered or unexported fields
}

func (*DecisionRequirementsMetadata) Descriptor deprecated

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

Deprecated: Use DecisionRequirementsMetadata.ProtoReflect.Descriptor instead.

func (*DecisionRequirementsMetadata) GetChecksum

func (x *DecisionRequirementsMetadata) GetChecksum() []byte

func (*DecisionRequirementsMetadata) GetDecisionRequirementsId

func (x *DecisionRequirementsMetadata) GetDecisionRequirementsId() string

func (*DecisionRequirementsMetadata) GetDecisionRequirementsKey

func (x *DecisionRequirementsMetadata) GetDecisionRequirementsKey() int64

func (*DecisionRequirementsMetadata) GetDecisionRequirementsName

func (x *DecisionRequirementsMetadata) GetDecisionRequirementsName() string

func (*DecisionRequirementsMetadata) GetDecisionRequirementsVersion

func (x *DecisionRequirementsMetadata) GetDecisionRequirementsVersion() int32

func (*DecisionRequirementsMetadata) GetIsDuplicate

func (x *DecisionRequirementsMetadata) GetIsDuplicate() bool

func (*DecisionRequirementsMetadata) GetNamespace

func (x *DecisionRequirementsMetadata) GetNamespace() string

func (*DecisionRequirementsMetadata) GetResourceName

func (x *DecisionRequirementsMetadata) GetResourceName() string

func (*DecisionRequirementsMetadata) ProtoMessage

func (*DecisionRequirementsMetadata) ProtoMessage()

func (*DecisionRequirementsMetadata) ProtoReflect

func (*DecisionRequirementsMetadata) Reset

func (x *DecisionRequirementsMetadata) Reset()

func (*DecisionRequirementsMetadata) String

type DecisionRequirementsRecord

type DecisionRequirementsRecord struct {
	Metadata                     *RecordMetadata               `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	DecisionRequirementsMetadata *DecisionRequirementsMetadata `protobuf:"bytes,2,opt,name=decisionRequirementsMetadata,proto3" json:"decisionRequirementsMetadata,omitempty"`
	Resource                     []byte                        `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*DecisionRequirementsRecord) Descriptor deprecated

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

Deprecated: Use DecisionRequirementsRecord.ProtoReflect.Descriptor instead.

func (*DecisionRequirementsRecord) GetDecisionRequirementsMetadata

func (x *DecisionRequirementsRecord) GetDecisionRequirementsMetadata() *DecisionRequirementsMetadata

func (*DecisionRequirementsRecord) GetMetadata

func (x *DecisionRequirementsRecord) GetMetadata() *RecordMetadata

func (*DecisionRequirementsRecord) GetResource

func (x *DecisionRequirementsRecord) GetResource() []byte

func (*DecisionRequirementsRecord) ProtoMessage

func (*DecisionRequirementsRecord) ProtoMessage()

func (*DecisionRequirementsRecord) ProtoReflect

func (*DecisionRequirementsRecord) Reset

func (x *DecisionRequirementsRecord) Reset()

func (*DecisionRequirementsRecord) String

func (x *DecisionRequirementsRecord) String() string

type DeploymentDistributionRecord

type DeploymentDistributionRecord struct {
	Metadata    *RecordMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	PartitionId int32           `protobuf:"varint,2,opt,name=partitionId,proto3" json:"partitionId,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentDistributionRecord) Descriptor deprecated

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

Deprecated: Use DeploymentDistributionRecord.ProtoReflect.Descriptor instead.

func (*DeploymentDistributionRecord) GetMetadata

func (x *DeploymentDistributionRecord) GetMetadata() *RecordMetadata

func (*DeploymentDistributionRecord) GetPartitionId

func (x *DeploymentDistributionRecord) GetPartitionId() int32

func (*DeploymentDistributionRecord) ProtoMessage

func (*DeploymentDistributionRecord) ProtoMessage()

func (*DeploymentDistributionRecord) ProtoReflect

func (*DeploymentDistributionRecord) Reset

func (x *DeploymentDistributionRecord) Reset()

func (*DeploymentDistributionRecord) String

type DeploymentRecord

type DeploymentRecord struct {
	Metadata                     *RecordMetadata                      `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Resources                    []*DeploymentRecord_Resource         `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"`
	ProcessMetadata              []*DeploymentRecord_ProcessMetadata  `protobuf:"bytes,3,rep,name=processMetadata,proto3" json:"processMetadata,omitempty"`
	DecisionRequirementsMetadata []*DecisionRequirementsMetadata      `protobuf:"bytes,4,rep,name=decisionRequirementsMetadata,proto3" json:"decisionRequirementsMetadata,omitempty"`
	DecisionMetadata             []*DeploymentRecord_DecisionMetadata `protobuf:"bytes,5,rep,name=decisionMetadata,proto3" json:"decisionMetadata,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentRecord) Descriptor deprecated

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

Deprecated: Use DeploymentRecord.ProtoReflect.Descriptor instead.

func (*DeploymentRecord) GetDecisionMetadata

func (x *DeploymentRecord) GetDecisionMetadata() []*DeploymentRecord_DecisionMetadata

func (*DeploymentRecord) GetDecisionRequirementsMetadata

func (x *DeploymentRecord) GetDecisionRequirementsMetadata() []*DecisionRequirementsMetadata

func (*DeploymentRecord) GetMetadata

func (x *DeploymentRecord) GetMetadata() *RecordMetadata

func (*DeploymentRecord) GetProcessMetadata

func (x *DeploymentRecord) GetProcessMetadata() []*DeploymentRecord_ProcessMetadata

func (*DeploymentRecord) GetResources

func (x *DeploymentRecord) GetResources() []*DeploymentRecord_Resource

func (*DeploymentRecord) ProtoMessage

func (*DeploymentRecord) ProtoMessage()

func (*DeploymentRecord) ProtoReflect

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

func (*DeploymentRecord) Reset

func (x *DeploymentRecord) Reset()

func (*DeploymentRecord) String

func (x *DeploymentRecord) String() string

type DeploymentRecord_DecisionMetadata

type DeploymentRecord_DecisionMetadata struct {
	DecisionId              string `protobuf:"bytes,1,opt,name=decisionId,proto3" json:"decisionId,omitempty"`
	Version                 int32  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	DecisionKey             int64  `protobuf:"varint,3,opt,name=decisionKey,proto3" json:"decisionKey,omitempty"`
	DecisionName            string `protobuf:"bytes,4,opt,name=decisionName,proto3" json:"decisionName,omitempty"`
	DecisionRequirementsId  string `protobuf:"bytes,5,opt,name=decisionRequirementsId,proto3" json:"decisionRequirementsId,omitempty"`
	DecisionRequirementsKey int64  `protobuf:"varint,6,opt,name=decisionRequirementsKey,proto3" json:"decisionRequirementsKey,omitempty"`
	IsDuplicate             bool   `protobuf:"varint,7,opt,name=isDuplicate,proto3" json:"isDuplicate,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentRecord_DecisionMetadata) Descriptor deprecated

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

Deprecated: Use DeploymentRecord_DecisionMetadata.ProtoReflect.Descriptor instead.

func (*DeploymentRecord_DecisionMetadata) GetDecisionId

func (x *DeploymentRecord_DecisionMetadata) GetDecisionId() string

func (*DeploymentRecord_DecisionMetadata) GetDecisionKey

func (x *DeploymentRecord_DecisionMetadata) GetDecisionKey() int64

func (*DeploymentRecord_DecisionMetadata) GetDecisionName

func (x *DeploymentRecord_DecisionMetadata) GetDecisionName() string

func (*DeploymentRecord_DecisionMetadata) GetDecisionRequirementsId

func (x *DeploymentRecord_DecisionMetadata) GetDecisionRequirementsId() string

func (*DeploymentRecord_DecisionMetadata) GetDecisionRequirementsKey

func (x *DeploymentRecord_DecisionMetadata) GetDecisionRequirementsKey() int64

func (*DeploymentRecord_DecisionMetadata) GetIsDuplicate

func (x *DeploymentRecord_DecisionMetadata) GetIsDuplicate() bool

func (*DeploymentRecord_DecisionMetadata) GetVersion

func (x *DeploymentRecord_DecisionMetadata) GetVersion() int32

func (*DeploymentRecord_DecisionMetadata) ProtoMessage

func (*DeploymentRecord_DecisionMetadata) ProtoMessage()

func (*DeploymentRecord_DecisionMetadata) ProtoReflect

func (*DeploymentRecord_DecisionMetadata) Reset

func (*DeploymentRecord_DecisionMetadata) String

type DeploymentRecord_ProcessMetadata

type DeploymentRecord_ProcessMetadata struct {
	BpmnProcessId        string `protobuf:"bytes,1,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	Version              int32  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	ProcessDefinitionKey int64  `protobuf:"varint,3,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	ResourceName         string `protobuf:"bytes,5,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	Checksum             []byte `protobuf:"bytes,6,opt,name=checksum,proto3" json:"checksum,omitempty"`
	IsDuplicate          bool   `protobuf:"varint,7,opt,name=isDuplicate,proto3" json:"isDuplicate,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentRecord_ProcessMetadata) Descriptor deprecated

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

Deprecated: Use DeploymentRecord_ProcessMetadata.ProtoReflect.Descriptor instead.

func (*DeploymentRecord_ProcessMetadata) GetBpmnProcessId

func (x *DeploymentRecord_ProcessMetadata) GetBpmnProcessId() string

func (*DeploymentRecord_ProcessMetadata) GetChecksum

func (x *DeploymentRecord_ProcessMetadata) GetChecksum() []byte

func (*DeploymentRecord_ProcessMetadata) GetIsDuplicate

func (x *DeploymentRecord_ProcessMetadata) GetIsDuplicate() bool

func (*DeploymentRecord_ProcessMetadata) GetProcessDefinitionKey

func (x *DeploymentRecord_ProcessMetadata) GetProcessDefinitionKey() int64

func (*DeploymentRecord_ProcessMetadata) GetResourceName

func (x *DeploymentRecord_ProcessMetadata) GetResourceName() string

func (*DeploymentRecord_ProcessMetadata) GetVersion

func (x *DeploymentRecord_ProcessMetadata) GetVersion() int32

func (*DeploymentRecord_ProcessMetadata) ProtoMessage

func (*DeploymentRecord_ProcessMetadata) ProtoMessage()

func (*DeploymentRecord_ProcessMetadata) ProtoReflect

func (*DeploymentRecord_ProcessMetadata) Reset

func (*DeploymentRecord_ProcessMetadata) String

type DeploymentRecord_Resource

type DeploymentRecord_Resource struct {
	Resource     []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	ResourceName string `protobuf:"bytes,2,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentRecord_Resource) Descriptor deprecated

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

Deprecated: Use DeploymentRecord_Resource.ProtoReflect.Descriptor instead.

func (*DeploymentRecord_Resource) GetResource

func (x *DeploymentRecord_Resource) GetResource() []byte

func (*DeploymentRecord_Resource) GetResourceName

func (x *DeploymentRecord_Resource) GetResourceName() string

func (*DeploymentRecord_Resource) ProtoMessage

func (*DeploymentRecord_Resource) ProtoMessage()

func (*DeploymentRecord_Resource) ProtoReflect

func (*DeploymentRecord_Resource) Reset

func (x *DeploymentRecord_Resource) Reset()

func (*DeploymentRecord_Resource) String

func (x *DeploymentRecord_Resource) String() string

type ErrorRecord

type ErrorRecord struct {
	Metadata           *RecordMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ExceptionMessage   string          `protobuf:"bytes,2,opt,name=exceptionMessage,proto3" json:"exceptionMessage,omitempty"`
	Stacktrace         string          `protobuf:"bytes,3,opt,name=stacktrace,proto3" json:"stacktrace,omitempty"`
	ErrorEventPosition int64           `protobuf:"varint,4,opt,name=errorEventPosition,proto3" json:"errorEventPosition,omitempty"`
	ProcessInstanceKey int64           `protobuf:"varint,5,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorRecord) Descriptor deprecated

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

Deprecated: Use ErrorRecord.ProtoReflect.Descriptor instead.

func (*ErrorRecord) GetErrorEventPosition

func (x *ErrorRecord) GetErrorEventPosition() int64

func (*ErrorRecord) GetExceptionMessage

func (x *ErrorRecord) GetExceptionMessage() string

func (*ErrorRecord) GetMetadata

func (x *ErrorRecord) GetMetadata() *RecordMetadata

func (*ErrorRecord) GetProcessInstanceKey

func (x *ErrorRecord) GetProcessInstanceKey() int64

func (*ErrorRecord) GetStacktrace

func (x *ErrorRecord) GetStacktrace() string

func (*ErrorRecord) ProtoMessage

func (*ErrorRecord) ProtoMessage()

func (*ErrorRecord) ProtoReflect

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

func (*ErrorRecord) Reset

func (x *ErrorRecord) Reset()

func (*ErrorRecord) String

func (x *ErrorRecord) String() string

type Hazelcast

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

func (*Hazelcast) SendToRingbuffer

func (h *Hazelcast) SendToRingbuffer(data []byte) error

type HazelcastClient

type HazelcastClient interface {
	SendToRingbuffer(data []byte) error
}

type IncidentRecord

type IncidentRecord struct {
	Metadata             *RecordMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ErrorType            string          `protobuf:"bytes,2,opt,name=errorType,proto3" json:"errorType,omitempty"`
	ErrorMessage         string          `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	BpmnProcessId        string          `protobuf:"bytes,4,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	ProcessInstanceKey   int64           `protobuf:"varint,5,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	ElementId            string          `protobuf:"bytes,6,opt,name=elementId,proto3" json:"elementId,omitempty"`
	ElementInstanceKey   int64           `protobuf:"varint,7,opt,name=elementInstanceKey,proto3" json:"elementInstanceKey,omitempty"`
	JobKey               int64           `protobuf:"varint,8,opt,name=jobKey,proto3" json:"jobKey,omitempty"`
	ProcessDefinitionKey int64           `protobuf:"varint,9,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	VariableScopeKey     int64           `protobuf:"varint,10,opt,name=variableScopeKey,proto3" json:"variableScopeKey,omitempty"`
	// contains filtered or unexported fields
}

func (*IncidentRecord) Descriptor deprecated

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

Deprecated: Use IncidentRecord.ProtoReflect.Descriptor instead.

func (*IncidentRecord) GetBpmnProcessId

func (x *IncidentRecord) GetBpmnProcessId() string

func (*IncidentRecord) GetElementId

func (x *IncidentRecord) GetElementId() string

func (*IncidentRecord) GetElementInstanceKey

func (x *IncidentRecord) GetElementInstanceKey() int64

func (*IncidentRecord) GetErrorMessage

func (x *IncidentRecord) GetErrorMessage() string

func (*IncidentRecord) GetErrorType

func (x *IncidentRecord) GetErrorType() string

func (*IncidentRecord) GetJobKey

func (x *IncidentRecord) GetJobKey() int64

func (*IncidentRecord) GetMetadata

func (x *IncidentRecord) GetMetadata() *RecordMetadata

func (*IncidentRecord) GetProcessDefinitionKey

func (x *IncidentRecord) GetProcessDefinitionKey() int64

func (*IncidentRecord) GetProcessInstanceKey

func (x *IncidentRecord) GetProcessInstanceKey() int64

func (*IncidentRecord) GetVariableScopeKey

func (x *IncidentRecord) GetVariableScopeKey() int64

func (*IncidentRecord) ProtoMessage

func (*IncidentRecord) ProtoMessage()

func (*IncidentRecord) ProtoReflect

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

func (*IncidentRecord) Reset

func (x *IncidentRecord) Reset()

func (*IncidentRecord) String

func (x *IncidentRecord) String() string

type JobBatchRecord

type JobBatchRecord struct {
	Metadata          *RecordMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Type              string          `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Worker            string          `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
	Timeout           int64           `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	MaxJobsToActivate int32           `protobuf:"varint,5,opt,name=maxJobsToActivate,proto3" json:"maxJobsToActivate,omitempty"`
	JobKeys           []int64         `protobuf:"varint,6,rep,packed,name=jobKeys,proto3" json:"jobKeys,omitempty"`
	Jobs              []*JobRecord    `protobuf:"bytes,7,rep,name=jobs,proto3" json:"jobs,omitempty"`
	Truncated         bool            `protobuf:"varint,8,opt,name=truncated,proto3" json:"truncated,omitempty"`
	// contains filtered or unexported fields
}

func (*JobBatchRecord) Descriptor deprecated

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

Deprecated: Use JobBatchRecord.ProtoReflect.Descriptor instead.

func (*JobBatchRecord) GetJobKeys

func (x *JobBatchRecord) GetJobKeys() []int64

func (*JobBatchRecord) GetJobs

func (x *JobBatchRecord) GetJobs() []*JobRecord

func (*JobBatchRecord) GetMaxJobsToActivate

func (x *JobBatchRecord) GetMaxJobsToActivate() int32

func (*JobBatchRecord) GetMetadata

func (x *JobBatchRecord) GetMetadata() *RecordMetadata

func (*JobBatchRecord) GetTimeout

func (x *JobBatchRecord) GetTimeout() int64

func (*JobBatchRecord) GetTruncated

func (x *JobBatchRecord) GetTruncated() bool

func (*JobBatchRecord) GetType

func (x *JobBatchRecord) GetType() string

func (*JobBatchRecord) GetWorker

func (x *JobBatchRecord) GetWorker() string

func (*JobBatchRecord) ProtoMessage

func (*JobBatchRecord) ProtoMessage()

func (*JobBatchRecord) ProtoReflect

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

func (*JobBatchRecord) Reset

func (x *JobBatchRecord) Reset()

func (*JobBatchRecord) String

func (x *JobBatchRecord) String() string

type JobRecord

type JobRecord struct {
	Metadata                  *RecordMetadata  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Type                      string           `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Worker                    string           `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
	Retries                   int32            `protobuf:"varint,4,opt,name=retries,proto3" json:"retries,omitempty"`
	Deadline                  int64            `protobuf:"varint,5,opt,name=deadline,proto3" json:"deadline,omitempty"`
	ErrorMessage              string           `protobuf:"bytes,6,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	CustomHeaders             *structpb.Struct `protobuf:"bytes,7,opt,name=customHeaders,proto3" json:"customHeaders,omitempty"`
	Variables                 *structpb.Struct `protobuf:"bytes,8,opt,name=variables,proto3" json:"variables,omitempty"`
	ElementId                 string           `protobuf:"bytes,9,opt,name=elementId,proto3" json:"elementId,omitempty"`
	ElementInstanceKey        int64            `protobuf:"varint,10,opt,name=elementInstanceKey,proto3" json:"elementInstanceKey,omitempty"`
	BpmnProcessId             string           `protobuf:"bytes,11,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	WorkflowDefinitionVersion int32            `protobuf:"varint,12,opt,name=workflowDefinitionVersion,proto3" json:"workflowDefinitionVersion,omitempty"`
	ProcessInstanceKey        int64            `protobuf:"varint,13,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	ProcessDefinitionKey      int64            `protobuf:"varint,14,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRecord) Descriptor deprecated

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

Deprecated: Use JobRecord.ProtoReflect.Descriptor instead.

func (*JobRecord) GetBpmnProcessId

func (x *JobRecord) GetBpmnProcessId() string

func (*JobRecord) GetCustomHeaders

func (x *JobRecord) GetCustomHeaders() *structpb.Struct

func (*JobRecord) GetDeadline

func (x *JobRecord) GetDeadline() int64

func (*JobRecord) GetElementId

func (x *JobRecord) GetElementId() string

func (*JobRecord) GetElementInstanceKey

func (x *JobRecord) GetElementInstanceKey() int64

func (*JobRecord) GetErrorMessage

func (x *JobRecord) GetErrorMessage() string

func (*JobRecord) GetMetadata

func (x *JobRecord) GetMetadata() *RecordMetadata

func (*JobRecord) GetProcessDefinitionKey

func (x *JobRecord) GetProcessDefinitionKey() int64

func (*JobRecord) GetProcessInstanceKey

func (x *JobRecord) GetProcessInstanceKey() int64

func (*JobRecord) GetRetries

func (x *JobRecord) GetRetries() int32

func (*JobRecord) GetType

func (x *JobRecord) GetType() string

func (*JobRecord) GetVariables

func (x *JobRecord) GetVariables() *structpb.Struct

func (*JobRecord) GetWorker

func (x *JobRecord) GetWorker() string

func (*JobRecord) GetWorkflowDefinitionVersion

func (x *JobRecord) GetWorkflowDefinitionVersion() int32

func (*JobRecord) ProtoMessage

func (*JobRecord) ProtoMessage()

func (*JobRecord) ProtoReflect

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

func (*JobRecord) Reset

func (x *JobRecord) Reset()

func (*JobRecord) String

func (x *JobRecord) String() string

type MessageRecord

type MessageRecord struct {
	Metadata       *RecordMetadata  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Name           string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CorrelationKey string           `protobuf:"bytes,3,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"`
	MessageId      string           `protobuf:"bytes,4,opt,name=messageId,proto3" json:"messageId,omitempty"`
	TimeToLive     int64            `protobuf:"varint,5,opt,name=timeToLive,proto3" json:"timeToLive,omitempty"`
	Variables      *structpb.Struct `protobuf:"bytes,6,opt,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageRecord) Descriptor deprecated

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

Deprecated: Use MessageRecord.ProtoReflect.Descriptor instead.

func (*MessageRecord) GetCorrelationKey

func (x *MessageRecord) GetCorrelationKey() string

func (*MessageRecord) GetMessageId

func (x *MessageRecord) GetMessageId() string

func (*MessageRecord) GetMetadata

func (x *MessageRecord) GetMetadata() *RecordMetadata

func (*MessageRecord) GetName

func (x *MessageRecord) GetName() string

func (*MessageRecord) GetTimeToLive

func (x *MessageRecord) GetTimeToLive() int64

func (*MessageRecord) GetVariables

func (x *MessageRecord) GetVariables() *structpb.Struct

func (*MessageRecord) ProtoMessage

func (*MessageRecord) ProtoMessage()

func (*MessageRecord) ProtoReflect

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

func (*MessageRecord) Reset

func (x *MessageRecord) Reset()

func (*MessageRecord) String

func (x *MessageRecord) String() string

type MessageStartEventSubscriptionRecord

type MessageStartEventSubscriptionRecord struct {
	Metadata             *RecordMetadata  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ProcessDefinitionKey int64            `protobuf:"varint,2,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	StartEventId         string           `protobuf:"bytes,3,opt,name=startEventId,proto3" json:"startEventId,omitempty"`
	MessageName          string           `protobuf:"bytes,4,opt,name=messageName,proto3" json:"messageName,omitempty"`
	BpmnProcessId        string           `protobuf:"bytes,5,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	CorrelationKey       string           `protobuf:"bytes,6,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"`
	MessageKey           int64            `protobuf:"varint,7,opt,name=messageKey,proto3" json:"messageKey,omitempty"`
	ProcessInstanceKey   int64            `protobuf:"varint,8,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	Variables            *structpb.Struct `protobuf:"bytes,9,opt,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageStartEventSubscriptionRecord) Descriptor deprecated

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

Deprecated: Use MessageStartEventSubscriptionRecord.ProtoReflect.Descriptor instead.

func (*MessageStartEventSubscriptionRecord) GetBpmnProcessId

func (x *MessageStartEventSubscriptionRecord) GetBpmnProcessId() string

func (*MessageStartEventSubscriptionRecord) GetCorrelationKey

func (x *MessageStartEventSubscriptionRecord) GetCorrelationKey() string

func (*MessageStartEventSubscriptionRecord) GetMessageKey

func (x *MessageStartEventSubscriptionRecord) GetMessageKey() int64

func (*MessageStartEventSubscriptionRecord) GetMessageName

func (x *MessageStartEventSubscriptionRecord) GetMessageName() string

func (*MessageStartEventSubscriptionRecord) GetMetadata

func (*MessageStartEventSubscriptionRecord) GetProcessDefinitionKey

func (x *MessageStartEventSubscriptionRecord) GetProcessDefinitionKey() int64

func (*MessageStartEventSubscriptionRecord) GetProcessInstanceKey

func (x *MessageStartEventSubscriptionRecord) GetProcessInstanceKey() int64

func (*MessageStartEventSubscriptionRecord) GetStartEventId

func (x *MessageStartEventSubscriptionRecord) GetStartEventId() string

func (*MessageStartEventSubscriptionRecord) GetVariables

func (*MessageStartEventSubscriptionRecord) ProtoMessage

func (*MessageStartEventSubscriptionRecord) ProtoMessage()

func (*MessageStartEventSubscriptionRecord) ProtoReflect

func (*MessageStartEventSubscriptionRecord) Reset

func (*MessageStartEventSubscriptionRecord) String

type MessageSubscriptionRecord

type MessageSubscriptionRecord struct {
	Metadata           *RecordMetadata  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ProcessInstanceKey int64            `protobuf:"varint,2,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	ElementInstanceKey int64            `protobuf:"varint,3,opt,name=elementInstanceKey,proto3" json:"elementInstanceKey,omitempty"`
	MessageName        string           `protobuf:"bytes,4,opt,name=messageName,proto3" json:"messageName,omitempty"`
	CorrelationKey     string           `protobuf:"bytes,5,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"`
	BpmnProcessId      string           `protobuf:"bytes,6,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	MessageKey         int64            `protobuf:"varint,7,opt,name=messageKey,proto3" json:"messageKey,omitempty"`
	Variables          *structpb.Struct `protobuf:"bytes,8,opt,name=variables,proto3" json:"variables,omitempty"`
	IsInterrupting     bool             `protobuf:"varint,9,opt,name=isInterrupting,proto3" json:"isInterrupting,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageSubscriptionRecord) Descriptor deprecated

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

Deprecated: Use MessageSubscriptionRecord.ProtoReflect.Descriptor instead.

func (*MessageSubscriptionRecord) GetBpmnProcessId

func (x *MessageSubscriptionRecord) GetBpmnProcessId() string

func (*MessageSubscriptionRecord) GetCorrelationKey

func (x *MessageSubscriptionRecord) GetCorrelationKey() string

func (*MessageSubscriptionRecord) GetElementInstanceKey

func (x *MessageSubscriptionRecord) GetElementInstanceKey() int64

func (*MessageSubscriptionRecord) GetIsInterrupting

func (x *MessageSubscriptionRecord) GetIsInterrupting() bool

func (*MessageSubscriptionRecord) GetMessageKey

func (x *MessageSubscriptionRecord) GetMessageKey() int64

func (*MessageSubscriptionRecord) GetMessageName

func (x *MessageSubscriptionRecord) GetMessageName() string

func (*MessageSubscriptionRecord) GetMetadata

func (x *MessageSubscriptionRecord) GetMetadata() *RecordMetadata

func (*MessageSubscriptionRecord) GetProcessInstanceKey

func (x *MessageSubscriptionRecord) GetProcessInstanceKey() int64

func (*MessageSubscriptionRecord) GetVariables

func (x *MessageSubscriptionRecord) GetVariables() *structpb.Struct

func (*MessageSubscriptionRecord) ProtoMessage

func (*MessageSubscriptionRecord) ProtoMessage()

func (*MessageSubscriptionRecord) ProtoReflect

func (*MessageSubscriptionRecord) Reset

func (x *MessageSubscriptionRecord) Reset()

func (*MessageSubscriptionRecord) String

func (x *MessageSubscriptionRecord) String() string

type ProcessEventRecord

type ProcessEventRecord struct {
	Metadata             *RecordMetadata  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ScopeKey             int64            `protobuf:"varint,2,opt,name=scopeKey,proto3" json:"scopeKey,omitempty"`
	ProcessDefinitionKey int64            `protobuf:"varint,3,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	TargetElementId      string           `protobuf:"bytes,4,opt,name=targetElementId,proto3" json:"targetElementId,omitempty"`
	Variables            *structpb.Struct `protobuf:"bytes,5,opt,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessEventRecord) Descriptor deprecated

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

Deprecated: Use ProcessEventRecord.ProtoReflect.Descriptor instead.

func (*ProcessEventRecord) GetMetadata

func (x *ProcessEventRecord) GetMetadata() *RecordMetadata

func (*ProcessEventRecord) GetProcessDefinitionKey

func (x *ProcessEventRecord) GetProcessDefinitionKey() int64

func (*ProcessEventRecord) GetScopeKey

func (x *ProcessEventRecord) GetScopeKey() int64

func (*ProcessEventRecord) GetTargetElementId

func (x *ProcessEventRecord) GetTargetElementId() string

func (*ProcessEventRecord) GetVariables

func (x *ProcessEventRecord) GetVariables() *structpb.Struct

func (*ProcessEventRecord) ProtoMessage

func (*ProcessEventRecord) ProtoMessage()

func (*ProcessEventRecord) ProtoReflect

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

func (*ProcessEventRecord) Reset

func (x *ProcessEventRecord) Reset()

func (*ProcessEventRecord) String

func (x *ProcessEventRecord) String() string

type ProcessInstanceCreationRecord

type ProcessInstanceCreationRecord struct {
	Metadata             *RecordMetadata  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	BpmnProcessId        string           `protobuf:"bytes,2,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	Version              int32            `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	ProcessDefinitionKey int64            `protobuf:"varint,4,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	ProcessInstanceKey   int64            `protobuf:"varint,5,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	Variables            *structpb.Struct `protobuf:"bytes,6,opt,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInstanceCreationRecord) Descriptor deprecated

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

Deprecated: Use ProcessInstanceCreationRecord.ProtoReflect.Descriptor instead.

func (*ProcessInstanceCreationRecord) GetBpmnProcessId

func (x *ProcessInstanceCreationRecord) GetBpmnProcessId() string

func (*ProcessInstanceCreationRecord) GetMetadata

func (*ProcessInstanceCreationRecord) GetProcessDefinitionKey

func (x *ProcessInstanceCreationRecord) GetProcessDefinitionKey() int64

func (*ProcessInstanceCreationRecord) GetProcessInstanceKey

func (x *ProcessInstanceCreationRecord) GetProcessInstanceKey() int64

func (*ProcessInstanceCreationRecord) GetVariables

func (x *ProcessInstanceCreationRecord) GetVariables() *structpb.Struct

func (*ProcessInstanceCreationRecord) GetVersion

func (x *ProcessInstanceCreationRecord) GetVersion() int32

func (*ProcessInstanceCreationRecord) ProtoMessage

func (*ProcessInstanceCreationRecord) ProtoMessage()

func (*ProcessInstanceCreationRecord) ProtoReflect

func (*ProcessInstanceCreationRecord) Reset

func (x *ProcessInstanceCreationRecord) Reset()

func (*ProcessInstanceCreationRecord) String

type ProcessInstanceRecord

type ProcessInstanceRecord struct {
	Metadata                 *RecordMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	BpmnProcessId            string          `protobuf:"bytes,2,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	Version                  int32           `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	ProcessDefinitionKey     int64           `protobuf:"varint,4,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	ProcessInstanceKey       int64           `protobuf:"varint,5,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	ElementId                string          `protobuf:"bytes,6,opt,name=elementId,proto3" json:"elementId,omitempty"`
	FlowScopeKey             int64           `protobuf:"varint,7,opt,name=flowScopeKey,proto3" json:"flowScopeKey,omitempty"`
	BpmnElementType          string          `protobuf:"bytes,8,opt,name=bpmnElementType,proto3" json:"bpmnElementType,omitempty"`
	ParentProcessInstanceKey int64           `protobuf:"varint,9,opt,name=parentProcessInstanceKey,proto3" json:"parentProcessInstanceKey,omitempty"`
	ParentElementInstanceKey int64           `protobuf:"varint,10,opt,name=parentElementInstanceKey,proto3" json:"parentElementInstanceKey,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInstanceRecord) Descriptor deprecated

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

Deprecated: Use ProcessInstanceRecord.ProtoReflect.Descriptor instead.

func (*ProcessInstanceRecord) GetBpmnElementType

func (x *ProcessInstanceRecord) GetBpmnElementType() string

func (*ProcessInstanceRecord) GetBpmnProcessId

func (x *ProcessInstanceRecord) GetBpmnProcessId() string

func (*ProcessInstanceRecord) GetElementId

func (x *ProcessInstanceRecord) GetElementId() string

func (*ProcessInstanceRecord) GetFlowScopeKey

func (x *ProcessInstanceRecord) GetFlowScopeKey() int64

func (*ProcessInstanceRecord) GetMetadata

func (x *ProcessInstanceRecord) GetMetadata() *RecordMetadata

func (*ProcessInstanceRecord) GetParentElementInstanceKey

func (x *ProcessInstanceRecord) GetParentElementInstanceKey() int64

func (*ProcessInstanceRecord) GetParentProcessInstanceKey

func (x *ProcessInstanceRecord) GetParentProcessInstanceKey() int64

func (*ProcessInstanceRecord) GetProcessDefinitionKey

func (x *ProcessInstanceRecord) GetProcessDefinitionKey() int64

func (*ProcessInstanceRecord) GetProcessInstanceKey

func (x *ProcessInstanceRecord) GetProcessInstanceKey() int64

func (*ProcessInstanceRecord) GetVersion

func (x *ProcessInstanceRecord) GetVersion() int32

func (*ProcessInstanceRecord) ProtoMessage

func (*ProcessInstanceRecord) ProtoMessage()

func (*ProcessInstanceRecord) ProtoReflect

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

func (*ProcessInstanceRecord) Reset

func (x *ProcessInstanceRecord) Reset()

func (*ProcessInstanceRecord) String

func (x *ProcessInstanceRecord) String() string

type ProcessMessageSubscriptionRecord

type ProcessMessageSubscriptionRecord struct {
	Metadata           *RecordMetadata  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ProcessInstanceKey int64            `protobuf:"varint,2,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	ElementInstanceKey int64            `protobuf:"varint,3,opt,name=elementInstanceKey,proto3" json:"elementInstanceKey,omitempty"`
	MessageName        string           `protobuf:"bytes,4,opt,name=messageName,proto3" json:"messageName,omitempty"`
	Variables          *structpb.Struct `protobuf:"bytes,5,opt,name=variables,proto3" json:"variables,omitempty"`
	BpmnProcessId      string           `protobuf:"bytes,6,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	MessageKey         int64            `protobuf:"varint,7,opt,name=messageKey,proto3" json:"messageKey,omitempty"`
	ElementId          string           `protobuf:"bytes,8,opt,name=elementId,proto3" json:"elementId,omitempty"`
	CorrelationKey     string           `protobuf:"bytes,9,opt,name=correlationKey,proto3" json:"correlationKey,omitempty"`
	IsInterrupting     bool             `protobuf:"varint,10,opt,name=isInterrupting,proto3" json:"isInterrupting,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessMessageSubscriptionRecord) Descriptor deprecated

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

Deprecated: Use ProcessMessageSubscriptionRecord.ProtoReflect.Descriptor instead.

func (*ProcessMessageSubscriptionRecord) GetBpmnProcessId

func (x *ProcessMessageSubscriptionRecord) GetBpmnProcessId() string

func (*ProcessMessageSubscriptionRecord) GetCorrelationKey

func (x *ProcessMessageSubscriptionRecord) GetCorrelationKey() string

func (*ProcessMessageSubscriptionRecord) GetElementId

func (x *ProcessMessageSubscriptionRecord) GetElementId() string

func (*ProcessMessageSubscriptionRecord) GetElementInstanceKey

func (x *ProcessMessageSubscriptionRecord) GetElementInstanceKey() int64

func (*ProcessMessageSubscriptionRecord) GetIsInterrupting

func (x *ProcessMessageSubscriptionRecord) GetIsInterrupting() bool

func (*ProcessMessageSubscriptionRecord) GetMessageKey

func (x *ProcessMessageSubscriptionRecord) GetMessageKey() int64

func (*ProcessMessageSubscriptionRecord) GetMessageName

func (x *ProcessMessageSubscriptionRecord) GetMessageName() string

func (*ProcessMessageSubscriptionRecord) GetMetadata

func (*ProcessMessageSubscriptionRecord) GetProcessInstanceKey

func (x *ProcessMessageSubscriptionRecord) GetProcessInstanceKey() int64

func (*ProcessMessageSubscriptionRecord) GetVariables

func (*ProcessMessageSubscriptionRecord) ProtoMessage

func (*ProcessMessageSubscriptionRecord) ProtoMessage()

func (*ProcessMessageSubscriptionRecord) ProtoReflect

func (*ProcessMessageSubscriptionRecord) Reset

func (*ProcessMessageSubscriptionRecord) String

type ProcessRecord

type ProcessRecord struct {
	Metadata             *RecordMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	BpmnProcessId        string          `protobuf:"bytes,2,opt,name=bpmnProcessId,proto3" json:"bpmnProcessId,omitempty"`
	Version              int32           `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	ProcessDefinitionKey int64           `protobuf:"varint,4,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	ResourceName         string          `protobuf:"bytes,5,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	Checksum             []byte          `protobuf:"bytes,6,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Resource             []byte          `protobuf:"bytes,7,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessRecord) Descriptor deprecated

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

Deprecated: Use ProcessRecord.ProtoReflect.Descriptor instead.

func (*ProcessRecord) GetBpmnProcessId

func (x *ProcessRecord) GetBpmnProcessId() string

func (*ProcessRecord) GetChecksum

func (x *ProcessRecord) GetChecksum() []byte

func (*ProcessRecord) GetMetadata

func (x *ProcessRecord) GetMetadata() *RecordMetadata

func (*ProcessRecord) GetProcessDefinitionKey

func (x *ProcessRecord) GetProcessDefinitionKey() int64

func (*ProcessRecord) GetResource

func (x *ProcessRecord) GetResource() []byte

func (*ProcessRecord) GetResourceName

func (x *ProcessRecord) GetResourceName() string

func (*ProcessRecord) GetVersion

func (x *ProcessRecord) GetVersion() int32

func (*ProcessRecord) ProtoMessage

func (*ProcessRecord) ProtoMessage()

func (*ProcessRecord) ProtoReflect

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

func (*ProcessRecord) Reset

func (x *ProcessRecord) Reset()

func (*ProcessRecord) String

func (x *ProcessRecord) String() string

type Record

type Record struct {
	Record *anypb.Any `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

Convenience message for packing any kind of record

func (*Record) Descriptor deprecated

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetRecord

func (x *Record) GetRecord() *anypb.Any

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) ProtoReflect

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

func (*Record) Reset

func (x *Record) Reset()

func (*Record) String

func (x *Record) String() string

type RecordId

type RecordId struct {
	PartitionId int32 `protobuf:"varint,1,opt,name=partitionId,proto3" json:"partitionId,omitempty"`
	Position    int64 `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

Convenience message for systems which use a key/id system for each record

func (*RecordId) Descriptor deprecated

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

Deprecated: Use RecordId.ProtoReflect.Descriptor instead.

func (*RecordId) GetPartitionId

func (x *RecordId) GetPartitionId() int32

func (*RecordId) GetPosition

func (x *RecordId) GetPosition() int64

func (*RecordId) ProtoMessage

func (*RecordId) ProtoMessage()

func (*RecordId) ProtoReflect

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

func (*RecordId) Reset

func (x *RecordId) Reset()

func (*RecordId) String

func (x *RecordId) String() string

type RecordMetadata

type RecordMetadata struct {
	PartitionId          int32                     `protobuf:"varint,1,opt,name=partitionId,proto3" json:"partitionId,omitempty"`
	Position             int64                     `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	Key                  int64                     `protobuf:"varint,3,opt,name=key,proto3" json:"key,omitempty"`
	Timestamp            int64                     `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	RecordType           RecordMetadata_RecordType `protobuf:"varint,5,opt,name=recordType,proto3,enum=exporter_protocol.RecordMetadata_RecordType" json:"recordType,omitempty"`
	Intent               string                    `protobuf:"bytes,6,opt,name=intent,proto3" json:"intent,omitempty"`
	ValueType            RecordMetadata_ValueType  `protobuf:"varint,7,opt,name=valueType,proto3,enum=exporter_protocol.RecordMetadata_ValueType" json:"valueType,omitempty"`
	SourceRecordPosition int64                     `protobuf:"varint,8,opt,name=sourceRecordPosition,proto3" json:"sourceRecordPosition,omitempty"`
	RejectionType        string                    `protobuf:"bytes,9,opt,name=rejectionType,proto3" json:"rejectionType,omitempty"`
	RejectionReason      string                    `protobuf:"bytes,10,opt,name=rejectionReason,proto3" json:"rejectionReason,omitempty"`
	// contains filtered or unexported fields
}

Packs all non-value info into a single field; the idea here is so we can embed the *Record messages into other messages (e.g. JobRecord and JobBatchRecord) by simply omitting the optional metadata field, but by setting it the message becomes a full fledged record. Also cuts down how much properties need to be duplicated if we want to have flat records.

func (*RecordMetadata) Descriptor deprecated

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

Deprecated: Use RecordMetadata.ProtoReflect.Descriptor instead.

func (*RecordMetadata) GetIntent

func (x *RecordMetadata) GetIntent() string

func (*RecordMetadata) GetKey

func (x *RecordMetadata) GetKey() int64

func (*RecordMetadata) GetPartitionId

func (x *RecordMetadata) GetPartitionId() int32

func (*RecordMetadata) GetPosition

func (x *RecordMetadata) GetPosition() int64

func (*RecordMetadata) GetRecordType

func (x *RecordMetadata) GetRecordType() RecordMetadata_RecordType

func (*RecordMetadata) GetRejectionReason

func (x *RecordMetadata) GetRejectionReason() string

func (*RecordMetadata) GetRejectionType

func (x *RecordMetadata) GetRejectionType() string

func (*RecordMetadata) GetSourceRecordPosition

func (x *RecordMetadata) GetSourceRecordPosition() int64

func (*RecordMetadata) GetTimestamp

func (x *RecordMetadata) GetTimestamp() int64

func (*RecordMetadata) GetValueType

func (x *RecordMetadata) GetValueType() RecordMetadata_ValueType

func (*RecordMetadata) ProtoMessage

func (*RecordMetadata) ProtoMessage()

func (*RecordMetadata) ProtoReflect

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

func (*RecordMetadata) Reset

func (x *RecordMetadata) Reset()

func (*RecordMetadata) String

func (x *RecordMetadata) String() string

type RecordMetadata_RecordType

type RecordMetadata_RecordType int32
const (
	RecordMetadata_UNKNOWN_RECORD_TYPE RecordMetadata_RecordType = 0
	RecordMetadata_EVENT               RecordMetadata_RecordType = 1
	RecordMetadata_COMMAND             RecordMetadata_RecordType = 2
	RecordMetadata_COMMAND_REJECTION   RecordMetadata_RecordType = 3
)

func (RecordMetadata_RecordType) Descriptor

func (RecordMetadata_RecordType) Enum

func (RecordMetadata_RecordType) EnumDescriptor deprecated

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

Deprecated: Use RecordMetadata_RecordType.Descriptor instead.

func (RecordMetadata_RecordType) Number

func (RecordMetadata_RecordType) String

func (x RecordMetadata_RecordType) String() string

func (RecordMetadata_RecordType) Type

type RecordMetadata_ValueType

type RecordMetadata_ValueType int32
const (
	RecordMetadata_UNKNOWN_VALUE_TYPE               RecordMetadata_ValueType = 0
	RecordMetadata_JOB                              RecordMetadata_ValueType = 1
	RecordMetadata_DEPLOYMENT                       RecordMetadata_ValueType = 2
	RecordMetadata_PROCESS_INSTANCE                 RecordMetadata_ValueType = 3
	RecordMetadata_INCIDENT                         RecordMetadata_ValueType = 4
	RecordMetadata_MESSAGE                          RecordMetadata_ValueType = 5
	RecordMetadata_MESSAGE_SUBSCRIPTION             RecordMetadata_ValueType = 6
	RecordMetadata_PROCESS_MESSAGE_SUBSCRIPTION     RecordMetadata_ValueType = 7
	RecordMetadata_JOB_BATCH                        RecordMetadata_ValueType = 8
	RecordMetadata_TIMER                            RecordMetadata_ValueType = 9
	RecordMetadata_MESSAGE_START_EVENT_SUBSCRIPTION RecordMetadata_ValueType = 10
	RecordMetadata_VARIABLE                         RecordMetadata_ValueType = 11
	RecordMetadata_VARIABLE_DOCUMENT                RecordMetadata_ValueType = 12
	RecordMetadata_PROCESS_INSTANCE_CREATION        RecordMetadata_ValueType = 13
	RecordMetadata_ERROR                            RecordMetadata_ValueType = 14
	RecordMetadata_PROCESS                          RecordMetadata_ValueType = 15
	RecordMetadata_DEPLOYMENT_DISTRIBUTION          RecordMetadata_ValueType = 16
	RecordMetadata_PROCESS_EVENT                    RecordMetadata_ValueType = 17
	RecordMetadata_DECISION                         RecordMetadata_ValueType = 18
	RecordMetadata_DECISION_REQUIREMENTS            RecordMetadata_ValueType = 19
	RecordMetadata_DECISION_EVALUATION              RecordMetadata_ValueType = 20
)

func (RecordMetadata_ValueType) Descriptor

func (RecordMetadata_ValueType) Enum

func (RecordMetadata_ValueType) EnumDescriptor deprecated

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

Deprecated: Use RecordMetadata_ValueType.Descriptor instead.

func (RecordMetadata_ValueType) Number

func (RecordMetadata_ValueType) String

func (x RecordMetadata_ValueType) String() string

func (RecordMetadata_ValueType) Type

type TimerRecord

type TimerRecord struct {
	Metadata             *RecordMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ElementInstanceKey   int64           `protobuf:"varint,2,opt,name=elementInstanceKey,proto3" json:"elementInstanceKey,omitempty"`
	DueDate              int64           `protobuf:"varint,3,opt,name=dueDate,proto3" json:"dueDate,omitempty"`
	Repetitions          int32           `protobuf:"varint,4,opt,name=repetitions,proto3" json:"repetitions,omitempty"`
	TargetElementId      string          `protobuf:"bytes,5,opt,name=targetElementId,proto3" json:"targetElementId,omitempty"`
	ProcessInstanceKey   int64           `protobuf:"varint,6,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	ProcessDefinitionKey int64           `protobuf:"varint,7,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	// contains filtered or unexported fields
}

func (*TimerRecord) Descriptor deprecated

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

Deprecated: Use TimerRecord.ProtoReflect.Descriptor instead.

func (*TimerRecord) GetDueDate

func (x *TimerRecord) GetDueDate() int64

func (*TimerRecord) GetElementInstanceKey

func (x *TimerRecord) GetElementInstanceKey() int64

func (*TimerRecord) GetMetadata

func (x *TimerRecord) GetMetadata() *RecordMetadata

func (*TimerRecord) GetProcessDefinitionKey

func (x *TimerRecord) GetProcessDefinitionKey() int64

func (*TimerRecord) GetProcessInstanceKey

func (x *TimerRecord) GetProcessInstanceKey() int64

func (*TimerRecord) GetRepetitions

func (x *TimerRecord) GetRepetitions() int32

func (*TimerRecord) GetTargetElementId

func (x *TimerRecord) GetTargetElementId() string

func (*TimerRecord) ProtoMessage

func (*TimerRecord) ProtoMessage()

func (*TimerRecord) ProtoReflect

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

func (*TimerRecord) Reset

func (x *TimerRecord) Reset()

func (*TimerRecord) String

func (x *TimerRecord) String() string

type VariableDocumentRecord

type VariableDocumentRecord struct {
	Metadata        *RecordMetadata                        `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ScopeKey        int64                                  `protobuf:"varint,2,opt,name=scopeKey,proto3" json:"scopeKey,omitempty"`
	UpdateSemantics VariableDocumentRecord_UpdateSemantics `` /* 146-byte string literal not displayed */
	Variables       *structpb.Struct                       `protobuf:"bytes,4,opt,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

func (*VariableDocumentRecord) Descriptor deprecated

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

Deprecated: Use VariableDocumentRecord.ProtoReflect.Descriptor instead.

func (*VariableDocumentRecord) GetMetadata

func (x *VariableDocumentRecord) GetMetadata() *RecordMetadata

func (*VariableDocumentRecord) GetScopeKey

func (x *VariableDocumentRecord) GetScopeKey() int64

func (*VariableDocumentRecord) GetUpdateSemantics

func (*VariableDocumentRecord) GetVariables

func (x *VariableDocumentRecord) GetVariables() *structpb.Struct

func (*VariableDocumentRecord) ProtoMessage

func (*VariableDocumentRecord) ProtoMessage()

func (*VariableDocumentRecord) ProtoReflect

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

func (*VariableDocumentRecord) Reset

func (x *VariableDocumentRecord) Reset()

func (*VariableDocumentRecord) String

func (x *VariableDocumentRecord) String() string

type VariableDocumentRecord_UpdateSemantics

type VariableDocumentRecord_UpdateSemantics int32
const (
	VariableDocumentRecord_UNKNOWN_UPDATE_SEMANTICS VariableDocumentRecord_UpdateSemantics = 0
	VariableDocumentRecord_LOCAL                    VariableDocumentRecord_UpdateSemantics = 1
	VariableDocumentRecord_PROPAGATE                VariableDocumentRecord_UpdateSemantics = 2
)

func (VariableDocumentRecord_UpdateSemantics) Descriptor

func (VariableDocumentRecord_UpdateSemantics) Enum

func (VariableDocumentRecord_UpdateSemantics) EnumDescriptor deprecated

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

Deprecated: Use VariableDocumentRecord_UpdateSemantics.Descriptor instead.

func (VariableDocumentRecord_UpdateSemantics) Number

func (VariableDocumentRecord_UpdateSemantics) String

func (VariableDocumentRecord_UpdateSemantics) Type

type VariableRecord

type VariableRecord struct {
	Metadata             *RecordMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Name                 string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value                string          `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	ScopeKey             int64           `protobuf:"varint,4,opt,name=scopeKey,proto3" json:"scopeKey,omitempty"`
	ProcessInstanceKey   int64           `protobuf:"varint,5,opt,name=processInstanceKey,proto3" json:"processInstanceKey,omitempty"`
	ProcessDefinitionKey int64           `protobuf:"varint,6,opt,name=processDefinitionKey,proto3" json:"processDefinitionKey,omitempty"`
	// contains filtered or unexported fields
}

func (*VariableRecord) Descriptor deprecated

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

Deprecated: Use VariableRecord.ProtoReflect.Descriptor instead.

func (*VariableRecord) GetMetadata

func (x *VariableRecord) GetMetadata() *RecordMetadata

func (*VariableRecord) GetName

func (x *VariableRecord) GetName() string

func (*VariableRecord) GetProcessDefinitionKey

func (x *VariableRecord) GetProcessDefinitionKey() int64

func (*VariableRecord) GetProcessInstanceKey

func (x *VariableRecord) GetProcessInstanceKey() int64

func (*VariableRecord) GetScopeKey

func (x *VariableRecord) GetScopeKey() int64

func (*VariableRecord) GetValue

func (x *VariableRecord) GetValue() string

func (*VariableRecord) ProtoMessage

func (*VariableRecord) ProtoMessage()

func (*VariableRecord) ProtoReflect

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

func (*VariableRecord) Reset

func (x *VariableRecord) Reset()

func (*VariableRecord) String

func (x *VariableRecord) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL