zeebe

package
v0.3.0-beta2 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2022 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 (x *DecisionEvaluationRecord) GetEvaluatedDecisions() []*DecisionEvaluationRecord_EvaluatedDecision

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 

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

Deprecated: Use DecisionEvaluationRecord_EvaluatedDecision.ProtoReflect.Descriptor instead.

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionId 

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetDecisionId() string

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionKey 

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetDecisionKey() int64

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionName 

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetDecisionName() string

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionOutput 

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetDecisionOutput() string

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionType 

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetDecisionType() string

func (*DecisionEvaluationRecord_EvaluatedDecision) GetDecisionVersion 

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetDecisionVersion() int64

func (*DecisionEvaluationRecord_EvaluatedDecision) GetEvaluatedInputs 

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetEvaluatedInputs() []*DecisionEvaluationRecord_EvaluatedInput

func (*DecisionEvaluationRecord_EvaluatedDecision) GetMatchedRules 

func (x *DecisionEvaluationRecord_EvaluatedDecision) GetMatchedRules() []*DecisionEvaluationRecord_MatchedRule

func (*DecisionEvaluationRecord_EvaluatedDecision) ProtoMessage 

func (*DecisionEvaluationRecord_EvaluatedDecision) ProtoMessage()

func (*DecisionEvaluationRecord_EvaluatedDecision) ProtoReflect 

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

func (*DecisionEvaluationRecord_EvaluatedDecision) Reset 

func (x *DecisionEvaluationRecord_EvaluatedDecision) Reset()

func (*DecisionEvaluationRecord_EvaluatedDecision) String 

func (x *DecisionEvaluationRecord_EvaluatedDecision) String() 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 (x *DecisionEvaluationRecord_EvaluatedInput) GetInputId() string

func (*DecisionEvaluationRecord_EvaluatedInput) GetInputName 

func (x *DecisionEvaluationRecord_EvaluatedInput) GetInputName() string

func (*DecisionEvaluationRecord_EvaluatedInput) GetInputValue 

func (x *DecisionEvaluationRecord_EvaluatedInput) GetInputValue() string

func (*DecisionEvaluationRecord_EvaluatedInput) ProtoMessage 

func (*DecisionEvaluationRecord_EvaluatedInput) ProtoMessage()

func (*DecisionEvaluationRecord_EvaluatedInput) ProtoReflect 

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

func (*DecisionEvaluationRecord_EvaluatedInput) Reset 

func (x *DecisionEvaluationRecord_EvaluatedInput) Reset()

func (*DecisionEvaluationRecord_EvaluatedInput) String 

func (x *DecisionEvaluationRecord_EvaluatedInput) String() 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 (x *DecisionEvaluationRecord_EvaluatedOutput) GetOutputId() string

func (*DecisionEvaluationRecord_EvaluatedOutput) GetOutputName 

func (x *DecisionEvaluationRecord_EvaluatedOutput) GetOutputName() string

func (*DecisionEvaluationRecord_EvaluatedOutput) GetOutputValue 

func (x *DecisionEvaluationRecord_EvaluatedOutput) GetOutputValue() string

func (*DecisionEvaluationRecord_EvaluatedOutput) ProtoMessage 

func (*DecisionEvaluationRecord_EvaluatedOutput) ProtoMessage()

func (*DecisionEvaluationRecord_EvaluatedOutput) ProtoReflect 

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

func (*DecisionEvaluationRecord_EvaluatedOutput) Reset 

func (x *DecisionEvaluationRecord_EvaluatedOutput) Reset()

func (*DecisionEvaluationRecord_EvaluatedOutput) String 

func (x *DecisionEvaluationRecord_EvaluatedOutput) String() 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 (x *DecisionEvaluationRecord_MatchedRule) GetEvaluatedOutputs() []*DecisionEvaluationRecord_EvaluatedOutput

func (*DecisionEvaluationRecord_MatchedRule) GetRuleId 

func (x *DecisionEvaluationRecord_MatchedRule) GetRuleId() string

func (*DecisionEvaluationRecord_MatchedRule) GetRuleIndex 

func (x *DecisionEvaluationRecord_MatchedRule) GetRuleIndex() int32

func (*DecisionEvaluationRecord_MatchedRule) ProtoMessage 

func (*DecisionEvaluationRecord_MatchedRule) ProtoMessage()

func (*DecisionEvaluationRecord_MatchedRule) ProtoReflect 

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

func (*DecisionEvaluationRecord_MatchedRule) Reset 

func (x *DecisionEvaluationRecord_MatchedRule) Reset()

func (*DecisionEvaluationRecord_MatchedRule) String 

func (x *DecisionEvaluationRecord_MatchedRule) String() 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 (x *DecisionRequirementsMetadata) ProtoReflect() protoreflect.Message

func (*DecisionRequirementsMetadata) Reset 

func (x *DecisionRequirementsMetadata) Reset()

func (*DecisionRequirementsMetadata) String 

func (x *DecisionRequirementsMetadata) String() 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 (x *DecisionRequirementsRecord) ProtoReflect() protoreflect.Message

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 (x *DeploymentDistributionRecord) ProtoReflect() protoreflect.Message

func (*DeploymentDistributionRecord) Reset 

