Skip to content

Commit

Permalink
Merge branch 'master' into gocql_config
Browse files Browse the repository at this point in the history
  • Loading branch information
@mantas-sidlauskas
mantas-sidlauskas authored Mar 25, 2024
2 parents 05daa0b + 27234b9 commit fcd8e7d
Show file tree
Hide file tree
Showing 13 changed files with 1,023 additions and 713 deletions.
276 changes: 266 additions & 10 deletions .gen/go/shared/shared.go
View file

Large diffs are not rendered by default.

466 changes: 234 additions & 232 deletions .gen/proto/history/v1/service.pb.yarpc.go
View file

Large diffs are not rendered by default.

466 changes: 234 additions & 232 deletions .gen/proto/matching/v1/service.pb.yarpc.go
View file

Large diffs are not rendered by default.

466 changes: 234 additions & 232 deletions .gen/proto/shared/v1/history.pb.yarpc.go
View file

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion cmd/server/go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ require (
github.com/startreedata/pinot-client-go v0.2.0 // latest release supports pinot v0.12.0 which is also internal version
github.com/stretchr/testify v1.8.3
github.com/uber-go/tally v3.3.15+incompatible // indirect
github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210
github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562
github.com/uber/ringpop-go v0.8.5 // indirect
github.com/uber/tchannel-go v1.22.2 // indirect
github.com/urfave/cli v1.22.4
Expand Down
4 changes: 2 additions & 2 deletions cmd/server/go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -397,8 +397,8 @@ github.com/uber-go/tally v3.3.12+incompatible/go.mod h1:YDTIBxdXyOU/sCWilKB4bgyu
github.com/uber-go/tally v3.3.15+incompatible h1:9hLSgNBP28CjIaDmAuRTq9qV+UZY+9PcvAkXO4nNMwg=
github.com/uber-go/tally v3.3.15+incompatible/go.mod h1:YDTIBxdXyOU/sCWilKB4bgyufu1cEi0jdVnRdxvjnmU=
github.com/uber/cadence-idl v0.0.0-20211111101836-d6b70b60eb8c/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210 h1:iuPF2QAZM90Jpx0s+2LnxLN+ElGsxB2JnXKGNLc18+w=
github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562 h1:/G/9GZPDEfZOgKIwjIIuEtFqLh4i4RDySpVvcx6jERY=
github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
github.com/uber/jaeger-client-go v2.22.1+incompatible h1:NHcubEkVbahf9t3p75TOCR83gdUHXjRJvjoBh1yACsM=
github.com/uber/jaeger-client-go v2.22.1+incompatible/go.mod h1:WVhlPFC8FDjOFMMWRy2pZqQJSXxYSwNYOkTr/Z6d3Kk=
github.com/uber/jaeger-lib v2.2.0+incompatible h1:MxZXOiR2JuoANZ3J6DE/U0kSFv/eJ/GfSYVCjK7dyaw=
Expand Down
8 changes: 8 additions & 0 deletions common/types/mapper/proto/api.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -911,6 +911,7 @@ func FromDecisionTaskFailedEventAttributes(t *types.DecisionTaskFailedEventAttri
NewRunId: t.NewRunID,
ForkEventVersion: t.ForkEventVersion,
BinaryChecksum: t.BinaryChecksum,
RequestId: t.RequestID,
}
}

Expand All @@ -929,6 +930,7 @@ func ToDecisionTaskFailedEventAttributes(t *apiv1.DecisionTaskFailedEventAttribu
NewRunID: t.NewRunId,
ForkEventVersion: t.ForkEventVersion,
BinaryChecksum: t.BinaryChecksum,
RequestID: t.RequestId,
}
}

Expand Down Expand Up @@ -4472,6 +4474,7 @@ func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecut
Cause: t.Cause,
ExternalExecutionInfo: FromExternalExecutionInfoFields(t.ExternalWorkflowExecution, t.ExternalInitiatedEventID),
Identity: t.Identity,
RequestId: t.RequestID,
}
}

Expand All @@ -4484,6 +4487,7 @@ func ToWorkflowExecutionCancelRequestedEventAttributes(t *apiv1.WorkflowExecutio
ExternalInitiatedEventID: ToExternalInitiatedID(t.ExternalExecutionInfo),
ExternalWorkflowExecution: ToExternalWorkflowExecution(t.ExternalExecutionInfo),
Identity: t.Identity,
RequestID: t.RequestId,
}
}

Expand Down Expand Up @@ -4801,6 +4805,7 @@ func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSign
SignalName: t.SignalName,
Input: FromPayload(t.Input),
Identity: t.Identity,
RequestId: t.RequestID,
}
}

Expand All @@ -4812,6 +4817,7 @@ func ToWorkflowExecutionSignaledEventAttributes(t *apiv1.WorkflowExecutionSignal
SignalName: t.SignalName,
Input: ToPayload(t.Input),
Identity: t.Identity,
RequestID: t.RequestId,
}
}

