945
946
// SyncWorkflowState mocks base method.
947
>
func (m *MockAdminServiceClient) SyncWorkflowState(ctx context.Context, in *adminservice.SyncWorkflowStateRequest, opts ...grpc.CallOption) (*adminservice.SyncWorkflowStateResponse, error) {
service_grpc.pb.mock.go
948
>
m.ctrl.T.Helper()
949
>
varargs := []any{ctx, in}
950
>
for _, a := range opts {
951
varargs = append(varargs, a)
952
}
954
>
ret0, _ := ret[0].(*adminservice.SyncWorkflowStateResponse)
955
>
ret1, _ := ret[1].(error)
956
>
return ret0, ret1
957
}
958
959
// SyncWorkflowState indicates an expected call of SyncWorkflowState.
960
>
func (mr *MockAdminServiceClientMockRecorder) SyncWorkflowState(ctx, in any, opts ...any) *gomock.Call {
service_grpc.pb.mock.go
961
>
mr.mock.ctrl.T.Helper()
962
>
varargs := append([]any{ctx, in}, opts...)
963
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SyncWorkflowState", reflect.TypeOf((*MockAdminServiceClient)(nil).SyncWorkflowState), varargs...)
964
>
}
965
966
// MockAdminService_StreamWorkflowReplicationMessagesClient is a mock of AdminService_StreamWorkflowReplicationMessagesClient interface.