func (x *DeploymentDistributionRecord) Reset()

func (*DeploymentDistributionRecord) String 

func (x *DeploymentDistributionRecord) String() 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 (x *DeploymentRecord_DecisionMetadata) ProtoReflect() protoreflect.Message

func (*DeploymentRecord_DecisionMetadata) Reset 

func (x *DeploymentRecord_DecisionMetadata) Reset()

func (*DeploymentRecord_DecisionMetadata) String 

func (x *DeploymentRecord_DecisionMetadata) String() 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 (x *DeploymentRecord_ProcessMetadata) ProtoReflect() protoreflect.Message

func (*DeploymentRecord_ProcessMetadata) Reset 

func (x *DeploymentRecord_ProcessMetadata) Reset()

func (*DeploymentRecord_ProcessMetadata) String 

func (x *DeploymentRecord_ProcessMetadata) String() 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 (x *DeploymentRecord_Resource) ProtoReflect() protoreflect.Message

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 (x *MessageStartEventSubscriptionRecord) GetMetadata() *RecordMetadata

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 (x *MessageStartEventSubscriptionRecord) GetVariables() *structpb.Struct

func (*MessageStartEventSubscriptionRecord) ProtoMessage 

func (*MessageStartEventSubscriptionRecord) ProtoMessage()

func (*MessageStartEventSubscriptionRecord) ProtoReflect 

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

func (*MessageStartEventSubscriptionRecord) Reset 

func (x *MessageStartEventSubscriptionRecord) Reset()

func (*MessageStartEventSubscriptionRecord) String 

func (x *MessageStartEventSubscriptionRecord) String() 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 (x *MessageSubscriptionRecord) ProtoReflect() protoreflect.Message

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 (x *ProcessInstanceCreationRecord) GetMetadata() *RecordMetadata

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 (x *ProcessInstanceCreationRecord) ProtoReflect() protoreflect.Message

func (*ProcessInstanceCreationRecord) Reset 

func (x *ProcessInstanceCreationRecord) Reset()

func (*ProcessInstanceCreationRecord) String 

func (x *ProcessInstanceCreationRecord) String() 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 (x *ProcessMessageSubscriptionRecord) GetMetadata() *RecordMetadata

func (*ProcessMessageSubscriptionRecord) GetProcessInstanceKey 

func (x *ProcessMessageSubscriptionRecord) GetProcessInstanceKey() int64

func (*ProcessMessageSubscriptionRecord) GetVariables 

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

func (*ProcessMessageSubscriptionRecord) ProtoMessage 

func (*ProcessMessageSubscriptionRecord) ProtoMessage()

func (*ProcessMessageSubscriptionRecord) ProtoReflect 

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

func (*ProcessMessageSubscriptionRecord) Reset 

func (x *ProcessMessageSubscriptionRecord) Reset()

func (*ProcessMessageSubscriptionRecord) String 

func (x *ProcessMessageSubscriptionRecord) String() 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) Descriptor() protoreflect.EnumDescriptor

func (RecordMetadata_RecordType) Enum 

func (x RecordMetadata_RecordType) Enum() *RecordMetadata_RecordType

func (RecordMetadata_RecordType) EnumDescriptor deprecated 

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

Deprecated: Use RecordMetadata_RecordType.Descriptor instead.

func (RecordMetadata_RecordType) Number 

func (x RecordMetadata_RecordType) Number() protoreflect.EnumNumber

func (RecordMetadata_RecordType) String 

func (x RecordMetadata_RecordType) String() string

func (RecordMetadata_RecordType) Type 

func (RecordMetadata_RecordType) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (RecordMetadata_ValueType) Enum 

func (x RecordMetadata_ValueType) Enum() *RecordMetadata_ValueType

func (RecordMetadata_ValueType) EnumDescriptor deprecated 

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

Deprecated: Use RecordMetadata_ValueType.Descriptor instead.

func (RecordMetadata_ValueType) Number 

func (x RecordMetadata_ValueType) Number() protoreflect.EnumNumber

func (RecordMetadata_ValueType) String 

func (x RecordMetadata_ValueType) String() string

func (RecordMetadata_ValueType) Type 

func (RecordMetadata_ValueType) Type() protoreflect.EnumType

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 (x *VariableDocumentRecord) GetUpdateSemantics() VariableDocumentRecord_UpdateSemantics

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) Descriptor() protoreflect.EnumDescriptor

func (VariableDocumentRecord_UpdateSemantics) Enum 

func (x VariableDocumentRecord_UpdateSemantics) Enum() *VariableDocumentRecord_UpdateSemantics

func (VariableDocumentRecord_UpdateSemantics) EnumDescriptor deprecated 

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

Deprecated: Use VariableDocumentRecord_UpdateSemantics.Descriptor instead.

func (VariableDocumentRecord_UpdateSemantics) Number 

func (x VariableDocumentRecord_UpdateSemantics) Number() protoreflect.EnumNumber

func (VariableDocumentRecord_UpdateSemantics) String 

func (x VariableDocumentRecord_UpdateSemantics) String() string

func (VariableDocumentRecord_UpdateSemantics) Type 

func (VariableDocumentRecord_UpdateSemantics) Type() protoreflect.EnumType

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

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.