Expand Down Expand Up @@ -4845,6 +4851,7 @@ func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStart
PrevAutoResetPoints: FromResetPoints(t.PrevAutoResetPoints),
Header: FromHeader(t.Header),
PartitionConfig: t.PartitionConfig,
RequestId: t.RequestID,
}
}

Expand Down Expand Up @@ -4881,6 +4888,7 @@ func ToWorkflowExecutionStartedEventAttributes(t *apiv1.WorkflowExecutionStarted
PrevAutoResetPoints: ToResetPoints(t.PrevAutoResetPoints),
Header: ToHeader(t.Header),
PartitionConfig: t.PartitionConfig,
RequestID: t.RequestId,
}
}

Expand Down
8 changes: 8 additions & 0 deletions common/types/mapper/thrift/shared.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1268,6 +1268,7 @@ func FromDecisionTaskFailedEventAttributes(t *types.DecisionTaskFailedEventAttri
NewRunId: &t.NewRunID,
ForkEventVersion: &t.ForkEventVersion,
BinaryChecksum: &t.BinaryChecksum,
RequestId: &t.RequestID,
}
}

Expand All @@ -1287,6 +1288,7 @@ func ToDecisionTaskFailedEventAttributes(t *shared.DecisionTaskFailedEventAttrib
NewRunID: t.GetNewRunId(),
ForkEventVersion: t.GetForkEventVersion(),
BinaryChecksum: t.GetBinaryChecksum(),
RequestID: t.GetRequestId(),
}
}

Expand Down Expand Up @@ -6100,6 +6102,7 @@ func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecut
ExternalInitiatedEventId: t.ExternalInitiatedEventID,
ExternalWorkflowExecution: FromWorkflowExecution(t.ExternalWorkflowExecution),
Identity: &t.Identity,
RequestId: &t.RequestID,
}
}

Expand All @@ -6113,6 +6116,7 @@ func ToWorkflowExecutionCancelRequestedEventAttributes(t *shared.WorkflowExecuti
ExternalInitiatedEventID: t.ExternalInitiatedEventId,
ExternalWorkflowExecution: ToWorkflowExecution(t.ExternalWorkflowExecution),
Identity: t.GetIdentity(),
RequestID: t.GetRequestId(),
}
}

Expand Down Expand Up @@ -6397,6 +6401,7 @@ func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSign
SignalName: &t.SignalName,
Input: t.Input,
Identity: &t.Identity,
RequestId: &t.RequestID,
}
}

Expand All @@ -6409,6 +6414,7 @@ func ToWorkflowExecutionSignaledEventAttributes(t *shared.WorkflowExecutionSigna
SignalName: t.GetSignalName(),
Input: t.Input,
Identity: t.GetIdentity(),
RequestID: t.GetRequestId(),
}
}

Expand Down Expand Up @@ -6446,6 +6452,7 @@ func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStart
PrevAutoResetPoints: FromResetPoints(t.PrevAutoResetPoints),
Header: FromHeader(t.Header),
PartitionConfig: t.PartitionConfig,
RequestId: &t.RequestID,
}
}

Expand Down Expand Up @@ -6483,6 +6490,7 @@ func ToWorkflowExecutionStartedEventAttributes(t *shared.WorkflowExecutionStarte
PrevAutoResetPoints: ToResetPoints(t.PrevAutoResetPoints),
Header: ToHeader(t.Header),
PartitionConfig: t.PartitionConfig,
RequestID: t.GetRequestId(),
}
}

Expand Down
28 changes: 28 additions & 0 deletions common/types/shared.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1146,6 +1146,7 @@ type DecisionTaskFailedEventAttributes struct {
NewRunID string `json:"newRunId,omitempty"`
ForkEventVersion int64 `json:"forkEventVersion,omitempty"`
BinaryChecksum string `json:"binaryChecksum,omitempty"`
RequestID string `json:"requestId,omitempty"`
}

// GetCause is an internal getter (TBD...)
Expand Down Expand Up @@ -1188,6 +1189,14 @@ func (v *DecisionTaskFailedEventAttributes) GetForkEventVersion() (o int64) {
return
}

// GetRequestID is an internal getter (TBD...)
func (v *DecisionTaskFailedEventAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}

