mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
5a601d081b
Full module path rebrand from Temporal to Hanzo Tasks: - go.mod module: github.com/hanzoai/tasks - All internal Go imports updated (1906 files) - cmd/server renamed to cmd/tasksd - Binary name: tasksd (was temporal-server) - Docker images: hanzoai/tasks (was temporalio/server) - README rewritten with Hanzo Tasks branding - LLM.md created with integration notes - Makefile, goreleaser, CI workflows updated - go.temporal.io/sdk and go.temporal.io/api imports preserved (separate repos) Fork of Temporal.io (MIT license).
106 lines
6.7 KiB
Go
106 lines
6.7 KiB
Go
// Code generated by MockGen. DO NOT EDIT.
|
|
// Source: transaction.go
|
|
//
|
|
// Generated by this command:
|
|
//
|
|
// mockgen -package workflow -source transaction.go -destination transaction_mock.go
|
|
//
|
|
|
|
// Package workflow is a generated GoMock package.
|
|
package workflow
|
|
|
|
import (
|
|
context "context"
|
|
reflect "reflect"
|
|
|
|
chasm "github.com/hanzoai/tasks/chasm"
|
|
persistence "github.com/hanzoai/tasks/common/persistence"
|
|
gomock "go.uber.org/mock/gomock"
|
|
)
|
|
|
|
// MockTransaction is a mock of Transaction interface.
|
|
type MockTransaction struct {
|
|
ctrl *gomock.Controller
|
|
recorder *MockTransactionMockRecorder
|
|
isgomock struct{}
|
|
}
|
|
|
|
// MockTransactionMockRecorder is the mock recorder for MockTransaction.
|
|
type MockTransactionMockRecorder struct {
|
|
mock *MockTransaction
|
|
}
|
|
|
|
// NewMockTransaction creates a new mock instance.
|
|
func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction {
|
|
mock := &MockTransaction{ctrl: ctrl}
|
|
mock.recorder = &MockTransactionMockRecorder{mock}
|
|
return mock
|
|
}
|
|
|
|
// EXPECT returns an object that allows the caller to indicate expected use.
|
|
func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder {
|
|
return m.recorder
|
|
}
|
|
|
|
// ConflictResolveWorkflowExecution mocks base method.
|
|
func (m *MockTransaction) ConflictResolveWorkflowExecution(ctx context.Context, conflictResolveMode persistence.ConflictResolveWorkflowMode, archetypeID chasm.ArchetypeID, resetWorkflowFailoverVersion int64, resetWorkflowSnapshot *persistence.WorkflowSnapshot, resetWorkflowEventsSeq []*persistence.WorkflowEvents, newWorkflowFailoverVersion *int64, newWorkflowSnapshot *persistence.WorkflowSnapshot, newWorkflowEventsSeq []*persistence.WorkflowEvents, currentWorkflowFailoverVersion *int64, currentWorkflowMutation *persistence.WorkflowMutation, currentWorkflowEventsSeq []*persistence.WorkflowEvents, isWorkflow bool) (int64, int64, int64, error) {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "ConflictResolveWorkflowExecution", ctx, conflictResolveMode, archetypeID, resetWorkflowFailoverVersion, resetWorkflowSnapshot, resetWorkflowEventsSeq, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, currentWorkflowFailoverVersion, currentWorkflowMutation, currentWorkflowEventsSeq, isWorkflow)
|
|
ret0, _ := ret[0].(int64)
|
|
ret1, _ := ret[1].(int64)
|
|
ret2, _ := ret[2].(int64)
|
|
ret3, _ := ret[3].(error)
|
|
return ret0, ret1, ret2, ret3
|
|
}
|
|
|
|
// ConflictResolveWorkflowExecution indicates an expected call of ConflictResolveWorkflowExecution.
|
|
func (mr *MockTransactionMockRecorder) ConflictResolveWorkflowExecution(ctx, conflictResolveMode, archetypeID, resetWorkflowFailoverVersion, resetWorkflowSnapshot, resetWorkflowEventsSeq, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, currentWorkflowFailoverVersion, currentWorkflowMutation, currentWorkflowEventsSeq, isWorkflow any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ConflictResolveWorkflowExecution", reflect.TypeOf((*MockTransaction)(nil).ConflictResolveWorkflowExecution), ctx, conflictResolveMode, archetypeID, resetWorkflowFailoverVersion, resetWorkflowSnapshot, resetWorkflowEventsSeq, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, currentWorkflowFailoverVersion, currentWorkflowMutation, currentWorkflowEventsSeq, isWorkflow)
|
|
}
|
|
|
|
// CreateWorkflowExecution mocks base method.
|
|
func (m *MockTransaction) CreateWorkflowExecution(ctx context.Context, createMode persistence.CreateWorkflowMode, archetypeID chasm.ArchetypeID, newWorkflowFailoverVersion int64, newWorkflowSnapshot *persistence.WorkflowSnapshot, newWorkflowEventsSeq []*persistence.WorkflowEvents, isWorkflow bool) (int64, error) {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "CreateWorkflowExecution", ctx, createMode, archetypeID, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, isWorkflow)
|
|
ret0, _ := ret[0].(int64)
|
|
ret1, _ := ret[1].(error)
|
|
return ret0, ret1
|
|
}
|
|
|
|
// CreateWorkflowExecution indicates an expected call of CreateWorkflowExecution.
|
|
func (mr *MockTransactionMockRecorder) CreateWorkflowExecution(ctx, createMode, archetypeID, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, isWorkflow any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CreateWorkflowExecution", reflect.TypeOf((*MockTransaction)(nil).CreateWorkflowExecution), ctx, createMode, archetypeID, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, isWorkflow)
|
|
}
|
|
|
|
// SetWorkflowExecution mocks base method.
|
|
func (m *MockTransaction) SetWorkflowExecution(ctx context.Context, archetypeID chasm.ArchetypeID, workflowSnapshot *persistence.WorkflowSnapshot) error {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "SetWorkflowExecution", ctx, archetypeID, workflowSnapshot)
|
|
ret0, _ := ret[0].(error)
|
|
return ret0
|
|
}
|
|
|
|
// SetWorkflowExecution indicates an expected call of SetWorkflowExecution.
|
|
func (mr *MockTransactionMockRecorder) SetWorkflowExecution(ctx, archetypeID, workflowSnapshot any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetWorkflowExecution", reflect.TypeOf((*MockTransaction)(nil).SetWorkflowExecution), ctx, archetypeID, workflowSnapshot)
|
|
}
|
|
|
|
// UpdateWorkflowExecution mocks base method.
|
|
func (m *MockTransaction) UpdateWorkflowExecution(ctx context.Context, updateMode persistence.UpdateWorkflowMode, archetypeID chasm.ArchetypeID, currentWorkflowFailoverVersion int64, currentWorkflowMutation *persistence.WorkflowMutation, currentWorkflowEventsSeq []*persistence.WorkflowEvents, newWorkflowFailoverVersion *int64, newWorkflowSnapshot *persistence.WorkflowSnapshot, newWorkflowEventsSeq []*persistence.WorkflowEvents, isWorkflow bool) (int64, int64, error) {
|
|
m.ctrl.T.Helper()
|
|
ret := m.ctrl.Call(m, "UpdateWorkflowExecution", ctx, updateMode, archetypeID, currentWorkflowFailoverVersion, currentWorkflowMutation, currentWorkflowEventsSeq, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, isWorkflow)
|
|
ret0, _ := ret[0].(int64)
|
|
ret1, _ := ret[1].(int64)
|
|
ret2, _ := ret[2].(error)
|
|
return ret0, ret1, ret2
|
|
}
|
|
|
|
// UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
|
|
func (mr *MockTransactionMockRecorder) UpdateWorkflowExecution(ctx, updateMode, archetypeID, currentWorkflowFailoverVersion, currentWorkflowMutation, currentWorkflowEventsSeq, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, isWorkflow any) *gomock.Call {
|
|
mr.mock.ctrl.T.Helper()
|
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkflowExecution", reflect.TypeOf((*MockTransaction)(nil).UpdateWorkflowExecution), ctx, updateMode, archetypeID, currentWorkflowFailoverVersion, currentWorkflowMutation, currentWorkflowEventsSeq, newWorkflowFailoverVersion, newWorkflowSnapshot, newWorkflowEventsSeq, isWorkflow)
|
|
}
|