// DecisionTaskScheduledEventAttributes is an internal type (TBD...)
type DecisionTaskScheduledEventAttributes struct {
TaskList *TaskList `json:"taskList,omitempty"`
Expand Down Expand Up @@ -7041,6 +7050,7 @@ type WorkflowExecutionCancelRequestedEventAttributes struct {
ExternalInitiatedEventID *int64 `json:"externalInitiatedEventId,omitempty"`
ExternalWorkflowExecution *WorkflowExecution `json:"externalWorkflowExecution,omitempty"`
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
}

// WorkflowExecutionCanceledEventAttributes is an internal type (TBD...)
Expand Down Expand Up @@ -7321,6 +7331,7 @@ type WorkflowExecutionSignaledEventAttributes struct {
SignalName string `json:"signalName,omitempty"`
Input []byte `json:"input,omitempty"`
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
}

// GetSignalName is an internal getter (TBD...)
Expand All @@ -7347,6 +7358,14 @@ func (v *WorkflowExecutionSignaledEventAttributes) GetIdentity() (o string) {
return
}

// GetRequestID is an internal getter (TBD...)
func (v *WorkflowExecutionSignaledEventAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}

// WorkflowExecutionStartedEventAttributes is an internal type (TBD...)
type WorkflowExecutionStartedEventAttributes struct {
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
Expand Down Expand Up @@ -7378,6 +7397,7 @@ type WorkflowExecutionStartedEventAttributes struct {
Header *Header `json:"header,omitempty"`
JitterStartSeconds *int32 `json:"jitterStartSeconds,omitempty"`
PartitionConfig map[string]string
RequestID string `json:"requestId,omitempty"`
}

// GetParentWorkflowDomain is an internal getter (TBD...)
Expand Down Expand Up @@ -7515,6 +7535,14 @@ func (v *WorkflowExecutionStartedEventAttributes) GetPartitionConfig() (o map[st
return
}

// GetRequestID is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}

// WorkflowExecutionTerminatedEventAttributes is an internal type (TBD...)
type WorkflowExecutionTerminatedEventAttributes struct {
Reason string `json:"reason,omitempty"`
Expand Down
4 changes: 4 additions & 0 deletions common/types/testdata/history.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -274,6 +274,7 @@ var (
PrevAutoResetPoints: &ResetPoints,
Header: &Header,
PartitionConfig: PartitionConfig,
RequestID: RequestID,
}
WorkflowExecutionCompletedEventAttributes = types.WorkflowExecutionCompletedEventAttributes{
Result: Payload1,
Expand Down Expand Up @@ -325,6 +326,7 @@ var (
NewRunID: RunID2,
ForkEventVersion: Version1,
BinaryChecksum: Checksum,
RequestID: RequestID,
}
ActivityTaskScheduledEventAttributes = types.ActivityTaskScheduledEventAttributes{
ActivityID: ActivityID,
Expand Down Expand Up @@ -416,6 +418,7 @@ var (
SignalName: SignalName,
Input: Payload1,
Identity: Identity,
RequestID: RequestID,
}
WorkflowExecutionTerminatedEventAttributes = types.WorkflowExecutionTerminatedEventAttributes{
Reason: Reason,
Expand All @@ -427,6 +430,7 @@ var (
ExternalInitiatedEventID: common.Int64Ptr(EventID1),
ExternalWorkflowExecution: &WorkflowExecution,
Identity: Identity,
RequestID: RequestID,
}
WorkflowExecutionCanceledEventAttributes = types.WorkflowExecutionCanceledEventAttributes{
DecisionTaskCompletedEventID: EventID1,
Expand Down
2 changes: 1 addition & 1 deletion go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ require (
github.com/startreedata/pinot-client-go v0.2.0 // latest release supports pinot v0.12.0 which is also internal version
github.com/stretchr/testify v1.8.3
github.com/uber-go/tally v3.3.15+incompatible
github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210
github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562
github.com/uber/ringpop-go v0.8.5
github.com/uber/tchannel-go v1.22.2
github.com/urfave/cli v1.22.4
Expand Down
4 changes: 2 additions & 2 deletions go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -444,8 +444,8 @@ github.com/uber-go/tally v3.3.12+incompatible/go.mod h1:YDTIBxdXyOU/sCWilKB4bgyu
github.com/uber-go/tally v3.3.15+incompatible h1:9hLSgNBP28CjIaDmAuRTq9qV+UZY+9PcvAkXO4nNMwg=
github.com/uber-go/tally v3.3.15+incompatible/go.mod h1:YDTIBxdXyOU/sCWilKB4bgyufu1cEi0jdVnRdxvjnmU=
github.com/uber/cadence-idl v0.0.0-20211111101836-d6b70b60eb8c/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210 h1:iuPF2QAZM90Jpx0s+2LnxLN+ElGsxB2JnXKGNLc18+w=
github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562 h1:/G/9GZPDEfZOgKIwjIIuEtFqLh4i4RDySpVvcx6jERY=
github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
github.com/uber/jaeger-client-go v2.22.1+incompatible h1:NHcubEkVbahf9t3p75TOCR83gdUHXjRJvjoBh1yACsM=
github.com/uber/jaeger-client-go v2.22.1+incompatible/go.mod h1:WVhlPFC8FDjOFMMWRy2pZqQJSXxYSwNYOkTr/Z6d3Kk=
github.com/uber/jaeger-lib v2.2.0+incompatible h1:MxZXOiR2JuoANZ3J6DE/U0kSFv/eJ/GfSYVCjK7dyaw=
Expand Down
2 changes: 1 addition & 1 deletion idls
Submodule idls updated from afd574 to cd945b

0 comments on commit fcd8e7d

Please sign in to comment.